php實現mqtt源碼

1. 物聯網開發需要什麼技術呢

物聯網開發需要的技術
一：單片機/嵌入式開發
智能硬體，哎，不就是單片機嗎?說到底就是一個微控制器，現在出現的智能手錶，調光LED燈，藍牙開鎖，WiFi插座等等，說到底不就是單片機開發嘛?單片機，電子和通信專業一般都會教51或AVR、計算機系接觸不到。現在流行的Arino也是單片機開發的一種。
但是要做一款智能硬體，技術上只會單片機編程還是不行的。哎呀嘛什麼智能硬體，本質上就是一個電子產品!。所以你要開發一款能拿得出手的智能硬體，電子系統設計必須要會的!
二：網路通信協議
智能硬體與傳統的電子產品最大的差別，就是智能硬體連上了網路。要連上網路，就需要用到網路通信模塊及學習網路通信協議——TCP/IP。
TCP/IP是一個技術的總稱，裡麵包含兩種協議TCP、UDP，位於網路通信分層模型的傳輸層，同時也是由操作系統管理。而HTTP、DNS、URI等這些技術，屬於應用層，位於TCP/UDP之上。同樣，最近物聯網比較流行的，針對計算能力有限的通訊設備而出的MQTT協議，也屬於TCP之上。
為了讓電子產品有聯網的能力，只要在電路設計上給主控晶元連接一個通信模塊，寫好收發網路指令的代碼，剩下的就是電子產品設計了。
三：服務端開發框架
Client/Server架構，即客戶端/伺服器架構。智能硬體連上後台伺服器後，其就是一個客戶端，一個終端。由於單片機中資源受限，實際上是不太可能用HTTP協議的，所以互聯網中通用的Web伺服器開發並不適合這里。有的廠家會在TCP之上自定義協議，有的就移植別人做好的協議比如MQTT，CoAP等等。
服務端開發就比較復雜了。單片機/嵌入式軟體開發還好，只要學習好C語言即可打遍天下無敵手，而服務端開發，用Java呢還是Python還是php?反正Java和Python選一個就好了，嵌入式出身的工程師，一般都會學Python。
Python伺服器端的開發框架種類繁多，Web開發的有Django、FlaskTornado WebServer，TCP伺服器可以用Twisted，等等。MQTT有已經做好的伺服器，像這樣的伺服器不用自己開發，直接部署即可。

2. 如何實現消息推送功能

3. 怎麼實現伺服器給android客戶端主動推送消息

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

常見的解決方案實現原理：

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

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

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

(3)php實現mqtt源碼擴展閱讀：

推送消息注意事項：

1、支持第三方推送內容，是要客戶端和伺服器都支持的，客戶端和伺服器都導入推送SDK。

2、伺服器推送內容，可以精確指定推送時間，推送的具體接收人，用戶群，位置。

3、即推送的維度可以使時間，位置，人群。

4、極光使用了兩種不同的通知方式，一種是推送通知，一種是推送消息。

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

參考資料來源：網路-伺服器

參考資料來源：網路-Android客戶端

參考資料來源：網路-信息推送

4. 請教Nodejs實現XMPP和MQTT協議的具體思路

MQTT是一個輕量級的消息發布/訂閱協議，它是實現基於手機客戶端的消息推送伺服器的理想解決方案。 我們可以從這里下載該項目的實例代碼，並且可以找到一個採用PHP書寫的伺服器端實現。 架構如下所示： wmqtt.jar 是IBM提供的MQTT協議的實現。

5. 如何使用ActiveMQ+MQTT實現Android點對點消息通知

2013-12-20
實現點對點消息通知的關鍵問題
ActiveMQ使用MQTT協議，加上android上的paho包，即可簡單實現消息通知功能，但是mqtt協議只支持topic，而且不能用selector，使得點對點的消息投遞變成問題。
有兩個解決思路：
1、每個clientId，建一個topic...這個辦法對解決消息點對點投遞非常有效，但是有兩個大問題:

隨著用戶數增多，topic數量增多，對管理性要求增大，對內存的管理也有問題。
消息廣播操作也變得非常麻煩，只能一個個的發送了。

2、另一個思路，就是在消息廣播的基礎上，進行點對點控制，實現某些特徵的消息投遞到指定的訂閱者。
這個的實現比較簡單，而且沒有上面方案的大問題。代碼稍微改下即可：
其實就只添加了一個新的類： ClientIdFilterDispatchPolicy
可以git clone所在版本源碼，然後加上這個類，mvn package以後使用。

