现在项目需要兼容rabbitmq,现在能发送消息了,但是监听消息有什么好的方法么

现在项目需要兼容rabbitmq,现在能发送消息了,但是监听消息有什么好的方法么?不想在afterJFinalStart ()里面添加while(true),能不能像springboot中那样有一个监听的注解类似 @RabbitListener(queues = QUEUE_NAME) 或者其他监听的方式

评论区

JFinal

2019-10-25 15:31

在 onStart() 里面启动一个线程来监听即可:
public void onStart() {
Thread thread = new Thread(() -> {
监听代码在此
});

thread.setDaemon(true);
thread.start();

JFinal

2019-10-25 15:31

注意,这里的 onStart() 就是老版本 jfinal 中的 afterJFinalStart(),老版本的用法现在也支持,建议用 onStart() ,更省代码,也不易打错字母

zzutligang

2019-11-05 11:23

别搞这么麻烦,用paho.mqtt客户端库,很容易实现收到消息的回调

热门反馈

扫码入社