登录千米开放平台ISV控制台，在"我的应用-消息服务-订阅消息"页面，选择需要订阅的消息类型，点击消息后面的"订阅"即可。

消息订阅成功以后，可以在"我的订阅"中看到已经成功订阅的消息。如果需要取消消息的订阅,直接点击"取消订阅"即可。消息取消以后,应用将不会接受到该主题的消息推送。

点击消息主题名称，可以查看每个消息返回的详细字段信息。

调用qianmi.qmcs.user.permit接口给用户(E生活直销商,新零售商家)开通,可以选择只给用户开通部分消息主题,也可以全部开通,具体请看该API的详细入参说明。

• 给用户开通消息的前提是用户已经给应用授权,如果应用尚未获得授权,请先参考用户授权介绍。
• 取消用户的消息服务,请调用qianmi.qmcs.user.cancel接口。
• 若想查看用户已经开通了哪些消息主题,请调用 qianmi.qmcs.user.get接口。
• 可以给不同用户建立不同的消息通道分组，比如区分付费用户和免费用户,优先保证付费用户,就可以通过消息分组来接受不同用户的消息,注意自定义分组名称不能是default或者以default开头,每个应用最多可以建50个不同的分组,某个授权用户只能属于某一个分组，新的分组建立将会导致旧的分组失效。
• 更多的消息主题详细字段信息及消息示例,请参考"文档中心 > 消息文档",详情请点击:消息文档进入。

目前仅支持JAVA和.NET语言,其他语言建议采用API接受消息。通过SDK接受消息,只需要关注接受消息后的业务处理,不需要关心消息重发,确认,长连接的心跳,重连接等操作,SDK内部会自动处理好这一切,开放平台推荐使用SDK接受消息。

public interface MessageHandler {

    /**
     * 消息通道客户端收到消息后，会回调该方法处理具体的业务，处理结果可以通过以下两种方式来表述：
     * 1.抛出异常或设置status.fail()表明消息处理失败，需要消息通道服务端重发
     * 2.不抛出异常，也没有设置status信息，则表明消息处理成功，消息通道服务端不会再投递此消息
     *
     * @param message 消息内容
     * @param status 处理结果，如果调用status.fail()，通道将会择机重发消息；否则，通道认为消息处理成功
     * @throws Exception 消息处理失败，消息通道将会择机重发消息
     */
    public void onMessage(Message message, MessageStatus status) throws Exception;

}

  //创建链接客户端,使用默认分组
  QmcsClient client = new QmcsClient(appkey,appSecret,"default");
  //消息处理
  client.setMessageHandler(new MessageHandler(){
        @Override
        public void onMessage(Message message, MessageStatus status) throws Exception {
            try {
                //以下仅为示例代码,实际业务处理根据自身需要开发
                System.out.println(message.getTopic());
                System.out.println(message.getContent());
            } catch (Exception e){
                 e.printStackTrace();
                 status.fail();//消息处理失败,需要服务端重新推送
            }
        }
  });
  client.connect("ws://mc.api.qianmi.com");//发起连接请求

  //创建链接客户端,使用默认分组
  QmcsClient client = new QmcsClient(appkey,appSecret,"default");
  //消息处理
  client.OnMessage += (s,e) =>
  {
      try
      {
            //以下仅为示例代码,实际业务处理根据自身需要开发
            Console.WriteLine(e.Message.Topic);
            Console.WriteLine(e.Message.Content);
      }
      catch (Exception exp)
      {
            Console.WriteLine(exp.StackTrace);
            e.Fail();   //消息处理失败，需要服务端重新推送
      }
  };
  client.Connect("ws://mc.api.qianmi.com");//发起连接请求

由于很多语言无法保障多线程和长连接处理,或者处理起来非常不方便,比如PHP,Python等,这些语言官方暂时未提供SDK接受消息方式,可以通过API方式来消费和确认消息,下面将对如何使用API方式获取消息做详细说明:

  OpenClient client = new DefaultOpenClient(url,appkey,appSecret);
  do {
    Integer quantity = 100;
    String groupName = "default";
    QmcsMessagesConsumeResponse rsp = null;
    do {
        QmcsMessagesConsumeRequest req = new QmcsMessagesConsumeRequest();
        req.setQuantity(quantity);
        req.setGroupName(groupName);
        rsp = client.execute(req);
        if (rsp.isSuccess() && rsp.getQmcs_messages() != null) {
            for (QmcsMessage msg : rsp.getQmcs_messages()) {
                // 处理消息,这里仅为示例代码,实际业务根据自身需要开发
                System.out.println(msg.getContent());
                System.out.println(msg.getTopic());
                // 确认消费状态
                QmcsMessagesConfirmRequest cReq = new QmcsMessagesConfirmRequest();
                cReq.setSMessageIds(msg.getId());
                QmcsMessagesConfirmResponse cRsp = client.execute(cReq);
                System.out.println(cRsp.isSuccess());
            }
        }
        System.out.println(rsp.getBody());
    } while (rsp != null && rsp.isSuccess() && rsp.getQmcs_messages() != null );
    Thread.sleep(5000L); //根据自身服务器处理能力合理设置轮训时间
  } while (true);

  IOpenClient client = new DefaultOpenClient(url,appkey,appSecret);
  do
  {
    int quantity = 100;
    string groupName = "default";
    QmcsMessagesConsumeResponse rsp = null;
    do
    {
        QmcsMessagesConsumeRequest req = new QmcsMessagesConsumeRequest();
        req.setQuantity(quantity);
        req.setGroupName(groupName);
        rsp = client.execute(req);
        if (!rsp.IsError && rsp.QmcsMessages != null)
        {
            foreach (QmcsMessage msg in rsp.QmcsMessages)
            {
                // 处理消息,这里仅为示例代码,实际业务根据自身需要开发
                Console.WriteLine(msg.Topic);
                Console.WriteLine(msg.Content);
                // 确认消费状态
                QmcsMessagesConfirmRequest cReq = new QmcsMessagesConfirmRequest();
                cReq.setSMessageIds(msg.Id);
                QmcsMessagesConfirmResponse cRsp = client.execute(cReq);
                Console.WriteLine(cRsp.IsError);
            }
        }
        Console.WriteLine(rsp.Body);
    } while (rsp != null && !rsp.IsError && rsp.QmcsMessages != null );
    Thread.sleep(new TimeSpan(0, 0, 5)); //根据自身服务器处理能力合理设置轮训时间
  } while (true);

一般在线订购应用,如果用户很多的情况,应用部署在多台服务器上面,组成了集群来接受消息,或者需要对当前用户进行消息隔离,分别处理,都可以通过设置分组的方式通过多连接来获取消息。

如果消息通过SDK主动推送方式获取,多连接有两种方式:1.创建多个用户分组,为每个分组创建一个连接通道;2.为同一个分组创建多个连接通道(同一应用使用同一分组最多可以创建5个连接通道)。

• 创建分组: 调用qianmi.qmcs.group.add接口创建自定义分组,用户默认属于default分组,添加自定义分组名称不能是"default"或者以"default"开头,通过SDK或者API消费消息时如果不指定分组,则表示采用默认分组连接,每个应用最多只能创建50个自定义分组,每个分组用户数量不限,但是某个授权用户只能属于某一个分组，新的分组建立将会导致旧的分组失效。
• 删除分组: 调用qianmi.qmcs.group.delete接口删除指定的分组,或者分组下的某些用户,分组删除以后,用户的消息将会存到default默认分组中,之前没有消费的自定义分组消息将无法再次获取。