使用說明
本修改實現mqtt協議使用單個topic，來做消息廣播和點對點的投遞。
1、將本文件夾下的activemq-broker-5.9.0.jar、activemq-spring-5.9.0.jar換掉apache-activemq-5.9.0\lib下的jar。
2、參考本文件夾下activemq.xml，在topic上配置
<dispatchPolicy>
<clientIdFilterDispatchPolicy />
</dispatchPolicy>
3、對於此配置下的所有名稱以.PTP結尾的隊列，
如果要投遞消息的properties里包含PTP_CLIENTID，則系統只會將此消息發給clientId為此值的訂閱者；如果當前沒有此clientId的訂閱者，消息不會被任何人接收到。
如果投遞消息的properties里不包含PTP_CLIENTID，則消息廣播給所有的訂閱者。 跟正常消息投遞一致。

其中後綴.PTP和鍵值PTP_CLIENTID，是可以配置的：
<dispatchPolicy>
<clientIdFilterDispatchPolicy ptpSuffix="" ptpClientId="clientId"/>
</dispatchPolicy>
如上配置，使得此policy下的所有topic都起作用，且消息的properties里獲取clientId的key變成clientId。

消息發布者，如果要對所有人廣播消息，直接發送消息即可。
如果要對指定的消息訂閱者發消息，請在消息里設置接收者的clientId：

message.setStringProperty(PTP_CLIENTID, clientId);則此消息只有指定的訂閱者可以拿到。
簡單測試
兩台android設備使用MQTT協議訂閱到ActiveMQ的同一個topic，clientId分別為mqtt-1001和mqtt1002；
寫代碼發兩條消息，設置消息屬性中PTP_CLIENTID分別為mqtt-1001和mqtt1002；
兩個設備分別接收到自己的消息通知，相互之間沒有影響。還可以測試下如果消息沒有PTP_CLIENTID，兩個都能收到。

6. 請教 MQTT+SAM_PHP Android推送

$result = $conn->connect(SAM_MQTT, array(SAM_HOST => '127.0.0.1', SAM_PORT => 1883)); 樓主知道這句話是什麼意思嗎？推送給全部用戶還不知道如何比較好的去做，但是你可以遍歷你全部的注冊用戶，根據這些用戶的ID逐一推送，android端連接時設備ID使用用戶ID，這方法太笨拙了

7. PHP里 $mqtt->publish("bluerhinos/phpMQTT/patterns",date($patt),0);後面的路徑是什麼意思

兩塊錢解決你的問題。一，可以看出來這個是類對一個封裝好了的方法進行調用，但是沒有具體類的內容，所以不能知道具體作用。既然你知道這個是路徑了，那也沒錯，沒啥意思就是路徑而已。

8. 如何通過php實現mqtt協議

MQTT是一個輕量級的消息發布/訂閱協議，它是實現基於手機客戶端的消息推送伺服器的理想解決方案。

我們可以從這里下載該項目的實例代碼，並且可以找到一個採用PHP書寫的伺服器端實現。

架構如下所示：

9. 用thinkphp 開發萬人在線的聊天室性能跟得上么

首先聊天室主要的瓶頸並不在於用什麼語言做後端，而在於整體處理架構。

當你打算做聊天室的時候你可以自己看看如何解決以下問題：

1. 數據的傳輸（如何及時把收到的數據傳輸給別人）

2. 資料庫的處理（對於數據的操作，萬人在線的聊天室數據量產生肯定很大，那麼怎麼保證資料庫能扛得下去）

3. web伺服器是否有能力對抗那麼大的並發數量

4. 伺服器的帶寬是否能支撐下去

以上四點是基於B/S架構必有的問題，如果並非B/S架構那麼後端也沒必要使用PHP吧？

第一點、可以使用websocket進行解決，但缺點是不能支持舊版本的瀏覽器

（如果需要支持可以使用AJAX輪詢進行處理，但會加大伺服器壓力）

第二點、可以增加緩存層，所有數據先進緩存，然後一定時間把緩存寫入資料庫。前提是需要內存足夠大

（或者可以使用資料庫中間件進行讀寫分離，或者直接分表處理）

第三點、再對WEB伺服器優化後你能做的只有創建集群，用幾台機去緩解壓力

第四點、買帶寬

說白了，沒有一定的金錢做為支持的背景下thinkphp和c做出來的性能相差不大，因為瓶頸並不在它那