MQTT – 九霄天空-IT技术分享学习

MQTT_Client实例Golang代码

2020年5月18日2020年5月29日
Golang, MQTT
988 clicked


package test

import (
    "fmt"
    "time"
    MQTT "github.com/eclipse/paho.mqtt.golang"
    LOG "github.com/sirupsen/logrus"
)

func main() {
    opts := MQTT.NewClientOptions()
    opts.AddBroker("tcp://127.0.0.1:1883")
    opts.SetClientID("custom-store")

    var callback MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) {
        fmt.Printf("TOPIC: %s\n", msg.Topic())
        fmt.Printf("MSG: %s\n", msg.Payload())
    }

    c := MQTT.NewClient(opts)
    if token := c.Connect(); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }
    LOG.Info("create mqtt client")

    c.Subscribe("/go-mqtt/sample", 0, callback)
    LOG.Info("subscibe topic /go-mqtt/sample")
    for i := 0; i < 10; i++ {
        text := fmt.Sprintf("this is msg #%d!", i)
        token := c.Publish("/go-mqtt/sample", 1, false, text)
        token.Wait()
    }

    for i := 1; i < 10; i++ {
        time.Sleep(1 * time.Second)
    }
    c.Disconnect(250)
}

package test

import (

"fmt"

"time"

MQTT "github.com/eclipse/paho.mqtt.golang"

LOG "github.com/sirupsen/logrus"

)

func main() {

opts := MQTT.NewClientOptions()

opts.AddBroker("tcp://127.0.0.1:1883")

opts.SetClientID("custom-store")

var callback MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) {

fmt.Printf("TOPIC: %s\n", msg.Topic())

fmt.Printf("MSG: %s\n", msg.Payload())

}

c := MQTT.NewClient(opts)

if token := c.Connect(); token.Wait() && token.Error() != nil {

panic(token.Error())

}

LOG.Info("create mqtt client")

c.Subscribe("/go-mqtt/sample", 0, callback)

LOG.Info("subscibe topic /go-mqtt/sample")

for i := 0; i < 10; i++ {

text := fmt.Sprintf("this is msg #%d!", i)

token := c.Publish("/go-mqtt/sample", 1, false, text)

token.Wait()

}

for i := 1; i < 10; i++ {

time.Sleep(1 * time.Second)

}

c.Disconnect(250)

}

MQTT客户端paho.mqtt.XXX

2020年5月16日2020年6月25日
MQTT, Others
1,431 clicked

1. MQTT客户端C代码库 C语言库：https://github.com/eclipse/paho.mqtt.c 1.1 C源码下载构建

# centos7 OS 方法一
$ git clone https://github.com/eclipse/paho.mqtt.c.git
$ cd paho.mqtt.c
$ make
$ sudo make install
# make help查看当前Makefile支持命令
# make package 构造安装包压缩目录，解压缩后是生成项目链接库

mkdir -p build/output/samples
mkdir -p build/output/test
echo OSTYPE is Linux
OSTYPE is Linux
mkdir -p /usr/local/include
install -m 644  build/output/libpaho-mqtt3c.so.1.3 /usr/local/lib
install -m 644  build/output/libpaho-mqtt3cs.so.1.3 /usr/local/lib
install -m 644  build/output/libpaho-mqtt3a.so.1.3 /usr/local/lib
install -m 644  build/output/libpaho-mqtt3as.so.1.3 /usr/local/lib
install  build/output/paho_c_version /usr/local/bin
install  build/output/samples/paho_c_pub /usr/local/bin
install  build/output/samples/paho_c_sub /usr/local/bin
install  build/output/samples/paho_cs_pub /usr/local/bin
install  build/output/samples/paho_cs_sub /usr/local/bin
/sbin/ldconfig /usr/local/lib
ln -s libpaho-mqtt3c.so.1 /usr/local/lib/libpaho-mqtt3c.so
ln -s libpaho-mqtt3cs.so.1 /usr/local/lib/libpaho-mqtt3cs.so
ln -s libpaho-mqtt3a.so.1 /usr/local/lib/libpaho-mqtt3a.so
ln -s libpaho-mqtt3as.so.1 /usr/local/lib/libpaho-mqtt3as.so
install -m 644 src/MQTTAsync.h /usr/local/include
install -m 644 src/MQTTClient.h /usr/local/include
install -m 644 src/MQTTClientPersistence.h /usr/local/include
install -m 644 src/MQTTProperties.h /usr/local/include
install -m 644 src/MQTTReasonCodes.h /usr/local/include
install -m 644 src/MQTTSubscribeOpts.h /usr/local/include
install -m 644 src/MQTTExportDeclarations.h /usr/local/include
install -m 644 doc/man/man1/paho_c_pub.1 /usr/local/share/man/man1
install -m 644 doc/man/man1/paho_c_sub.1 /usr/local/share/man/man1
install -m 644 doc/man/man1/paho_cs_pub.1 /usr/local/share/man/man1
install -m 644 doc/man/man1/paho_cs_sub.1 /usr/local/share/man/man1

