【MYS-6ULX-IOT试用体验】公用洗衣机无线控制(结项贴) - 问答 - 电子技术论坛 - 最好最受欢迎电子论坛!

电子发烧友官网论坛在线研讨会活动客服QQ:3144539146
开启辅助访问 收藏本站切换到宽版

电子技术论坛»论坛 › 问答

【MYS-6ULX-IOT试用体验】公用洗衣机无线控制(结项贴)

刘 刚 ( 楼主 ) 2017-8-7 15:39:55  只看该作者 倒序浏览
本帖最后由 sandman78 于 2017-8-7 17:14 编辑

本项目实现公用洗衣机的移动端预订、付费、排队。洗衣机通过WIFI联网，采用MQTT协议与服务器通讯，执行服务器下发的命令。具体实现为接收mqtt服务器发布的命令，根据需要发到串口控制洗衣机工作。mqtt应用层采用json数据格式，串口采用自定义二进制格式。关于串口编程之前有过介绍，Go的标准库支持json处理，这里只介绍开发板的mqtt应用部分、不涉及具体业务。

mqtt数据处理

mqtt简介

mqtt是一种基于发布/订阅（Publish/Subscribe）模式的轻量级通讯协议，该协议构建于TCP/IP协议上，由IBM在1999年发布，目前最新版本为v3.1.1。MQTT最大的优点在于可以以极少的代码和有限的带宽，为远程设备提供实时可靠的消息服务。做为一种低开销、低带宽占用的即时通讯协议，MQTT在物联网、小型设备、移动应用等方面有广泛的应用。详细介绍可参见官网的介绍。

go语言对MQTT的支持

eclipse提供了paho.mqtt.golang客户端包

首先下载

  1. $ go get github.com/eclipse/paho.mqtt.golang
复制代码



使用之前导入
  1. import "github.com/eclipse/paho.mqtt.golang"
复制代码


设置MQTT的参数
  1. opts := MQTT.NewClientOptions().AddBroker(addr).SetClientID("go_pc").SetCleanSession(true).SetDefaultPublishHandler(func(client MQTT.Client, msg MQTT.Message) {
  2.     choke <- [2]string{msg.Topic(), string(msg.Payload())}
  3. })
复制代码

AddBroker用于设置MQTT服务器的地址
SetClientID设置client的ID，在同一网络中，客户端ID是唯一的.
SetCleanSession, 如果设置为false，Client断开连接后，Server应该保存Client的订阅信息。如果为true，表示Server应该立刻丢弃任何会话状态信息。
SetDefaultPublishHandler，设置收到消息后的默认处理函数，这里把收到的主题和消息内容通过choke发送给处理函数。

连接MQTT服务器
  1. client := MQTT.NewClient(opts)
  2. if token := client.Connect(); token.Wait() && token.Error() != nil {
  3.     panic(token.Error())
  4. }
复制代码

订阅关注的消息
  1. for _, topic := range subTopics {
  2.     if token := client.Subscribe(topic, 0, nil); token.Wait() && token.Error() != nil {
  3.         fmt.Println(token.Error())
  4.         os.Exit(1)
  5.     }
  6. }
复制代码

subTopics为字符串数组保存着待订阅的主题。

运行消息发布goroutine，通过<-message接收发布的消息和主题，message类型为chan [2]string分别对应主题和消息
  1. go func() {
  2.     for {
  3.         msg := <-message
  4.         token := client.Publish(msg[0], 0, false, msg[1])
  5.         token.Wait()
  6.     }
  7. }()
复制代码

主循环
  1. for {
  2.         select {
  3.         case data := <-choke:
  4.         ... // 这里处理接收到的订阅消息
  5.         message <- [2]string{"topic1/topic2", string(buf)} // 发布消息

  7.         case <-time.After(time.Second * 1):
  8.         ... // 这里可处理定时任务
  9.         }
  10.     }
  11. }
复制代码

参考完整代码如下

  2. func qmqtt(addr string, posid []string) {
  3.     c := &serial.Config{Name: PORT, Baud: 115200}
  4.     s, err := serial.OpenPort(c)
  5.     defer s.Close()
  6.     if err != nil {
  7.         log.Fatal(err)
  8.     }

  10.     var subTopics = []string{"washer/c2d/raw/" + POSIDS}
  11.     choke := make(chan [2]string)
  12.     message := make(chan [2]string)

  14.     opts := MQTT.NewClientOptions().AddBroker(addr).SetClientID("go_pc").SetCleanSession(true).SetDefaultPublishHandler(func(client MQTT.Client, msg MQTT.Message) {
  15.         choke <- [2]string{msg.Topic(), string(msg.Payload())}
  16.     })

  18.     client := MQTT.NewClient(opts)

  20.     if token := client.Connect(); token.Wait() && token.Error() != nil {
  21.         panic(token.Error())
  22.     }

  24.     for _, topic := range subTopics {
  25.         if token := client.Subscribe(topic, 0, nil); token.Wait() && token.Error() != nil {
  26.             fmt.Println(token.Error())
  27.             os.Exit(1)
  28.         }
  29.     }

  31.     go func() {
  32.         for {
  33.             msg := <-message
  34.             token := client.Publish(msg[0], 0, false, msg[1])
  35.             token.Wait()
  36.         }
  37.     }()

  39.     p := packet.NewPacket(s, 0x55, []int{6, 0, 1})
  40.     x := washer.Encode(POSID, 0x11, []byte{})
  41.     for {
  42.         select {
  43.         case data := <-choke:
  44.             buf, err := p.Exchange([]byte(data[1]))
  45.             if err != nil {
  46.                 fmt.Println(err)
  47.                 continue
  48.             }
  49.             if _, err := washer.Decode(POSID, 0x11, buf); err != nil {
  50.                 fmt.Println(err)
  51.                 continue
  52.             }
  53.             message <- [2]string{"washer/d2c/" + POSIDS, string(buf)}
  54.         }
  55.     }
  56. }
复制代码
评分 1 积分 +5 收起 理由
Bootstrap + 5 原创技术先锋,加分鼓励!

查看全部评分

【新技能】那些你不知道的红外热像“隐形”功能
回复 赞1

举报 使用道具

1个回复
沙发
jyaxz 发表于 2018-5-10 13:54:23
mqtt这个挺好的东西，谢谢楼主的研究
华强芯城电阻小批量现货，下单即发，全网底价！点击进入>> 
回复 赞1 支持 反对

举报 使用道具

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

相关帖子


关闭

站长推荐上一条 /7 下一条

小黑屋|手机版|Archiver|电子发烧友 ( 湘ICP备2023018690号 )

GMT+8, 2024-12-25 10:53 , Processed in 0.635573 second(s), Total 76, Slave 53 queries .

Powered by 电子发烧友网

© 2015 bbs.elecfans.com

微信扫描
快速回复 返回顶部 返回列表