MQTT – 4. MQTT Broker

Posted on 2020-11-23 by hoyo

—

MQTT broker

Broker 幾乎都是 Erlang 的天下

後續考量 MySQL 身份認證、SSL、平台支援、ACL 訂閱限制，最後選擇 EMQ X

—

EMQ X

不得不說，大陸的軟體就是好用，設想的較為周全，文件也齊全，平台支援性也完整

CentOS 7

# wget https://www.emqx.io/downloads/broker/v4.2.3/emqx-centos7-4.2.3-x86_64.rpm

# rpm -ivh emqx-centos7-4.2.3-x86_64.rpm

# emqx start

Ubuntu 20

# wget https://www.emqx.io/cn/downloads/broker/v4.2.2/emqx-ubuntu20.04-4.2.2-x86_64.deb

# dpkg -i emqx-ubuntu20.04-4.2.2-x86_64.deb

# emqx start

—

VerneMQ

CentOS 7

Installing on CentOS and RHEL

下載安裝後不要傻傻的按照官方的說法直接啟動服務，那是不會成功的，還要先設定設定檔才行

-- Unit vernemq.service has begun starting up.

Nov 15 14:39:18 hoyoserver vernemq[3427]: Before you can continue, the product license

Nov 15 14:39:18 hoyoserver vernemq[3427]: must be accepted. The license can be viewed at

Nov 15 14:39:18 hoyoserver vernemq[3427]: https://vernemq.com/end-user-license-agreement

Nov 15 14:39:18 hoyoserver vernemq[3427]: If you do not accept this license you will

Nov 15 14:39:18 hoyoserver vernemq[3427]: not be able to use VerneMQ.

Nov 15 14:39:18 hoyoserver vernemq[3427]: Accepting the product license will modify the

Nov 15 14:39:18 hoyoserver vernemq[3427]: VerneMQ config file

Nov 15 14:39:18 hoyoserver vernemq[3427]: /etc/vernemq/vernemq.conf

Nov 15 14:39:18 hoyoserver systemd[1]: vernemq.service: control process exited, code=exited status=2

Nov 15 14:39:18 hoyoserver vernemq[3427]: setting the "accept_eula" config to "yes".

Nov 15 14:39:18 hoyoserver vernemq[3427]: Product license not accepted. Stopping.

Nov 15 14:39:18 hoyoserver systemd[1]: Failed to start VerneMQ Server.

1	# vi /etc/vernemq/vernemq.conf

1 2	accept_eula = yes listener.tcp.default = 0.0.0.0:1883

Ubuntu 20 – Docker

使用 dpkg 安裝 deb ，出現 libss 版本不符錯誤，目前找不到解決方法，改採 Docker 方式使用

1	# docker run -p 1883:1883 -p 8888:8888 -e "DOCKER_VERNEMQ_ACCEPT_EULA=yes" -e "DOCKER_VERNEMQ_ALLOW_ANONYMOUS=on" --name vernemq1 -d vernemq/vernemq

使用 netstat 查詢轉址無法判斷，直接測試使用即可

開機啟動

1	# docker update --restart=always <CONTAINER ID>

Dockerfile

Dockerfile

FROM debian:stretch-slim

RUN apt-get update && \

apt-get -y install bash procps openssl iproute2 curl jq libsnappy-dev net-tools && \

