HOYO 的 2020 回顧

Posted on 2020-12-26 by hoyo

公司

富邦銀行的 BEMS 案子褲子都脫了，什麼都沒看到。還好都不會浪費以後還用的到…
使用 ESP8266 進行一些 RS485 Modbus 的通訊測試，在一些特定應用場合異常好用
接手一個外包廠商花了一年半進度還做不到 50% 的需量網頁版系統，自己從頭到尾花了 3 個月就上線使用
因為富邦銀行案子需求開始使用 NanoPi 開發通訊硬體，增加了 Python 以及 Linux 的熟練度
年底的時候因為「班班有冷氣」政策，所有冷氣、電錶相關廠商雞飛狗跳，我們也不例外
開始嘗試使用 MQTT 這個大家都已經用爛的通訊方式，並且花了 3 天將公司提的需量 APP做了一個產品

—

個人

過年的時候終於嘗試了瓦斯爐韓式烤肉，好吃又好玩
暑假的時候一家人去了日月潭、九族文化村，台灣 369 遊樂園終於湊齊了
又是公司出差才第一次去宜蘭，實在是又窮又宅，主要是窮，有錢就到處玩樂了
因為國慶煙火在台南，而且在安平，終於第一次看了台灣的國慶煙火
因為又窮又宅，所以嘗試了使用壓克力顏料進行創作，好玩是好玩就是收捨麻煩
受到神奇 YouTube 演算法，被安麗了一堆健身影片之後開始進行 168 斷食，以及在家做簡單的鍛鍊，

—

2020 代表字

健康、健身、我們下次健

—

791 total views, 2 views today

ESP8266 – RS485 Modbus 通訊

Posted on 2020-12-21 by hoyo

—

MAX485

【MSP430開發日誌】UART延伸應用RS485(MAX485模組) – 前言與準備

最後的腳位對應為

RO => RXD = D5

DI => TXD = D6

TR = D2

—

SoftwareSerial

因為使用了 UART 轉 RS485 小板，因此只要設定好鮑率、傳送的資料及計算 CRC 即可

ESP8266 Two Serial Ports With SoftwareSerial Library

#include <SoftwareSerial.h>

SoftwareSerial mySerial(14, 12); // RX, TX

#define DE 4 // D6使能發送器，高電平有效

void setup()

{

pinMode(not_RE, OUTPUT);

pinMode(DE, OUTPUT);

digitalWrite(not_RE, HIGH); // disable receiver

digitalWrite(DE, HIGH); // enable transmitter

Serial.begin(57600);

mySerial.begin(9600);

}

void loop()

{

Serial.println("aaa");

mySerial.println("aaa");

delay(100);

}

—

CRC

Arduino and RS485 communication

