48.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.关闭生产者

public class RocketMQSendMessageTest {

    //发送消息
    public static void main(String[] args) throws MQClientException, RemotingException, InterruptedException, MQBrokerException {
        //1.创建消息生产者，并且设置生产组名
        DefaultMQProducer producer = new DefaultMQProducer("myProducer-group");

        //2.为生产者设置NameServer地址
        producer.setNamesrvAddr("192.168.110.130: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();

    }
}