全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
消息队列 MQ

步骤三:发送消息

更新时间:2017-12-15 20:42:11

在控制台申请 Topic 资源后,您可以通过控制台发送消息或者调用 SDK/API 发送消息。控制台发送消息主要用于快速验证 Topic 资源的可用性,在生产环境下使用 MQ 建议调用相关的 SDK/API 进行消息发送。

通过控制台发送消息

控制台发送消息步骤如下:

  1. 在 MQ 控制台的左侧菜单栏单击发布管理

  2. 在消息列表中找到您刚刚创建的 Topic,单击右侧操作选项里的发送

  3. 发送消息对话框输入消息的具体内容,单击确定。控制台会返回消息发送成功通知以及相应的 Message ID。

调用 SDK/API 发送消息

在生产环境使用 MQ,建议调用 SDK/API 来进行消息发送。本文以 TCP 协议下调用 Java SDK 为例进行说明。如果需要使用其他协议或者开发语言请参见帮助中心相关文档。

调用 TCP Java SDK 发送消息

  1. 通过下面两种方式可以引入依赖(任选一种):

    • Maven 方式引入依赖:

      <dependency>
         <groupId>com.aliyun.openservices</groupId>
         <artifactId>ons-client</artifactId>
         <version>1.7.0.Final</version>
      </dependency>
      
    • 下载依赖 JAR 包: 下载链接

    说明:关于 TCP 接入点域名,请参见TCP 接入说明

  2. 根据以下说明设置相关参数,运行示例代码:

    public class ProducerTest {
     public static void main(String[] args) {
         Properties properties = new Properties();
         // 您在 MQ 控制台创建的 Producer ID
         properties.put(PropertyKeyConst.ProducerId, "XXX");
         // 鉴权用 AccessKey,在阿里云服务器管理控制台创建
         properties.put(PropertyKeyConst.AccessKey,"XXX");
         // 鉴权用 SecretKey,在阿里云服务器管理控制台创建
         properties.put(PropertyKeyConst.SecretKey, "XXX");
         // 设置 TCP 接入域名(此处以公共云的公网接入为例)
         properties.put(PropertyKeyConst.ONSAddr,
           "http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet");
    
         Producer producer = ONSFactory.createProducer(properties);
         // 在发送消息前,必须调用 start 方法来启动 Producer,只需调用一次即可
         producer.start();
    
         //循环发送消息
         while(true){
             Message msg = new Message( //
                 // 在控制台创建的 Topic,即该消息所属的 Topic 名称
                 "TopicTestMQ",
                 // Message Tag,
                 // 可理解为 Gmail 中的标签,对消息进行再归类,方便 Consumer 指定过滤条件在 MQ 服务器过滤
                 "TagA",
                 // Message Body
                 // 任何二进制形式的数据, MQ 不做任何干预,
                 // 需要 Producer 与 Consumer 协商好一致的序列化和反序列化方式
                 "Hello MQ".getBytes());
             // 设置代表消息的业务关键属性,请尽可能全局唯一,以方便您在无法正常收到消息情况下,可通过 MQ 控制台查询消息并补发
             // 注意:不设置也不会影响消息正常收发
             msg.setKey("ORDERID_100");
             // 发送消息,只要不抛异常就是成功
             // 打印 Message ID,以便用于消息发送状态查询
             SendResult sendResult = producer.send(msg);
             System.out.println("Send Message success. Message ID is: " + sendResult.getMessageId());
         }
    
         // 在应用退出前,可以销毁 Producer 对象
         // 注意:如果不销毁也没有问题
         producer.shutdown();
     }
    }
    

查看消息是否发送成功

消息发送后,您可以在控制台查看消息发送状态,步骤如下:

  1. 在 MQ 控制台左侧菜单栏依次单击消息查询**Message ID 查询**。

  2. 在 Message ID 查询页面输入发送消息后返回的 Message ID,单击搜索查询消息发送状态。

    StoreTime 表示 MQ 服务端存储这条消息的时间。如果查询到此消息,表示消息已经成功发送到服务端。

注意:此步骤演示的是第一次使用 MQ 的场景,此时订阅端从未启动过,所以消息状态显示“暂无消费数据”。要启动订阅端并进行消息订阅请继续下一步操作订阅消息。更多消息状态请参见消息查询

本文导读目录