Simple Message Queue (formerly MNS)：主題使用樣本

前提條件

• 已安裝SDK。

• 已配置訪問網域名稱及憑證。

  重要

  • 本文代碼中提及的endpoint從配置訪問網域名稱時的sample.cfg檔案中讀取，accid、acckey和 token從環境變數中讀取。

  • 範例程式碼下載，請參見範例程式碼。

訊息體編碼選擇

對訊息體是否進行Base64編碼，請參見訊息體編碼選擇指南。

發布訊息

• 運行publish_message.py發布多條訊息到主題中，命令如下：

  python publish_message.py MyTopic1        

  返回結果如下：

  ==========Publish Message To Topic==========
  TopicName:MyTopic1
  MessageCount:3
  
  Publish Raw Message Succeed. MessageBody:I am test message 0. MessageID:4EA4CF419C3A7FC67FA95077****0001
  Publish Raw Message Succeed. MessageBody:I am test message 1. MessageID:4EA4CF419C3A7FC67FA95077****0002
  Publish Raw Message Succeed. MessageBody:I am test message 2. MessageID:4EA4CF419C3A7FC67FA95077****0003
  Publish Base64 Encoded Message Succeed. MessageBody:I am test message 0. MessageID:4EA4CF419C3A7FC67FA95077****0004
  Publish Base64 Encoded Message Succeed. MessageBody:I am test message 1. MessageID:4EA4CF419C3A7FC67FA95077****0005
  Publish Base64 Encoded Message Succeed. MessageBody:I am test message 2. MessageID:4EA4CF419C3A7FC67FA95077****0006

• 核心代碼：

  my_account = Account(endpoint, accid, acckey, token)
  topic_name = sys.argv[1] if len(sys.argv) > 1 else "MySampleTopic"
  my_topic = my_account.get_topic(topic_name)
  
  msg_count = 3
  print("%sPublish Message To Topic%s\nTopicName:%s\nMessageCount:%s\n" % (10*"=", 10*"=", topic_name, msg_count))
  
  for i in range(msg_count):
      try:
          msg_body = u"I am test message %s." % i
          msg = TopicMessage(msg_body)
          re_msg = my_topic.publish_message(msg)
          print("Publish Raw Message Succeed. MessageBody:%s MessageID:%s" % (msg_body, re_msg.message_id))
      except MNSExceptionBase as e:
          if e.type == "TopicNotExist":
              print("Topic not exist, please create it.")
              sys.exit(1)
          print("Publish Raw Message Fail. Exception:%s" % e)
  
  for i in range(msg_count):
      try:
          msg_body = u"I am test message %s." % i
          msg = Base64TopicMessage(msg_body)
          re_msg = my_topic.publish_message(msg)
          print("Publish Base64 Encoded Message Succeed. MessageBody:%s MessageID:%s" % (msg_body, re_msg.message_id))
      except MNSExceptionBase as e:
          if e.type == "TopicNotExist":
              print("Topic not exist, please create it.")
              sys.exit(1)
          print("Publish Base64 Encoded Message Fail. Exception:%s" % e)