#方法二，cmake指定构建安装目录，作为第三方动态链接库
#将项目目录下载到/root下面,同时指定生成目标安装位置为/root/mqtt
mkdir -p root/mqtt/build
cd /root/mqtt/
cmake -DCMAKE_INSTALL_PREFIX="/root/mqtt" ../paho.mqtt.c
make
make install

# centos7 OS 方法一

$ git clone https://github.com/eclipse/paho.mqtt.c.git

$ cd paho.mqtt.c

$ make

$ sudo make install

# make help查看当前Makefile支持命令

# make package 构造安装包压缩目录，解压缩后是生成项目链接库

mkdir -p build/output/samples

mkdir -p build/output/test

echo OSTYPE is Linux

OSTYPE is Linux

mkdir -p /usr/local/include

install -m 644 build/output/libpaho-mqtt3c.so.1.3 /usr/local/lib

install -m 644 build/output/libpaho-mqtt3cs.so.1.3 /usr/local/lib

install -m 644 build/output/libpaho-mqtt3a.so.1.3 /usr/local/lib

install -m 644 build/output/libpaho-mqtt3as.so.1.3 /usr/local/lib

install build/output/paho_c_version /usr/local/bin

install build/output/samples/paho_c_pub /usr/local/bin

install build/output/samples/paho_c_sub /usr/local/bin

install build/output/samples/paho_cs_pub /usr/local/bin

install build/output/samples/paho_cs_sub /usr/local/bin

/sbin/ldconfig /usr/local/lib

ln -s libpaho-mqtt3c.so.1 /usr/local/lib/libpaho-mqtt3c.so

ln -s libpaho-mqtt3cs.so.1 /usr/local/lib/libpaho-mqtt3cs.so

ln -s libpaho-mqtt3a.so.1 /usr/local/lib/libpaho-mqtt3a.so

ln -s libpaho-mqtt3as.so.1 /usr/local/lib/libpaho-mqtt3as.so

install -m 644 src/MQTTAsync.h /usr/local/include

install -m 644 src/MQTTClient.h /usr/local/include

install -m 644 src/MQTTClientPersistence.h /usr/local/include

install -m 644 src/MQTTProperties.h /usr/local/include

install -m 644 src/MQTTReasonCodes.h /usr/local/include

install -m 644 src/MQTTSubscribeOpts.h /usr/local/include

install -m 644 src/MQTTExportDeclarations.h /usr/local/include

install -m 644 doc/man/man1/paho_c_pub.1 /usr/local/share/man/man1

install -m 644 doc/man/man1/paho_c_sub.1 /usr/local/share/man/man1

install -m 644 doc/man/man1/paho_cs_pub.1 /usr/local/share/man/man1

install -m 644 doc/man/man1/paho_cs_sub.1 /usr/local/share/man/man1

#方法二，cmake指定构建安装目录，作为第三方动态链接库

#将项目目录下载到/root下面,同时指定生成目标安装位置为/root/mqtt

mkdir -p root/mqtt/build

cd /root/mqtt/

cmake -DCMAKE_INSTALL_PREFIX="/root/mqtt" ../paho.mqtt.c

make

make install

编译成功后，生成4个二进制可执行文件，paho_c_pub paho_c_sub paho_cs_pub paho_cs_… 阅读更多 »MQTT客户端paho.mqtt.XXX

MQTT服务(EMQX)安装

2020年4月16日2020年5月16日
MQTT, Others
3,337 clicked

安装及测试EMQ X EMQ X R3.0 (Erlang/Enterprise/Elastic MQTT Broker) 是基于 Erlang/OTP 语言平台开发，支持大规模连接和分布式集群，发布订阅模式的开源 MQTT 消息服务器。 MQTT是一个由IBM主导开发的物联网传输… 阅读更多 »MQTT服务(EMQX)安装