rm -rf /var/lib/apt/lists/* && \

addgroup --gid 10000 vernemq && \

adduser --uid 10000 --system --ingroup vernemq --home /vernemq --disabled-password vernemq

WORKDIR /vernemq

# Defaults

ENV DOCKER_VERNEMQ_KUBERNETES_LABEL_SELECTOR="app=vernemq" \

DOCKER_VERNEMQ_LOG__CONSOLE=console \

PATH="/vernemq/bin:$PATH" \

VERNEMQ_VERSION="1.11.0"

COPY --chown=10000:10000 bin/vernemq.sh /usr/sbin/start_vernemq

COPY --chown=10000:10000 files/vm.args /vernemq/etc/vm.args

ADD https://github.com/vernemq/vernemq/releases/download/$VERNEMQ_VERSION/vernemq-$VERNEMQ_VERSION.stretch.tar.gz /tmp

RUN tar -xzvf /tmp/vernemq-$VERNEMQ_VERSION.stretch.tar.gz && \

rm /tmp/vernemq-$VERNEMQ_VERSION.stretch.tar.gz && \

chown -R 10000:10000 /vernemq && \

ln -s /vernemq/etc /etc/vernemq && \

ln -s /vernemq/data /var/lib/vernemq && \

ln -s /vernemq/log /var/log/vernemq

# Ports

# 1883 MQTT

# 8883 MQTT/SSL

# 8080 MQTT WebSockets

# 44053 VerneMQ Message Distribution

# 4369 EPMD - Erlang Port Mapper Daemon

# 8888 Prometheus Metrics

# 9100 9101 9102 9103 9104 9105 9106 9107 9108 9109 Specific Distributed Erlang Port Range

EXPOSE 1883 8883 8080 44053 4369 8888 \

9100 9101 9102 9103 9104 9105 9106 9107 9108 9109

VOLUME ["/vernemq/log", "/vernemq/data", "/vernemq/etc"]

HEALTHCHECK CMD vernemq ping | grep -q pong

USER vernemq

CMD ["start_vernemq"]

啟動自動執行 /usr/sbin/start_vernemq

start_vernemq

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

#!/usr/bin/env bash

NET_INTERFACE=$(route | grep '^default' | grep -o '[^ ]*$')

NET_INTERFACE=${DOCKER_NET_INTERFACE:-${NET_INTERFACE}}

IP_ADDRESS=$(ip -4 addr show ${NET_INTERFACE} | grep -oE '[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}' | sed -e "s/^[[:space:]]*//" | head -n 1)

IP_ADDRESS=${DOCKER_IP_ADDRESS:-${IP_ADDRESS}}

# Ensure the Erlang node name is set correctly

if env | grep "DOCKER_VERNEMQ_NODENAME" -q; then

sed -i.bak -r "s/-name VerneMQ@.+/-name VerneMQ@${DOCKER_VERNEMQ_NODENAME}/" /vernemq/etc/vm.args

else

if [ -n "$DOCKER_VERNEMQ_SWARM" ]; then

NODENAME=$(hostname -i)

sed -i.bak -r "s/VerneMQ@.+/VerneMQ@${NODENAME}/" /etc/vernemq/vm.args

else

sed -i.bak -r "s/-name VerneMQ@.+/-name VerneMQ@${IP_ADDRESS}/" /vernemq/etc/vm.args

if env | grep "DOCKER_VERNEMQ_DISCOVERY_NODE" -q; then

discovery_node=$DOCKER_VERNEMQ_DISCOVERY_NODE

if [ -n "$DOCKER_VERNEMQ_SWARM" ]; then

tmp=''

while [[ -z "$tmp" ]]; do

tmp=$(getent hosts tasks.$discovery_node | awk '{print $1}' | head -n 1)

sleep 1

done

discovery_node=$tmp

if [ -n "$DOCKER_VERNEMQ_COMPOSE" ]; then

tmp=''

while [[ -z "$tmp" ]]; do

tmp=$(getent hosts $discovery_node | awk '{print $1}' | head -n 1)

sleep 1

done

discovery_node=$tmp

sed -i.bak -r "/-eval.+/d" /vernemq/etc/vm.args

echo "-eval \"vmq_server_cmd:node_join('VerneMQ@$discovery_node')\"" >> /vernemq/etc/vm.args

# If you encounter "SSL certification error (subject name does not match the host name)", you may try to set DOCKER_VERNEMQ_KUBERNETES_INSECURE to "1".

insecure=""

if env | grep "DOCKER_VERNEMQ_KUBERNETES_INSECURE" -q; then

insecure="--insecure"

if env | grep "DOCKER_VERNEMQ_DISCOVERY_KUBERNETES" -q; then

DOCKER_VERNEMQ_KUBERNETES_CLUSTER_NAME=${DOCKER_VERNEMQ_KUBERNETES_CLUSTER_NAME:-cluster.local}

# Let's get the namespace if it isn't set

DOCKER_VERNEMQ_KUBERNETES_NAMESPACE=${DOCKER_VERNEMQ_KUBERNETES_NAMESPACE:-`cat /var/run/secrets/kubernetes.io/serviceaccount/namespace`}

# Let's set our nodename correctly

