关于使用MQ系统解耦的一点思考

原创
2017/11/09 10:20
阅读数 1.9K

MQ使用场景非常多如异步消息处理、系统解耦、数据同步、流量削峰等,经常在一些博文看到这些词语,就拿系统解耦来说,如用户下单后需要通知库存系统进行扣减库存,通知物流系统进行发货,推荐搜索系统等,这些都是和业务息息相关的,所以不允许出现某个系统接收不到消息的情况,而好多博客、文章并没有说明存在这种情况,如果读者不了解就很容易拿到线上的生产环境,不出问题还好,等出现问题那就是大问题。

我们公司使用的是activeMq,而activeMq默认的topic模式,只是发消息给正在订阅的消费者,如果消费者挂了那就收不到消息了,所以需要设置activeMq的topic为持久订阅模式。

方法如下:

一、生产者需要设置消息为持久模式

//通过session 创建producer
MessageProducer producer = session.createProducer(null);  
//设置producer的投递模式为持久模式
producer.setDeliveryMode(DeliveryMode.PERSISTENT);

二、设置客户端的clientID,相同的clientID会认为是一个客户端,后连接的会报错


// 创建connection
connection = connectionFactory.createConnection();
connection.setClientID("bbb"); //持久订阅需要设置这个。
connection.start();

// 创建session
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

// 创建destination
Topic topic = session.createTopic("userSyncTopic"); //Topic名称

MessageConsumer consumer = session.createDurableSubscriber(topic,"bbb"); //持久订阅
展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部