首页 > 其他好文 > 详细

rocketmq

时间：2020-01-06 14:55:32 阅读：67 评论：0 收藏：0 [点我收藏+]

标签：static sage star byte tde 启动指定集群 shu

点击查看折叠代码块

/**

普通消息生产者
*/
public class Producer {
public static void main(String[] args) throws Exception {
// 创建一个消息发送入口对象，主要用于消息发送，指定生产者组
DefaultMQProducer producer = new DefaultMQProducer("producerGroup");
// 设置NameServe地址，如果是集群环境，用分号隔开
producer.setNamesrvAddr("127.0.0.1:9876");
// 启动并创建消息发送组件
producer.start();
// topic的名字
String topic = "rocketDemo1";
// 标签名
String taget = "tag";
// 要发送的数据
String body = "hello,RocketMq";
Message message = new Message(topic,taget,body.getBytes());
// 发送消息
SendResult result = producer.send(message);
System.out.println(result);
// 关闭消息发送对象
producer.shutdown();
}
}

标签：static sage star byte tde 启动指定集群 shu

原文地址：https://www.cnblogs.com/kaischoolmate/p/12155929.html

踩

(0)

赞

(0)

举报

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行

更多

友情链接

兰亭集智国之画百度统计站长统计阿里云 chrome插件新版天听网

关于我们 - 联系我们 - 留言反馈

© 2014 mamicode.com 版权所有联系我们:gaon5@hotmail.com

迷上了代码！