最近做的项目的一个版本需求中,需要用到MQ,对数据记录进行异步落库,这样可以减轻数据库的压力,同时可以抗住大量的数据落库。这里需要说明一下本人用到的MQ是公司自己在阿里的RokectMQ的基础上进行封装的,然后加上自己的东西,形成个性化的开发,且安全性高。这里就不多透露相关公司的信息啦,我就叫它MQ。

       由于刚刚从事JAVA开发这个行业不久,所以在使用到这个MQ的时候本人还是比较陌生的,于是花了一些时间去学习,当然学习的时候能记住的东西还是不多的,因为在学习理论的时候,没有真正的去实践,效果不是很明显,就这样学的也是云里雾里。对公司的MQ有了最基本的了解之后,就开始动手撸代码了,在这个需求中引入了公司的MQ依赖jar包,然后在开发环境中配置好相关的MQ信息,写了一个消费MQ的类,当然发消息的代码还是很好写的。

MQ生产者的核心代码:

@Autowired

private MqsTemplate mqsTemplate ;

public void sendMqs(String key, ContentDto dto){

String content = JSON.toJSONString(dto);

mqsTemplate.sendMessage(content, topic, tag, key);

}

MQ消费者的核心代码:

BaseConsumer.java

public abstract class BaseConsumer implements MqsListener<String>{

@Autowired

private TestMapperOne testMapperOne;

@Autowired

private TestMapperTwo testMapperTwo;

@Override

public void onMessage(String topic, String tag, String key, String message){

log.info("topic {} tag {} key {}", topic, tag, key);

try{

this.consumer(key, message, tag);

}catch(Exception e){

log.error(String.format("topic %s tag %s key %s message %s), topic, tag, key, message), e);
}
}
protected abstract void consumer(String key, String message, String tag);
}
TestConsumer.java
@Service
@MqsMessageListener(consumerId = "${自己去MQ的页面去新增就行}"//最开始的写法(错误的写法)
topicTags = ("${haha.mq.topic:TEST_HAHA}:${haha.mq.topic:TEST_TAG01};" +
"${haha.mq.topic:TEST_HAHA}:${haha.mq.topic:TEST_TAG02}")
//在这里对于同一个topic,使用“ ; ”分割是不当的,分号分割是指多个topicTags的topic是不同的,如果这里这样分割的话,
消息发送到MQ去,可以发现消息确实是发送到了MQ,但是没有被消费者消费,这也就是我遇到的坑了,由于开年刚来上班,公司的众
位大佬还没来上班,能问的人又很少,于是自己琢磨了一上午。
最终发现,原来是由于我在同一个项目的同一个类上的唯一topic对应了不同的tag,在MQ的页面可以清晰的看到,后面的tag覆盖了前面的tag,
显然这样是不合理的。 经过查阅资料发现,同一个类上的唯一topic对应不同的tag写法如下 正确写法: topicTags
= ("${haha.mq.topic:TEST_HAHA}:${haha.mq.topic:TEST_TAG01}||" + "${haha.mq.topic:TEST_TAG02}") ) 在同一个类中(也就是一个消费者中),同一个topic对应不同的tag,应该使用 “ || ”进行分割,使用""或“*”订阅所有tag。 public class TestConsumer extends BaseConsumer { //此处代码就不写了,主要就是根据不同的tag,然后把对应的数据请求持久层的接口,进行落库,当然这里我是为了省事,才踩到这样的坑,
其实针对不同的情况,就算是使用同一个topic订阅,分成两个类去写就ok了,在MQ中再新增一个消费者,这样在同一个项目的不同消费者类中,
一个topic对应一个tag。就算它们两个的topic是一样的都是没关系的,而且这样别人看起你的代码来,也是非常直观的,层次分明。
}

PS:这里补充一下

@MqsMessageListener 是消费者监听注解,用于发现消费者,以及属性包括消费所有单一功能的注解,作用在类上面。

以上就是踩到的RocketMQ的坑,由于开发经验有限,技术粗糙,上文的描述可能不是太清晰,可能会出现误点或者错误的地方,望大家给予建议,我加以改进,共同进步!

觉得此文不错的,点赞转发,本人非常感谢!

02-25 11:50