01 消息訂閱發布開源庫(網易傳媒技術團隊：消息中間件實現延遲隊列的應用與實踐)

關于mosquitto怎么用c語言實現消息的訂閱和發送（mqtt）

1.目標：測試Mosquitto使用MQTT協議發消息的相關性能指標，包含發送速度，并發負載能力，資源占用，消息到達率。

2.MQTT協議簡介：

1).建立長連接。客戶端發起請求和服務端建立長連接，建立成功后，服務端會返回ACK(CONNACK)

2).客戶端訂閱：客戶端發起訂閱，訂閱成功后，服務端會返回ACK(SUBACK)

3).發消息：發布者會給服務端發消息，服務端在把消息給合適的客戶端。

Qos=0(服務質量)：客戶端消息收到后，不會發出ACK給服務端(PUBACK)。

Qos =1:服務端會發ACK給發布者，客戶端收到消息后會發ACK給服務端。

4).取消訂閱：客戶端發起取消訂閱，服務端返回ACK(UNSUBACK)

5)Pingreq&Pingresp:客戶端和服務端會保持心跳。

3.存在問題：

1. 如何模擬出40W的用戶

2. 如何長連接，訂閱，發消息，取消訂閱，Pingreq行為如何實現。

4. python開源庫 Mosquitto.py，解決所有問題

1. 模擬40W用戶

a)可以使用虛擬機和Mosquitto.py實現，具體為：一般一臺虛擬機最多是6W+的模擬數據（需要修改句柄數，我使用5W），方法是Client_id可以簡單的做出5W個來，然后調用Mosquitto里面的買粉絲nnect方法，建立長連接。準備8臺虛擬機就可以實現40W客戶端的模擬

2.行為的模擬

a)訂閱：Mosquitto.subscribe / 發消息：Mosquitto.publish / 取消訂閱：Mosquitto.unsubscribe。 簡單一句話 Mosquitto庫實現所有的行為.

5. 指標：發送速度，到達率，并發負載，資源占用。

a. 發送速度：服務端日志記錄，分析解決

b. 到達率： 1.客戶端記錄下收到消息，分析計算。2.計算服務端收到的PUBACK（客戶端收到消息返回的ACK），進行計算

c. 并發負載：5W 用戶不斷增加，注意觀察服務端的負載情況。

e.資源占用：其實主要是cpu/mem/帶寬：cpu多核的話需要觀察top命令下的_id字段, mem可以觀察買粉絲 -h命令的剩余mem, 帶寬可以使用mpstat進行觀察

6. 可以遇見問題：

a. 模擬客戶端的虛擬機需要修改句柄數才能支持5W的客戶端模擬數量

b. 要先吃透MQTT協議的流程，吃透了進行測試會非常的方便

c. Clear session，設置為true則不為客戶端保留休息，設置為false保留消息。其實就是客戶端離線后在連接上可以收到之前推出的消息。

如何實現服務器給android客戶端主動推送消息

一、消息推送基礎

消息推送，就是在互聯網上通過定期傳送用戶需要的信息來減少信息過載的一項新技術。推送技術通過自動傳送信息給用戶，來減少用于網絡上搜索的時間。它根據用戶的興趣來搜索、過濾信息，并將其定期推給用戶，幫助用戶高效率地發掘有價值的信息

當我們開發需要和服務器交互的移動應用時，基本上都需要和服務器進行交互，包括上傳數據到服務器，同時從服務器上獲取數據。

一般情況下，客戶端與服務器之間通訊客戶端是主動的，但這就存在一個問題就是一旦服務器數據有更新或者服務器要下發通知給客戶端只能等客戶端連接的時候才能實現。這種方式使消息失去了實時性。

如何使客戶端能夠實時的收到服務器的消息和通知，總體來說有兩種方式，第一種是客戶端使用Pull（拉）的方式，就是隔一段時間就去服務器上獲取一下信息，看是否有更新的信息出現。第二種就是 服務器使用Push（推送）的方式，當服務器端有新信息了，則把最新的信息Push到客戶端上。這樣，客戶端就能自動的接收到消息。 

雖然Pull和Push兩種方式都能實現獲取服務器端更新信息的功能，但是明顯來說Push方式比Pull方式更優越。因為Pull方式更費客戶端的網絡流量，更主要的是費電量，還需要我們的程序不停地去監測服務端的變化。  

二、幾種常見的解決方案實現原理

1）輪詢(Pull)方式：客戶端定時向服務器發送詢問消息，一旦服務器有變化則立即同步消息。

2）SMS(Push)方式：通過攔截SMS消息并且解析消息內容來了解服務器的命令，但這種方式一般用戶在經濟上很難承受。

3）持久連接(Push)方式：客戶端和服務器之間建立長久連接，這樣就可以實現消息的及時行和實時性。

三、消息推送解決方案概述

A、C2DM云端推送方案

在Android手機平臺上，Google提供了C2DM（Cloudto Device Messaging）服務。Android Cloud to Device Messaging (C2DM)是一個用來幫助開發者從服務器向Android應用程序發送數據的服務。該服務提供了一個簡單的、輕量級的機制，允許服務器可以通知移動應用程序直接與服務器進行通信，以便于從服務器獲取應用程序更新和用戶數據。

