rocketmq消息发送方式,rocketmq异步发送消息

　　springboot rockermq实现简单的消息发送与接收

　　普通消息的发送方式有3种：单向发送、同步发送和异步发送。

　　下面来介绍下springboot rockermq整合实现普通消息的发送与接收

　　创建跳羚项目，添加rockermq依赖!- rocketMq依赖-依赖关系groupIdorg.apache.rocketmq/groupId artifactIdrocketmq-spring-boot-starter/artifactId版本2 . 2 . 1/版本/依赖关系配置rocketmq#端口服务器：端口： 8083

　　# 配置rocketmqrocketmq:名称-服务器： 127 .0 .0 .133609876 #生产者生产者： #生产者组名，规定在一个应用里面必须唯一组：组1 #消息发送的超时时间默认3000毫秒发送消息超时： 3000 #消息达到4096字节的时候，消息就会被压缩。默认4096压缩消息正文阈值： 4096 #最大的消息限制，默认为128K最大邮件大小： 4194304 #同步消息发送失败重试次数发送失败时重试次数： 3 #在内部发送失败时是否重试其他代理，这个参数在有多个经纪人时才生效重试-下一个-服务器：真#异步消息发送失败重试的次数发送异步失败时的重试次数： 3

　　新建一个控制器来做消息发送：package com。举例。springbootrockeddemo。控制器；导入组织。阿帕奇。火箭MQ。客户。制片人。发送回拨；导入org。阿帕奇。火箭MQ。客户。制片人。发送结果；导入org。阿帕奇。火箭MQ。春天。核心。火箭MQ模板；导入org。spring框架。豆子。工厂。注释。自动连线；导入org。spring框架。网络。绑定。注释。请求映射；导入org。spring框架。网络。绑定。注释。休息控制器；/** * 普通信息的三种方式：同步、异步、单向* @ author qzz */@ RestControllerpublic class RocketMQCOntroller { @ auto wired private RocketMQTemplate RocketMQTemplate；/** * 发送普通消息* convertAndSend(字符串目标，对象有效负载)发送字符串比较方便*/@请求映射(/send )public void send(){ rocket MQ template。convertandsend(测试主题，测试消息)；} /** * 发送同步消息*/@请求映射(/testSyncSend )public void testSyncSend(){//参数一：主题如果想添加标签，可以使用主题：标签的写法//参数二：消息内容发送结果发送结果=rocket MQ模板。同步发送(测试主题，同步消息测试);系统。出去。println(发送结果)；} /** * 发送异步消息*/@请求映射(/testasyncend )public void testasyncend(){//参数一：主题如果想添加标签，可以使用主题：标签的写法//参数二：消息内容//参数三：回调火箭MQ模板。异步发送(测试主题，异步消息测试，new send callback(){ @成功时覆盖公共void(send result send result){ system。出去。println(发送结果)；} @ Override公共void on exception(Throwable Throwable){ system。出去。println(消息发送异常);可投掷的。printstacktrace()；} });} /** * 发送单向消息*/@请求映射(/testone way )public void testone way(){//参数一：主题如果想添加标签，可以使用主题：标签的写法//参数二：消息内容火箭MQ模板。sendoneway(测试主题，单向消息测试);} }跳羚给我们提供了RocketMQTemplate模板类，我们利用这个类可以以多种形式发送消息。

　　发送方法指定主题主题测试题目.

　　新的消息消费者监视RocketMQConsumerListener，监视消息，并消费消息package com . example . spring boot rocettemo . config；import org . Apache . rocket MQ . spring . annotation . rocket MQ messagelistener；导入org . Apache . rocket MQ . spring . core . rocket MQ listener；导入org . spring framework . stereotype . service；/* * * Consume messages *配置rocket MQ Listener * @ author qzz */@ service @ rocket MQ messagelistener(consumer group= test ，Topic= test-topic )公共类RocketMQConsumer Listener实现rocket MQ Listener String { @ override public void on message(strings){ system . out . println( consumer message: s)；}}消费者类要实现RocketMQListener接口，动态指定消息类型字符串。

　　类应该用@RocketMQMessageListener注释，并且应该指定主题主题测试-主题和使用者组测试。

　　简单的消息收发就完成了！

　　启动服务并测试消息使用情况。

　　测试消息：

　　测试异步消息：

　　测试单向消息：

　　好了，消费成功！

　　这就是这篇关于Springboot详细解释RocketMQ发送和接收消息的过程的文章。有关Springboot消息发送和接收的更多信息，请搜索以前关于popular IT的文章或继续浏览下面的相关文章。我希望你以后能更多地支持流行音乐！

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。