码迷，mamicode.com
首页 > Web开发 > 详细

MQTT的学习研究（七）基于HTTP POST MQTT 发布消息服务端使用

时间：2015-07-01 18:06:48      阅读：148      评论：0      收藏：0      [点我收藏+]

标签：

参阅官方文档

 

http://publib.boulder.ibm.com/infocenter/wmqv7/v7r0/topic/com.ibm.mq.csqzau.doc/ts21220_.htm

 

 

           HTTP POST puts a message to a queue, or a publication to a topic. The HTTPPOST Java sample is an example an HTTP POST request of a message to a queue. Instead of using Java, you could create an HTTPPOST request using a browser form, or an AJAX toolkit instead.

Figure 1 shows an HTTP request to put a message on a queue called myQueue. This request contains the HTTP header x-msg-correlId to set the correlation ID of the WebSphere MQ message.

Figure 1. Example of an HTTP POST request to a queue 
POST /msg/queue/myQueue/ HTTP/1.1
Host: www.example.org
Content-Type: text/plain
x-msg-correlID: 1234567890
Content-Length: 50

Here‘s my message body that will appear on the queue.

Figure 2 shows the response sent back to the client. There is no response content.

Figure 2. Example of an HTTP POST response 
HTTP/1.1 200 OK
Date: Wed, 2 Jan 2007 22:38:34 GMT
Server: Apache-Coyote/1.1 WMQ-HTTP/1.1 JEE-Bridge/1.1
Content-Length: 0

 

请求的协议格式和请求的响应格式

 

The HTTP POST operation puts a message on a WebSphere® MQ queue, or publishes a message to a topic.

Syntax

Request

>>-POST-- --| Path |-- --HTTP version--CRLF--------------------->

   .-CRLF---------------.  .-CRLF---------------.   
   V                    |  V                    |   
>----+----------------+-+----+----------------+-+--------------->
     ‘-general-header-‘      ‘-request-header-‘     

   .-CRLF----------------------------.        .-CRLF----.   
   V                                 |        V         |   
>----+-----------------------------+-+--CRLF----Message-+------><
     ‘-| entity header (Request) |-‘                        

Path

|--/--contextRoot--/-------------------------------------------->

>--msg/--+-queue/--queueName--+-------------+-+--/--------------|
         |                    ‘-@--qMgrName-‘ |      
         ‘-topic/--topicName------------------‘      

entity-header (Request)

|--+----------------------------------------------+-------------|
   +-standard entity-header-- --entity-value------+   
   +-x-msg-class-- --message type-----------------+   
   +-x-msg-correlId-- --correlation ID------------+   
   +-x-msg-encoding-- --encoding type-------------+   
   +-x-msg-expiry-- --duration--------------------+   
   +-x-msg-format-- --message format--------------+   
   +-x-msg-msgId-- --message ID-------------------+   
   +-x-msg-persistence-- --persistence------------+   
   +-x-msg-priority-- --priority class------------+   
   +-x-msg-replyTo-- --reply-to queue-------------+   
   +-x-msg-require-headers-- --entity header name-+   
   ‘-x-msg-usr-- --user properties----------------‘   
Note:
  1. If a question mark (?) is used it must be substituted with %3f. For example, orange?topic should be specified as orange%3ftopic.
  2. @qMgrName is only valid on an HTTP POST
Response

>>-HTTP version-- --HTTP Status-Code-- --HTTP Reason-Phrase--CRLF-->

   .-CRLF---------------.  .-CRLF----------------.   
   V                    |  V                     |   
>----+----------------+-+----+-----------------+-+-------------->
     ‘-general-header-‘      ‘-response-header-‘     

   .-CRLF-----------------------------.   
   V                                  |   
>----+------------------------------+-+------------------------><
     ‘-| entity-header (Response) |-‘     

entity-header (Response)

