mianbin/ops-pro
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1： 这个rabbitTemplate 暂时回撤，对租户有点影响

Browse Source
This commit is contained in:
mianbin 2025-04-17 21:27:45 +08:00
parent 4221869ba3
commit 246a0c47b0
6 changed files with 0 additions and 52 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dependencies/.flattened-pom.xml vendored
View File

@ -135,11 +135,6 @@
<artifactId>spring-boot-starter-mq</artifactId> <artifactId>spring-boot-starter-mq</artifactId>
<version>${revision}</version> <version>${revision}</version>
</dependency> </dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>${rocketmq-spring.version}</version>
</dependency>
<dependency> <dependency>
<groupId>cd.casic.boot</groupId> <groupId>cd.casic.boot</groupId>
<artifactId>spring-boot-starter-mybatis</artifactId> <artifactId>spring-boot-starter-mybatis</artifactId>

8
dependencies/pom.xml vendored
View File

@ -35,8 +35,6 @@
<postgresql.version>42.7.4</postgresql.version> <postgresql.version>42.7.4</postgresql.version>
<!-- <anwena.version>2.1.0</anwena.version>--> <!-- <anwena.version>2.1.0</anwena.version>-->
<anwena.version>2.0.8.3</anwena.version> <anwena.version>2.0.8.3</anwena.version>
<!-- 消息队列 -->
<rocketmq-spring.version>2.3.1</rocketmq-spring.version>
<!-- 服务保障相关 --> <!-- 服务保障相关 -->
<lock4j.version>2.2.7</lock4j.version> <lock4j.version>2.2.7</lock4j.version>
<!-- 监控相关 --> <!-- 监控相关 -->
@ -155,12 +153,6 @@
<version>${revision}</version> <version>${revision}</version>
</dependency> </dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>${rocketmq-spring.version}</version>
</dependency>
<dependency> <dependency>
<groupId>cd.casic.boot</groupId> <groupId>cd.casic.boot</groupId>
<artifactId>spring-boot-starter-mybatis</artifactId> <artifactId>spring-boot-starter-mybatis</artifactId>

6
framework/spring-boot-starter-biz-tenant/pom.xml
View File

@ -59,12 +59,6 @@
<optional>true</optional> <optional>true</optional>
</dependency> </dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<optional>true</optional>
</dependency>
<!-- 工具类相关 --> <!-- 工具类相关 -->
<dependency> <dependency>
<groupId>com.google.guava</groupId> <groupId>com.google.guava</groupId>

5
framework/spring-boot-starter-mq/pom.xml
View File

@ -28,10 +28,5 @@
<artifactId>spring-rabbit</artifactId> <artifactId>spring-rabbit</artifactId>
<optional>true</optional> <optional>true</optional>
</dependency> </dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<optional>true</optional>
</dependency>
</dependencies> </dependencies>
</project> </project>

21
framework/spring-boot-starter-mq/src/main/java/cd/casic/framework/mq/rabbitmq/config/OpsRabbitMQAutoConfiguration.java
View File

@ -1,9 +1,6 @@
package cd.casic.framework.mq.rabbitmq.config; package cd.casic.framework.mq.rabbitmq.config;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter; import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.boot.autoconfigure.AutoConfiguration; import org.springframework.boot.autoconfigure.AutoConfiguration;
@ -28,23 +25,5 @@ public class OpsRabbitMQAutoConfiguration {
return new Jackson2JsonMessageConverter(); return new Jackson2JsonMessageConverter();
} }
/**
* 这里我这样写，默认租户的信息不通过socket 发送，rabbitmq处理流水线相关的消息，因为具有回调
*
* @param connectionFactory
* @return
*/
@Bean
public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMessageConverter(createMessageConverter());
rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
log.debug("收到消息发送异步确认， 消息ID:{}, ack:{}, cause:{}", correlationData.getId(), ack, cause);
}
});
return rabbitTemplate;
}
} }

7
framework/spring-boot-starter-websocket/pom.xml
View File

@ -43,12 +43,6 @@
<artifactId>spring-rabbit</artifactId> <artifactId>spring-rabbit</artifactId>
<optional>true</optional> <optional>true</optional>
</dependency> </dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<optional>true</optional>
</dependency>
<!-- 业务组件 --> <!-- 业务组件 -->
<dependency> <dependency>
<!-- 依赖 tenant 组件？因为广播某个类型的用户时候，需要根据租户过滤下，避免广播到别的租户！--> <!-- 依赖 tenant 组件？因为广播某个类型的用户时候，需要根据租户过滤下，避免广播到别的租户！-->
@ -56,7 +50,6 @@
<artifactId>spring-boot-starter-biz-tenant</artifactId> <artifactId>spring-boot-starter-biz-tenant</artifactId>
<scope>provided</scope> <scope>provided</scope>
</dependency> </dependency>
<!-- Test 测试相关 --> <!-- Test 测试相关 -->
<dependency> <dependency>
<groupId>cd.casic.boot</groupId> <groupId>cd.casic.boot</groupId>