VERNEMQ_KUBERNETES_SUBDOMAIN=${DOCKER_VERNEMQ_KUBERNETES_SUBDOMAIN:-$(curl -X GET $insecure --cacert /var/run/secrets/kubernetes.io/serviceaccount/ca.crt https://kubernetes.default.svc.$DOCKER_VERNEMQ_KUBERNETES_CLUSTER_NAME/api/v1/namespaces/$DOCKER_VERNEMQ_KUBERNETES_NAMESPACE/pods?labelSelector=$DOCKER_VERNEMQ_KUBERNETES_LABEL_SELECTOR -H "Authorization: Bearer $(cat /var/run/secrets/kubernetes.io/serviceaccount/token)" | jq '.items[0].spec.subdomain' | sed 's/"//g' | tr '\n' '\0')}

if [ $VERNEMQ_KUBERNETES_SUBDOMAIN == "null" ]; then

VERNEMQ_KUBERNETES_HOSTNAME=${MY_POD_NAME}.${DOCKER_VERNEMQ_KUBERNETES_NAMESPACE}.svc.${DOCKER_VERNEMQ_KUBERNETES_CLUSTER_NAME}

else

VERNEMQ_KUBERNETES_HOSTNAME=${MY_POD_NAME}.${VERNEMQ_KUBERNETES_SUBDOMAIN}.${DOCKER_VERNEMQ_KUBERNETES_NAMESPACE}.svc.${DOCKER_VERNEMQ_KUBERNETES_CLUSTER_NAME}

sed -i.bak -r "s/VerneMQ@.+/VerneMQ@${VERNEMQ_KUBERNETES_HOSTNAME}/" /vernemq/etc/vm.args

# Hack into K8S DNS resolution (temporarily)

kube_pod_names=$(curl -X GET $insecure --cacert /var/run/secrets/kubernetes.io/serviceaccount/ca.crt https://kubernetes.default.svc.$DOCKER_VERNEMQ_KUBERNETES_CLUSTER_NAME/api/v1/namespaces/$DOCKER_VERNEMQ_KUBERNETES_NAMESPACE/pods?labelSelector=$DOCKER_VERNEMQ_KUBERNETES_LABEL_SELECTOR -H "Authorization: Bearer $(cat /var/run/secrets/kubernetes.io/serviceaccount/token)" | jq '.items[].spec.hostname' | sed 's/"//g' | tr '\n' ' ')

for kube_pod_name in $kube_pod_names;

if [ $kube_pod_name == "null" ]

then

echo "Kubernetes discovery selected, but no pods found. Maybe we're the first?"

echo "Anyway, we won't attempt to join any cluster."

break

if [ $kube_pod_name != $MY_POD_NAME ]

then

echo "Will join an existing Kubernetes cluster with discovery node at ${kube_pod_name}.${VERNEMQ_KUBERNETES_SUBDOMAIN}.${DOCKER_VERNEMQ_KUBERNETES_NAMESPACE}.svc.${DOCKER_VERNEMQ_KUBERNETES_CLUSTER_NAME}"

echo "-eval \"vmq_server_cmd:node_join('VerneMQ@${kube_pod_name}.${VERNEMQ_KUBERNETES_SUBDOMAIN}.${DOCKER_VERNEMQ_KUBERNETES_NAMESPACE}.svc.${DOCKER_VERNEMQ_KUBERNETES_CLUSTER_NAME}')\"" >> /vernemq/etc/vm.args

break

done

if [ -f /vernemq/etc/vernemq.conf.local ]; then

cp /vernemq/etc/vernemq.conf.local /vernemq/etc/vernemq.conf

sed -i -r "s/###IPADDRESS###/${IP_ADDRESS}/" /vernemq/etc/vernemq.conf

else

sed -i '/########## Start ##########/,/########## End ##########/d' /vernemq/etc/vernemq.conf

echo "########## Start ##########" >> /vernemq/etc/vernemq.conf

env | grep DOCKER_VERNEMQ | grep -v 'DISCOVERY_NODE\|KUBERNETES\|SWARM\|COMPOSE\|DOCKER_VERNEMQ_USER' | cut -c 16- | awk '{match($0,/^[A-Z0-9_]*/)}{print tolower(substr($0,RSTART,RLENGTH)) substr($0,RLENGTH+1)}' | sed 's/__/./g' >> /vernemq/etc/vernemq.conf

users_are_set=$(env | grep DOCKER_VERNEMQ_USER)

if [ ! -z "$users_are_set" ]; then

echo "vmq_passwd.password_file = /vernemq/etc/vmq.passwd" >> /vernemq/etc/vernemq.conf

touch /vernemq/etc/vmq.passwd

for vernemq_user in $(env | grep DOCKER_VERNEMQ_USER); do

username=$(echo $vernemq_user | awk -F '=' '{ print $1 }' | sed 's/DOCKER_VERNEMQ_USER_//g' | tr '[:upper:]' '[:lower:]')

password=$(echo $vernemq_user | awk -F '=' '{ print $2 }')

/vernemq/bin/vmq-passwd /vernemq/etc/vmq.passwd $username <<EOF

$password

EOF

done

if [ -z "$DOCKER_VERNEMQ_ERLANG__DISTRIBUTION__PORT_RANGE__MINIMUM" ]; then

echo "erlang.distribution.port_range.minimum = 9100" >> /vernemq/etc/vernemq.conf

if [ -z "$DOCKER_VERNEMQ_ERLANG__DISTRIBUTION__PORT_RANGE__MAXIMUM" ]; then

echo "erlang.distribution.port_range.maximum = 9109" >> /vernemq/etc/vernemq.conf

if [ -z "$DOCKER_VERNEMQ_LISTENER__TCP__DEFAULT" ]; then

echo "listener.tcp.default = ${IP_ADDRESS}:1883" >> /vernemq/etc/vernemq.conf

if [ -z "$DOCKER_VERNEMQ_LISTENER__WS__DEFAULT" ]; then

echo "listener.ws.default = ${IP_ADDRESS}:8080" >> /vernemq/etc/vernemq.conf

if [ -z "$DOCKER_VERNEMQ_LISTENER__VMQ__CLUSTERING" ]; then

echo "listener.vmq.clustering = ${IP_ADDRESS}:44053" >> /vernemq/etc/vernemq.conf

if [ -z "$DOCKER_VERNEMQ_LISTENER__HTTP__METRICS" ]; then

echo "listener.http.metrics = ${IP_ADDRESS}:8888" >> /vernemq/etc/vernemq.conf

echo "########## End ##########" >> /vernemq/etc/vernemq.conf

# Check configuration file

/vernemq/bin/vernemq config generate 2>&1 > /dev/null | tee /tmp/config.out | grep error

if [ $? -ne 1 ]; then

echo "configuration error, exit"

echo "$(cat /tmp/config.out)"

exit $?

pid=0

# SIGUSR1-handler

siguser1_handler() {

echo "stopped"

}

# SIGTERM-handler

sigterm_handler() {

if [ $pid -ne 0 ]; then

# this will stop the VerneMQ process, but first drain the node from all existing client sessions (-k)

if [ -n "$VERNEMQ_KUBERNETES_HOSTNAME" ]; then

terminating_node_name=VerneMQ@$VERNEMQ_KUBERNETES_HOSTNAME

elif [ -n "$DOCKER_VERNEMQ_SWARM" ]; then

terminating_node_name=VerneMQ@$(hostname -i)

else

terminating_node_name=VerneMQ@$IP_ADDRESS

/vernemq/bin/vmq-admin cluster leave node=$terminating_node_name -k > /dev/null

/vernemq/bin/vmq-admin node stop > /dev/null

kill -s TERM ${pid}

exit 0

}

# Setup OS signal handlers

trap 'siguser1_handler' SIGUSR1

trap 'sigterm_handler' SIGTERM

# Start VerneMQ

/vernemq/bin/vernemq console -noshell -noinput $@ &

pid=$!

wait $pid

—

Eclipse Mosquitto

[ Broker ] 在 Ubuntu 安裝 Mosquitto MQTT Broker

Ubuntu 20

1	# apt-get install mosquitto mosquitto-clients

需要重新安裝設定檔可以使用

1	# apt-get -o DPkg::options::=--force-confmiss --reinstall install mosquitto

—

RabbitMQ

MQTT 在 RabbitMQ 只是其中一個 Plugin，不會用

Ubuntu 20

1	# apt-get install erlang-base erlang-asn1 erlang-crypto erlang-eldap erlang-ftp erlang-inets erlang-mnesia erlang-os-mon erlang-parsetools erlang-public-key erlang-runtime-tools erlang-snmp erlang-ssl erlang-syntax-tools erlang-tftp erlang-tools erlang-xmerl

1	# apt-get install rabbitmq-server

1	# rabbitmq-plugins enable rabbitmq_mqtt

—

Mosquitto MySQL plugin 安裝

1	# apt-get install libssl-dev mosquitto-dev libmysqlclient-dev

最後編譯失敗，不會用

—

22 total views, 6 views today

Fail2ban

Posted on 2020-11-22 by hoyo

—

參考資源

—

安裝

Ununtu

1	# apt-get install fail2ban

CentOS 7

1	# yum install fail2ban

—

系統服務

例如要控管 ssh 可以這樣設定

編輯 jail.conf

1	# vi /etc/fail2ban/jail.conf

設定 sshd 區段

[sshd]

port = ssh

logpath = %(sshd_log)s

backend = %(sshd_backend)s

maxretry = 3

findtime = 30

bantime = 300

將 fail2ban 服務開啟及啟動

1	# systemctl enable fail2ban ; systemctl start fail2ban

解除單一 IP 封鎖

1	# fail2ban-client set sshd unbanip 172.16.1.100

解除全部封鎖

1	# fail2ban-client unban --all

—

維護

查看有作用

1	# fail2ban-client status

查看作用執行細節

1	# fail2ban-client status web

Status for the jail: web

|- Filter

| |- Currently failed: 0

| |- Total failed: 4

| `- File list: /WEBSite/login_fail.log

`- Actions

|- Currently banned: 1

|- Total banned: 1

`- Banned IP list: 192.168.0.99

—

自訂服務應用 – 以網頁登入為例

如果其他應用也要套用，例如網頁登入，那就要多費點功夫

需要自訂規則建議先使用 fail2ban-regex 指令進行模擬，如此決定 log 格式以及正規式規則

log 至少需要包含 IP 以及時間，時間最好包含時區，例如

1	192.168.0.99 2020-11-22 00:00:30 CST

使用 fail2ban-regex 驗證正規式是否可抓取 log 資料格式

# fail2ban-regex -d '%Y-%m-%d %H:%M:%S %Z' '192.168.0.99 2020-11-21 14:03:00 CST' '<ADDR> .*'

Running tests

=============

Use datepattern : Year-Month-Day 24hour:Minute:Second

Use failregex line : <ADDR> .*

Use single line : 192.168.0.99 2020-11-21 14:03:00

Results

=======

Failregex: 1 total

|- #) [# of hits] regular expression

| 1) [1] <ADDR> .*

Ignoreregex: 0 total

Date template hits:

|- [# of hits] date format

| [1] Year-Month-Day 24hour:Minute:Second

Lines: 1 lines, 0 ignored, 1 matched, 0 missed

[processed in 0.00 sec]

編輯過濾規則設定檔

1	# vi /etc/fail2ban/filter.d/hoyo-web.conf

datepattern 的百分比符號在設定檔內是連續 2 個

[Definition]

failregex = ^<ADDR> .*$

datepattern = %%Y-%%m-%%d %%H:%%M:%%S %%Z

ignoreregex =

編輯 jail.local

1 2	# vi /etc/fail2ban/jail.local

[web]

enabled = true

filter = hoyo-web

logpath = /WEBSite/login_fail.log

bantime = 300

findtime = 10

maxretry = 3

再次使用 fail2ban-regex 驗證，這次使用檔案驗證

1	# fail2ban-regex ./login_fail.log /etc/fail2ban/filter.d/hoyo-web.conf

—

8 total views, no views today

MQTT – 0. 如果不是為了破壞地球，我也不會開始用

Posted on 2020-11-20 by hoyo

—

緣由

因為班班有冷氣加上台電要限制尖峰用電，需要配套需量反應的卸載機制，和上層的通訊一開始定義了 MQTT 所以才開始了解 (要不然要使用 Socket 到死的)

—

簡介

—

30 total views, 2 views today

MQTT – 2. 其他客戶端

Posted on 2020-11-20 by hoyo

—

參考

—

PHP Publish

PHP 的應用場景可能發生在需要從網頁發出 publish 控制需求，Hoyo 尚未在 PHP 上撰寫常駐程式

安裝，跳過 PHP 版本需求

1	> composer require php-mqtt/client --ignore-platform-reqs

程式範例

<?php

spl_autoload_register(function ($class_name) {

$load_FileName = str_replace('\\', '/', $class_name);

$file_name = __DIR__ ."/php/". $load_FileName .".php";

if ( is_file($file_name) === true ) {

require_once( $file_name );

}

});

$server = 'test.mosquitto.org';

$port = 1883;

$clientId = 'test-publisher';

$mqtt = new \PhpMqtt\Client\MQTTClient($server, $port, $clientId);

$mqtt->connect();

$mqtt->publish('aa/Get/DemandRange', 'Hello World!', 0);

$mqtt->close();

—

CLI

CLI 執行方式除了可以滿足單機執行外，讓 PHP 直接呼叫執行應該是更佳的方式，尤其是剛剛上述的 PHP Publish 效能不彰的情況

mosquitto_sub man page

因為加上了 MySQL 認證

1	# mosquitto_pub -h 172.16.1.220 -p 1883 -u emqx -P public -t aa/Get/DemandRange -m "0000"

完整範例

1	# mosquitto_pub -h 172.16.1.220 -p 8883 -u emqx -P public --cafile my_root_ca.pem --cert client.pem --key client.key -t aa/Get/DemandRange -m "0000"

-h host
-p port
-u 使用者帳號
-P 使用者密碼
–cafile SSL CA 證書檔案路徑
–cert SSL 證書檔案路徑
–key SSL Key 檔案路徑
-t Topic
-m Message

—

13 total views, no views today

MQTT – 1. 使用免費公開的 MQTT Broker Server 學習如何訂閱、發行(收發資料)

Posted on 2020-11-19 by hoyo

—

1	MQTT 客户端整个生命周期的行为可以概括为：建立连接、订阅主题、接收消息并处理、向指定主题发布消息、取消订阅、断开连接。

節錄： MQTT 客户端库

—

公開 MQTT Borker

ESP8266 连接到免费的公共 MQTT 服务器 – broker.emqx.io:1883
test.mosquitto.org – test.mosquitto.org:1883
Sandboxes | IoT development made simple – mqtt.eclipse.org:1883
通信猫共享MQTT服务器在线客户端 – mq.tongxinmao.com:18830

建議選擇 broker.emqx.io ，因為支援 WebSocket 可以從資料收集端直接呈現到網頁，不需要經過資料庫這類儲存媒介。實際應用也是 EMQ X Broker 才符合需求，學校專題或是個人嘗鮮可以使用 mosquitto 即可

—

程式參考

Simple Python MQTT Publish and Subscribe Example Script

以下 Python 範例程式已經根據可用 MQTT Broker 修改

程式先訂閱 house/bulb1 主題，然後發行 house/bulb1 此主題及內容

import time

import paho.mqtt.client as paho

broker = "broker.emqx.io"

# define callback

def on_message(client, userdata, message):

time.sleep(1)

print("received message =", str(message.payload.decode("utf-8")))

client = paho.Client("client-001") # create client object client1.on_publish = on_publish #assign function to callback client1.connect(broker,port) #establish connection client1.publish("house/bulb1","on")

######Bind function to callback

client.on_message = on_message

#####

print("connecting to broker ", broker)

client.connect(broker) # connect

client.loop_start() # start loop to process received messages

print("subscribing ")

client.subscribe("house/bulb1") # subscribe

print("publishing ")

client.publish("house/bulb1", "on") # publish

time.sleep(3)

client.disconnect() # disconnect

client.loop_stop() # stop loop

運作結果

connecting to broker broker.emqx.io

subscribing

publishing

received message = on

—

Topic 萬用字元

MQTT(五)SUBSCRIBE Message

finance/stock/ibm/#

finance/stock/ibm

finance/stock/ibm/closingprice

finance/stock/ibm/currentprice

finance/stock/+

/finance/stock/ibm

/finance/stock/xyz

不匹配

/finance/stock/ibm/closingprice

—

Socket VS MQTT

MQTT 要接收的資料必須自己訂閱，少了多了都有問題，Socket 要自己處理資料流
傳送時斷線 Socket 就是失敗，MQTT 根據 QoS 政策可以保證資料的送達。當 QoS 為 0 時，短暫的斷線 (拔網路線10秒) 也能成功送達
主機端須處理的程式 Socket 可以寫在 Workerman 內，MQTT 因為 Server 只是代理，所以程式必須分開，以健康度來說 MQTT 較佳；Socket 程式一致性及即時性較佳

—

25 total views, 1 views today

hoyo 學習紀錄

PHP 網頁應用 IOT 物聯網自動化

Author Archives: hoyo

MQTT – 4. MQTT Broker

MQTT broker

EMQ X

VerneMQ

Eclipse Mosquitto

RabbitMQ

Mosquitto MySQL plugin 安裝

Fail2ban

參考資源

安裝

系統服務

維護

自訂服務應用 – 以網頁登入為例

MQTT – 0. 如果不是為了破壞地球，我也不會開始用

緣由

簡介

MQTT – 2. 其他客戶端

參考

PHP Publish

CLI

MQTT – 1. 使用免費公開的 MQTT Broker Server 學習如何訂閱、發行(收發資料)

公開 MQTT Borker

程式參考

Topic 萬用字元

Socket VS MQTT