|--+-----------------------------------------+------------------|
   +-standard entity-header-- --entity-value-+   
   +-x-msg-class-- --message type------------+   
   +-x-msg-correlId-- --correlation ID-------+   
   +-x-msg-encoding-- --encoding type--------+   
   +-x-msg-expiry-- --duration---------------+   
   +-x-msg-format-- --message format---------+   
   +-x-msg-msgId-- --message ID--------------+   
   +-x-msg-persistence-- --persistence-------+   
   +-x-msg-priority-- --priority class-------+   
   +-x-msg-replyTo-- --reply-to queue--------+   
   +-x-msg-timestamp-- --HTTP-date-----------+   
   ‘-x-msg-usr-- --user properties-----------‘   
HTTP POST方式实现如下：
Java代码  技术分享
  1. package com.etrip.mqttv3.http;  
  2.   
  3.   
  4.   
  5. /** 
  6.  * This sample shows how to post a message. It has the same behaviour as the 
  7.  * amqsput command in that it will read in lines from the command line and put 
  8.  * them to the queue. It will put non-persistent String messages on to the queue 
  9.  * with UNLIMITED expiry and LOW (0) priority. The program is terminated by 
  10.  * either EOF being put into the entry line (^Z on windows) or a blank line. 
  11.  * usage: java HTTPPOST <Queue (default=SYSTEM.DEFAULT.LOCAL.QUEUE)> <host:port 
  12.  * (default localhost:8080> <context-root (the MQ Bridge for HTTP‘s 
  13.  * context-root)> 
  14.  */  
  15.   
  16. import java.io.BufferedReader;  
  17. import java.io.BufferedWriter;  
  18. import java.io.IOException;  
  19. import java.io.InputStreamReader;  
  20. import java.io.OutputStream;  
  21. import java.io.OutputStreamWriter;  
  22. import java.net.HttpURLConnection;  
  23. import java.net.MalformedURLException;  
  24. import java.net.URL;  
  25. /** 
  26.  *  
  27.  * 采用HTTP POST发布相关的消息  
  28.  *     The HTTP POST operation puts a message on a WebSphere® MQ queue, or publishes 
  29.  *  a message to a topic.  
  30.  *   
  31.  *  发布消息到主题或者队列的路径： 
  32.  *   
  33.  *   
  34.  *   
  35.  *   
  36.  *  
  37.  * @author longgangbai 
  38.  */  
  39. public class HTTPPOST  
  40. {  
  41.    private static final String DEFAULT_HOST = "localhost";  
  42.    private static final String DEFAULT_PORT = "8080";  
  43.    private static final String DEFAULT_QUEUE = "SYSTEM.DEFAULT.LOCAL.QUEUE";  
  44.   
  45.    private static final String DEFAULT_CONTEXT_ROOT = "mq";  
  46.   
  47.    private static final String CRLF = "\r\n";  
  48.   
  49.    public static int MALFORMED_URL_EXCEPTION_RC = -1;  
  50.   
  51.    public static int END_IOEXCEPTION_RC = -2;  
  52.   
  53.    /** 
  54.     * 构建发布主题队列路径 
  55.     *  
  56.     * @param host 
  57.     * @param port 
  58.     * @param context 
  59.     * @param queueName 
  60.     */  
  61.     private static String getPublishQueueURL(String host, String port,  
  62.             String context, String queueName) {  
  63.         StringBuffer urlString =new StringBuffer("http://");  
  64.            if(StringUtils.isEmtry(host)){  
  65.                host=DEFAULT_HOST;  
  66.            }  
  67.              
  68.            if(StringUtils.isEmtry(port)){  
  69.                port=DEFAULT_PORT;  
  70.            }  
  71.            urlString.append(host).append(":").append(port);  
  72.            if(StringUtils.isEmtry(context)){  
  73.                context=DEFAULT_CONTEXT_ROOT;  
  74.            }  
  75.            urlString.append("/");  
  76.            urlString.append(context);  
  77.            urlString.append("/msg/queue/");  
  78.            if(StringUtils.isEmtry(queueName)){  
  79.            }  
  80.            queueName=DEFAULT_QUEUE;  
  81.            urlString.append(queueName);  
  82.            System.out.println("urlString="+urlString);  
  83.            return urlString.toString();  
  84.     }  
  85.      
  86.     /** 
  87.      *   
  88.      * @param host 
  89.      * @param port 
  90.      * @param context 
  91.      * @param queueName 
  92.      * @param message 
  93.      * @return 
  94.      * @throws MalformedURLException 
  95.      */  
  96.        public static boolean publishTopic(String host,String port,String context,String queueName,String message ){  
  97.            boolean response = true;     
  98.            HttpURLConnection connection=null;  
  99.            try {  
  100.                     String publishURL=getPublishQueueURL(host, port, context, queueName);  
  101.                       URL url=new URL(publishURL);  
  102.                       connection = (HttpURLConnection) url.openConnection();  
  103.   
  104.                       /* Build the headers */  
  105.                       // the verb first  
  106.                       connection.setRequestMethod("POST");  
  107.   
  108.                       // Content type is a string message  
  109.                       connection.setRequestProperty("content-type", "text/plain");  
  110.   
  111.                       // set the message priority to low  
  112.                       connection.setRequestProperty("x-msg-priority", "LOW");  
  113.   
  114.                       // Ensure we can get the output stream from the connection  
  115.                       connection.setDoOutput(true);  
  116.   
  117.                       OutputStream outputStream = connection.getOutputStream();  
  118.                       // wrapper the outputstream in a writer  
  119.                       BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(  
  120.                             outputStream));  
  121.   
  122.                       // Now write the actual content.  
  123.                       // Make sure the CRLF is there in case some HTTP servers don‘t understand  
  124.                       // that it‘s the end of the message  
  125.                       writer.write(message + CRLF + CRLF);  
  126.                       writer.flush();  
  127.   
  128.                       // now actually send the message  
  129.                       connection.connect();  
  130.                        
  131.                       // check the response for errors  
  132.                       int responseCode = connection.getResponseCode();  
  133.                     if (responseCode != 200)  
  134.                       {  
  135.                            
  136.                           String responseMessage =connection.getResponseMessage();  
  137.                           System.out.println("responsere sponseCode "+responseCode+" response request ="+responseMessage);  
  138.                           System.out.println("responsere context ");  
  139.                          BufferedReader reader = new BufferedReader(new InputStreamReader(  
  140.                                  connection.getErrorStream()));  
  141.                            String line = null;  
  142.                            while ((line = reader.readLine()) != null)  
  143.                            {  
  144.                               System.out.println(line);  
  145.                            }  
  146.                          connection.disconnect();  
  147.                          response = false;  
  148.                       }else{  
  149.                           //获取相应的消息头信息  
  150.                           String responseQueueName=connection.getHeaderField("x-msg-replyTo");  
  151.                           System.out.println("responseQueueName="+responseQueueName);  
  152.                           System.out.println("response successful context :"+connection.getResponseMessage());  
  153.                       }  
  154.             } catch (MalformedURLException e) {  
  155.                 response = false;  
  156.                 e.printStackTrace();  
  157.                 // TODO: handle exception  
  158.             } catch (IOException e) {  
  159.                  response = false;  
  160.                 // TODO Auto-generated catch block  
  161.                 e.printStackTrace();  
  162.             }finally{  
  163.                 connection.disconnect();  
  164.             }  
  165.             return response;  
  166.        }  
  167.          
  168.        public static void main(String[] args) {  
  169.            HTTPPOST.publishTopic("192.168.208.46", "8080", "mq", "java_lover", "this is a message ");  
  170.        }  
  171. }  
 
HTTP POST 发布主题请求协议和响应协议
http://publib.boulder.ibm.com/infocenter/wmqv7/v7r0/topic/com.ibm.mq.csqzau.doc/ts21220_.htm
请求响应头各个字段的含义的讲解
http://publib.boulder.ibm.com/infocenter/wmqv7/v7r0/topic/com.ibm.mq.csqzau.doc/ts21250_.htm

响应错误处理
http://publib.boulder.ibm.com/infocenter/wmqv7/v7r0/topic/com.ibm.mq.csqzau.doc/ts21340_.htm

MQTT的学习研究（七）基于HTTP POST MQTT 发布消息服务端使用

标签：

原文地址：http://www.cnblogs.com/yudar/p/4613745.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)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！