Skip to content

java.md

Latest commit

 

History

History
159 lines (135 loc) · 5.03 KB

java.md

File metadata and controls

159 lines (135 loc) · 5.03 KB
Raw

java相关笔记

java 手动配置事务
@Autowired
private DataSource dataSource;

@Bean
public DataSourceTransactionManager dataSourceTransactionManager() {
    DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
    transactionManager.setDataSource(dataSource);
    return transactionManager;
}

@Bean
public TransactionTemplate transactionTemplate(DataSourceTransactionManager dataSourceTransactionManager) {
    TransactionTemplate transactionTemplate = new TransactionTemplate(dataSourceTransactionManager);
    transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
    transactionTemplate.setIsolationLevel(TransactionDefinition.ISOLATION_DEFAULT);
    return transactionTemplate;
}

// 代码中使用 transactionTemplate事务

public boolean result() {
    return template.execute(action -> {
        try {
            int result = userMapper.insert(new User());
            if (result == 1) {
                action.setRollbackOnly();
                return false;
            } else {
                return true;
            }
        } catch (Exception e) {
            action.setRollbackOnly();
        }
        return false;
    });
}
java 通过 创建Bean方式创建rabbitmq 相关队列
@PostConstruct
public void createDelayQueue() {
    //新建exchange
    Exchange exchange = ExchangeBuilder.directExchange(MsgSendQueue.EXCHANGE_NAME).durable(true).build();
    rabbitAdmin.declareExchange(exchange);
    //新建queue
    Queue queue = QueueBuilder.durable(MsgSendQueue.SEND_PACKAGE_DELAY.getQueueName()).withArgument("x-dead-letter-exchange", MsgSendQueue.EXCHANGE_NAME)
            .withArgument("x-dead-letter-routing-key", MsgSendQueue.SEND_PACKAGE_NORMAL.getQueueName())
            .withArgument("x-message-ttl", 60000)
            .build();
    rabbitAdmin.declareQueue(queue);
    //绑定
    rabbitAdmin.declareBinding(BindingBuilder.bind(queue).to(exchange).with(MsgSendQueue.SEND_PACKAGE_DELAY.getQueueName()).noargs());
}
maven 引用本地jar包
 <dependency>
            <groupId>e-iceblue</groupId>
            <artifactId>spire.doc</artifactId>
            <version>4.3.2</version>
            <scope>system</scope>
            <systemPath>${pom.basedir}/src/main/resources/spire-doc/spire.doc-4.3.2.jar</systemPath>
        </dependency>
maven skip test

mvn -Dmaven.test.skip=true -Dmaven.javadoc.skip=true -DskipTests，不执行测试用例，但编译测试用例类生成相应的class文件至target/test-classes下。 -Dmaven.test.skip=true，不执行测试用例，也不编译测试用例类。

maven 下载源码

mvn dependency:sources

maven -e -U -B 相关命令

https://blog.csdn.net/qq_32317661/article/details/81232337 maven deploy -e -U -B 等集成命令

maven 编译源码
<build>
  <plugins>
      <plugin>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-maven-plugin</artifactId>
          <configuration>
              <includeSystemScope>true</includeSystemScope>
          </configuration>
      </plugin>

      <plugin>
          <groupId>org.apache.maven.plugins</groupId>
          <artifactId>maven-source-plugin</artifactId>
          <configuration>
              <attach>true</attach>
          </configuration>
          <executions>
              <execution>
                  <phase>compile</phase>
                  <goals>
                      <goal>jar</goal>
                  </goals>
              </execution>
          </executions>
      </plugin>
  </plugins>
</build>

guava cache

expireAfterAccess: 当缓存项在指定的时间段内没有被读或写就会被回收。

expireAfterWrite：当缓存项在指定的时间段内没有更新就会被回收。

refreshAfterWrite：当缓存项上一次更新操作之后的多久会被刷新。
mongoTemplate 聚合查询
Aggregation aggregation = Aggregation.newAggregation(
            Aggregation.match(Criteria.where("batchId").in(ids)),
            Aggregation.group("batchId", "uniqueId"),
//开启disk磁盘
aggregation.withOptions(Aggregation.newAggregationOptions().
            allowDiskUse(true).build());
    Long start = System.currentTimeMillis();
    List<Object> list = mongoTemplate.aggregate(aggregation.withOptions(Aggregation.newAggregationOptions().
            allowDiskUse(true).build()), Detail.class, Object.class).getMappedResults();

jar包启动 指定配置参数

nohup java -jar xxx.jar --spring.profiles.active=prod > nohup.log 2>&1 &

pom 添加 本地jar

  <dependency>
        <groupId>e-iceblue</groupId>
        <artifactId>spire.doc</artifactId>
        <version>4.3.2</version>
        <scope>system</scope>
        <systemPath>${pom.basedir}/src/main/resources/spire-doc/spire.doc-4.3.2.jar</systemPath>
    </dependency>