69 lines
3.2 KiB
Markdown
69 lines
3.2 KiB
Markdown
#### 快速使用
|
||
|
||
##### pom引入：
|
||
|
||
```
|
||
<dependency>
|
||
<groupId>com.njcn</groupId>
|
||
<artifactId>rocket-mq-springboot-starter</artifactId>
|
||
<version>1.0.0</version>
|
||
</dependency>
|
||
```
|
||
|
||
##### 使用问题：
|
||
|
||
* WARN No appenders could be found for logger：启动项目时，会在日志中看到如下告警
|
||
|
||
```
|
||
RocketMQLog:WARN No appenders could be found for logger(io.netty.util.internal.InternalThreadLocalMap).
|
||
RocketMQLog:WARN Please initialize the logger system properly.
|
||
```
|
||
|
||
此时我们只需要在启动类中设置环境变量 [rocketmq.client.logUseSlf4j](http://rocketmq.client.loguseslf4j/) 为 true 明确指定RocketMQ的日志框架
|
||
|
||
```java
|
||
@SpringBootApplication
|
||
public class RocketDemoApplication {
|
||
public static void main(String[] args) {
|
||
/*
|
||
* 指定使用的日志框架，否则将会告警
|
||
* RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.InternalThreadLocalMap).
|
||
* RocketMQLog:WARN Please initialize the logger system properly.
|
||
*/
|
||
System.setProperty("rocketmq.client.logUseSlf4j", "true");
|
||
SpringApplication.run(RocketDemoApplication.class, args);
|
||
}
|
||
}
|
||
```
|
||
|
||
同时还得在配置文件中调整日志级别，不然在控制台会一直看到broker的日志信息
|
||
|
||
```yml
|
||
logging:
|
||
level:
|
||
RocketmqClient: ERROR
|
||
io:
|
||
netty: ERROR
|
||
```
|
||
|
||
#### 1、RocketMQ官方sdk中存在的问题：
|
||
|
||
##### 1.1、不支持LocalDate 和 LocalDateTime
|
||
|
||
原因：RocketMQ内置使用的转换器是**RocketMQMessageConverter**，转换Json时使用的是MappingJackson2MessageConverter，但是这个转换器不支持时间类型。
|
||
|
||
解决办法：需要自定义消息转换器，将MappingJackson2MessageConverter进行替换，并添加支持时间模块。
|
||
|
||
##### 1.2、RockeMQ环境隔离
|
||
|
||
原因：在使用RocketMQ时，通常会在代码中直接指定消息主题(topic)，而且开发环境和测试环境可能共用一个RocketMQ环境。如果没有进行处理，在开发环境发送的消息就可能被测试环境的消费者消费，测试环境发送的消息也可能被开发环境的消费者消费，从而导致数据混乱的问题。
|
||
|
||
解决方法：我们可以根据不同的环境实现自动隔离。通过简单配置一个选项，如dev、test、prod等不同环境，所有的消息都会被自动隔离。例如，当发送的消息主题为consumer_topic时，可以自动在topic后面加上环境后缀，如consumer_topic_dev。
|
||
|
||
详细查看EnvironmentIsolationConfig 配置。
|
||
|
||
##### 1.3、避免大量的重复代码
|
||
|
||
一个完整的消息传递链路：从生产者到消费者应包括 准备消息、发送消息、记录消息日志、发送失败处理、记录接受消息日志、处理业务逻辑、异常处理和异常重试等步骤。
|
||
|
||
虽然原生的rocketMQ可以完成这些动作，但是每个生产者和消费者都需要编写大量重复的代码来完成相同的任务。最终的目的是让开发人员只需要准备好消息实体并用封装后的工具类发送，而消费者只需处理核心业务逻辑，其他公共逻辑会得到统一处理。 |