uint16_t CalcCRC(byte * data, uint8_t datlen) {

uint16_t CRC = 0xFFFF; // Init CRC

uint8_t xor_flag;

for (uint8_t n = 0; n < datlen; n++) {

CRC = CRC ^ data[n];

for (uint8_t i = 0; i < 8; i++) {

if (CRC & 0x0001) {

xor_flag = 1;

}

else {

xor_flag = 0;

}

CRC = CRC >> 1;

if (xor_flag) {

CRC = CRC ^ 0xA001;

}

return CRC;

}

void SendCmd( byte * data, uint8_t datlen) { // this is just a test routine to send results Serial Monitor.

uint16_t CRC = CalcCRC(data, datlen);

for (uint8_t i = 0; i < datlen; i++) { // set TX mode, use the correct Serial (softSerial?)

Serial.print(data[i], HEX);

Serial.print(' ');

}

Serial.print(lowByte(CRC), HEX); // This does not match the Example. It could be an error in the manual.

Serial.print(' '); // If the device does not respond, reverse the order byte order the CRC

Serial.println(highByte(CRC), HEX); // is sent. Send highbyte then lowByte.

}

以 {0x01, 0x03, 0x00, 0x00, 0x00, 0x02} 為例，算出來應該是 0xC4, 0x0B 才對

—

硬體接線

正面

背面

—

程式範例

#include <SoftwareSerial.h>

SoftwareSerial rs485;

#define DE 4

byte s[] = {0x60, 0x03, 0x00, 0x00, 0x00, 0x10};

byte r[sizeof(s) + 2];

uint16_t CalcCRC(byte * data, uint8_t datlen) {

uint16_t CRC = 0xFFFF; // Init CRC

uint8_t xor_flag;

for (uint8_t n = 0; n < datlen; n++) {

CRC = CRC ^ data[n];

for (uint8_t i = 0; i < 8; i++) {

if (CRC & 0x0001) {

xor_flag = 1;

}

else {

xor_flag = 0;

}

CRC = CRC >> 1;

if (xor_flag) {

CRC = CRC ^ 0xA001;

}

return CRC;

}

void printHex(uint8_t num) {

char hexCar[2];

sprintf(hexCar, "%02X", num);

Serial.print(hexCar);

}

void setup()

{

pinMode(DE, OUTPUT);

Serial.begin(9600);

rs485.begin(2400, SWSERIAL_8N1, 14, 12);

for ( int i = 0; i < sizeof(s); i++ ) {

r[i] = s[i];

}

void loop()

{

digitalWrite(DE, HIGH);

uint16_t CRC = CalcCRC(s, 6);

r[6] = lowByte(CRC);

r[7] = highByte(CRC);

rs485.write(r, sizeof(r));

digitalWrite(DE, LOW);

delay(300);

for ( int i = 0; i < sizeof(r); i++ ) {

printHex(r[i]);

}

Serial.println();

if (rs485.available() > 0)

{

while (rs485.available() > 0)

{

Serial.print(rs485.read());

Serial.print(',');

yield();

}

Serial.println();

}

delay(1000);

}

運行結果

—

注意事項

如果選擇的 GPIO 會影響燒錄，那重新開機也會影響程式運作，必須先斷開開機完成才會運作，所以還是需要另外選不會影響的腳位。

—

244 total views, 4 views today

PHP – MQTT

Posted on 2020-12-21 by hoyo

—

參考資源

phpMQTT

除了上述資源外，一開始其實使用的是 php-mqtt/client 這個，不過軟體太肥，使用麻煩效能也差，才又找了 phpMQTT 使用

—

範例程式

主要是在網頁上執行 publish() 發送，因此只需要可連線，可發送即可

<?php

require('../3rdParty/phpMQTT.php');

$server = 'mq.tongxinmao.com'; // change if necessary

$port = 18830; // change if necessary

$username = ''; // set your username

$password = ''; // set your password

$client_id = 'phpMQTT-publisher'; // make sure this is unique for connecting to sever - you could use uniqid()

$mqtt = new \phpMQTT($server, $port, $client_id);

if ($mqtt->connect(true, NULL)) {

$mqtt->publish('esp8266/test', '{"LED":"'. $_GET['led'] .'"}', 0, false);

$mqtt->close();

} else {

echo "Time out!\n";

}

—

SSL 範例

<?php

// MQTT

const MQTT_Server = '172.16.1.220';

const MQTT_Port = 8883;

const MQTT_Username = 'user';

const MQTT_Password = 'password';

require_once __DIR__ . "/phpMQTT.php";

$mqtt = new \phpMQTT(MQTT_Server, MQTT_Port, 'EMS_'.uniqid(), __DIR__.'/my_root_ca.pem');

if ($mqtt->connect(true, NULL, MQTT_Username, MQTT_Password)) {

$alert = [

'id'=>$event_id,

'event'=>'PM2.5',

'time'=>date('Y-m-d H:i:s'),

'period'=>'start',

'set'=>$pm25_alarm_up,

'value'=>$data['Value']['PM2.5']

];

$mqtt->publish('DAE/Alert/'.$channel['Token'], json_encode($alert), 0, false);

$mqtt->close();

}

—

153 total views, no views today

ESP8266 – AP Mode 網頁伺服器

Posted on 2020-12-21 by hoyo

—

WebServer

Connection ESP8266 to ESP8266 Client Server can’t Connect, Help me?

使用 ESP8266WebServer.h 而不是自己寫

#include <ESP8266WiFi.h>

#include <WiFiClient.h>

#include <ESP8266WebServer.h>

IPAddress ip(192,168,1,81); // choose IP address

IPAddress subnet(255,255,255,0);

ESP8266WebServer server(80);

void handleRoot() {

String page = "<!DOCTYPE html>\n";

page += "<html>\n<body>\n<h1>Some heading</h1><br>Generated by ESP8266\n</body>\n</html>";

server.send(200, "text/html", page);

}

// what to do when accessed through http://ip_address/something_undefined

void handleNotFound(){

String message = "File not found\n\n";

message += "URI: ";

message += server.uri();

message += "\nMethod: ";

message += (server.method() == HTTP_GET)?"GET":"POST";

message += "\nArguments: ";

message += server.args();

message += "\n";

for (uint8_t i=0; i<server.args(); i++){

message += " " + server.argName(i) + ": " + server.arg(i) + "\n";

}

server.send(404, "text/plain", message);

}

void setup(void){

Serial.begin(74880); // so you can see debug messages automatically sent by ESP8266

WiFi.mode(WIFI_AP);

WiFi.softAPConfig(ip, ip, subnet); // declared as: bool softAPConfig (IPAddress local_ip, IPAddress gateway, IPAddress subnet)

WiFi.softAP("SOME_NAME", "password", 7); // network name, network password, wifi channel

IPAddress myIP = WiFi.softAPIP();

Serial.println();

Serial.print("AP IP address: ");

Serial.println(myIP);

server.on("/", handleRoot); // what to do when accessed through browser using http://IP_address

// what to do when accessed through http://ip_address/test

server.on("/test", [](){

server.send(200, "text/plain", "This is another page");

});

server.on("/sa/1", [](){

// ... <-- put here the code for NeoPixel = on

server.send(200, "text/html", "NeoPixel is now on");

});

server.on("/sa/0", [](){

// ... <-- put here the code for NeoPixel = off

server.send(200, "text/html", "NeoPixel is now off");

});

server.onNotFound(handleNotFound);

server.begin();

Serial.println("HTTP server started...");

}

void loop(void){

server.handleClient();

}

—

URL 的 $_GET()

ESP8266 Webserver: Getting query parameters

一般來說使用 handleSpecificArg() 是比較常用的

void handleGenericArgs() {

String message = "";

message += server.arg(0) + "\n";

String rs_message = getValue(message, ',');

message += rs_message;

server.send(200, "text / plain", message); //Response to the HTTP request

}

void handleSpecificArg() {

String message = "";

if (server.arg("Temperature") == "") { //Parameter not found

message = "Temperature Argument not found";

} else { //Parameter found

message = "Temperature Argument = ";

message += server.arg("Temperature"); //Gets the value of the query parameter

}

server.send(200, "text / plain", message); //Returns the HTTP response

}

server.on("/rs", handleGenericArgs);

—

應用

有了 WiFi AP 也有了取得網址變數的方法，接下來就可以設計應用場景網址的變數使用。例如 http://192.168.2.1/url?led=on&light=1 ，可以表示開啟 led 以及亮 1 秒

—

229 total views, 2 views today

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

最後編譯失敗，不會用

—

560 total views, no views today

hoyo 學習紀錄

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

Author Archives: hoyo

HOYO 的 2020 回顧

公司

個人

2020 代表字

ESP8266 – RS485 Modbus 通訊

MAX485

SoftwareSerial

CRC

硬體接線

程式範例

注意事項

PHP – MQTT

參考資源

範例程式

SSL 範例

ESP8266 – AP Mode 網頁伺服器

WebServer

URL 的 $_GET()

應用

MQTT – 4. MQTT Broker

MQTT broker

EMQ X

VerneMQ

Eclipse Mosquitto

RabbitMQ

Mosquitto MySQL plugin 安裝