該方案存在的主要問題是C2DM需要依賴于Google官方提供的C2DM服務器，由于國內的網絡環境，這個服務經常不可用。

B、MQTT協議實現Android推送

采用MQTT協議實現Android推送功能也是一種解決方案。MQTT是一個輕量級的消息發布/訂閱協議，它是實現基于手機客戶端的消息推送服務器的理想解決方案。

wmqtt.jar 是IBM提供的MQTT協議的實現。我們可以從這里（買粉絲s://github.買粉絲/toku/AndroidPushNotificationsDemo）下載該項目的實例代碼，并且可以找到一個采用PHP書寫的服務器端實現（買粉絲s://github.買粉絲/toku/PhpMQTTClient）。

C、RSMB實現推送功能

Really Small Message Broker (RSMB) ，是一個簡單的MQTT代理，同樣由IBM提供，其查看地址是：買粉絲://買粉絲.alphaworks.ibm.買粉絲/tech/rsmb。缺省打開1883端口，應用程序當中，它負責接收來自服務器的消息并將其轉發給指定的移動設備。SAM是一個針對MQTT寫的PHP庫。我們可以從這個買粉絲://pecl.php.買粉絲/package/sam/download/0.2.0地址下載它.

D、XMPP協議實現Android推送

Google官方的C2DM服務器底層也是采用XMPP協議進行的封裝。XMPP(可擴展通訊和表示協議)是基于可擴展標記語言（XML）的協議，它用于即時消息（IM）以及在線探測。這個協議可能最終允許因特網用戶向因特網上的其他任何人發送即時消息。

androidpn是一個基于XMPP協議的java開源Android push notification實現。它包含了完整的客戶端和服務器端。但也存在一些不足之處：

1） 比如時間過長時，就再也收不到推送的信息了。

2）性能上也不夠穩定。

3）如果將消息從服務器上推送出去，就不再管理了，不管消息是否成功到達客戶端手機上。

如果我們要使用androidpn，則還需要做大量的工作，需要理解XMPP協議、理解Androidpn的實現機制，需要調試內部存在的BUG。

E、使用第三方平臺

目前國內、國外有一些推送平臺可供使用，但是涉及到收費問題、保密問題、服務質量問題、擴展問題等等，又不得不是我們望而卻步。

四、消息推送完美方案

綜合以上論述，在建立Android消息推送方面可謂方案多多，但每一款方案都有其優缺點。但無論如何，還是自己搭建一個推送平臺是上策。因為你有、他有不如自己有。

舉個例子，在搭建自有推送平臺上建議使用《某某Android消息推送組件》。該組不僅可以拿來即用，并且還可以提供源碼以便擴展，實現自己的特殊需求。

A、推送原理

Android消息推送組件基于XMPP協議實現Android推送。XMPP（可擴展通訊和表示協議）是基于可擴展標記語言（XML）的協議，它用于即時消息（IM）以及在線探測。這個協議可能最終允許因特網用戶向因特網上的其他任何人發送即時消息。

如何實現消息推送功能

消息推送（Push）就是通過服務器把內容主動發送到客戶端的過程。運營人員通過自己的產品或第三方工具對用戶移動設備進行主動消息推送。完成推送后，消息通知會展示在移動設備的鎖定屏幕及通知欄上，用戶點擊通知即可去往相應頁面。

現在流行的消息推送實現方式，主要為長鏈接方式實現。其原理是客戶端主動和服務器建立TCP長鏈接，長鏈接建立之后，客戶端定期向服務器發送心跳包用于保持鏈接，當有消息要發送的時候，服務器可以直接通過這個已經建立好的長鏈接，將消息發送到客戶端。

個推作為國內移動推送領域的早期進入者，于2010年推出個推消息推送SDK產品，十余年來持續為移動開發者提供穩定、高效、智能的消息推送服務，成功服務了人民日報、新華社、CCTV、新浪微博等在內的數十萬APP客戶。個推消息推送，也是運用長鏈接的方式實現消息推送的，其長鏈接穩定性高、存活好，消息送達率高。開發者通過集成個推消息推送SDK，即可簡單、快捷地實現Android和iOS平臺的消息推送功能，有效提高產品活躍度、增加用戶留存。

如果您對個推消息推送感興趣，歡迎前往個推開發者中心免費注冊體驗。

個推的合作客戶

網易傳媒技術團隊：消息中間件實現延遲隊列的應用與實踐

1、有效期：限時活動、拼團。。。

2、超時處理：取消超時未支付訂單、超時自動確認收貨。。。

4、重試：網絡異常重試、打車派單、依賴條件未滿足重試。。。

5、定時任務：智能設備定時啟動。。。

1、RabbitMQ

1）簡介：基于AMQP協議，使用Erlang編寫，實現了一個Broker框架

a、Broker：接收和分發消息的代理服務器

b、Virtual Host：虛擬主機之間相互隔離，可理解為一個虛擬主機對應一個消息服務

c、Exchange：交換機，消息發送到指定虛擬機的交換機上

d、Binding：交換機與隊列綁定，并通過路由策略和routingKey將消息投遞到一個或多個隊列中

e、Queue：存放消息的隊列，FIFO，可持久化

f、Channel：信道，消費者通過信道消費消息，一個TCP連接上可同時創建成百上千個信道，作為消息隔離

<

很赞哦!（14）