Java实现消息发送

消息发送和接收演示

接下来我们使用Java代码来演示消息的发送和接收

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.0.2</version>
</dependency>

发送消息

消息发送步骤:

1. 创建消息生产者, 指定生产者所属的组名

2. 指定Nameserver地址

3. 启动生产者

4. 创建消息对象，指定主题、标签和消息体

5. 发送消息

6. 关闭生产者

package com.leon.test;import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.spring.core.RocketMQTemplate;public class RocketMQSendMessageTest {//发送消息public static void main(String[] args) throws Exception {//1.创建消息生产者,并且设置生产组名DefaultMQProducer producer = new DefaultMQProducer("myproducer-group");//2 为生产者设置NameServer的地址producer.setNamesrvAddr("192.168.109.131:9876");//3 启动生产者producer.start();//4 构建消息对象,主要是设置消息的主题 标签 内容Message message = new Message("myTopic", "myTag", ("Test RocketMQ Message").getBytes());//5 发送消息 第二个参数代表超时时间SendResult result = producer.send(message, 10000);System.out.println(result);//6 关闭生产者producer.shutdown();}
}

Java实现消息发送相关推荐

JAVA ActiveMQ消息发送和接收
JMS即Java消息服务(Java Message Service)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信. ...
java微信消息发送消息_JAVA模拟微信消息发送请求
JavaWeb模拟微信(网页版)发送消息到好友.PS:不是公众号,是好友之间,或者发送到群. 1.发送文字消息到好友,或群. 2.分析参数: 这里写图片描述 {\"BaseRequest\& ...
服务器怎么把信息发送给用户,java中怎么用tcp/ip将服务器的消息发送给多个用户...
java中怎么用tcp/ip将服务器的消息发送给多个用户关注:253 答案:2 mip版解决时间 2021-01-31 01:26 提问者╬═掵中注定 2021-01-30 20:03 jav ...
java开发微信第三方平台模板消息发送消息案例
今天利用自己的一点休息时间来编写了一个利用java开发的微信第三方平台,这次开发的目地是利用微信的模板消息无限的向关注用户推送消息.经过反复的测试,无BUG出现. 开发语言:java,数据库:mysq ...
java activeMQ消息的发送与接收
java activeMQ消息的发送与接收 activemq是我们经常用到的消息队列之一,比如说速度快,对spring的很好的支持,支持多种协议等等,今天我们就来看一下activeMQ消息的发送与接收 ...
java kafka消息的发送与接收
java kafka消息的发送与接收消息队列在java EE级开发是很常用到的工具之一,在众多消息队列当中,active mq与kafka相对比较受开发者的喜爱,那么kafka是怎样实现消息的发送与 ...
java发送ipmsg_用Java向IPMSG发送消息
# re: 用Java向IPMSG发送消息 hehe but No File Packages Defined on sourceforge. IP MSG程序效率写的很高曲强 Nicky 评论于 ...
javasocket连续给服务器发送消息,Java通过Socket发送和接收多条消息
我们需要实现一个Socket客户端,它应该连接到一个接受TCP连接的服务器.如果我通过netcap与服务器进行通信,我会立即得到它的响应(通过命令行).Java通过Socket发送和接收多条消息的工 ...
java企业微信消息发送工具类
java企业微信消息发送工具类用途基于java实现调用企业微信发送消息,文件,图片. 实现效果文件列表文件名用途 WechatUtil.java 企业微信工具类 WechatTest.jav ...

Java实现消息发送

消息发送和接收演示

发送消息

Java实现消息发送相关推荐

最新文章

热门文章