SpringMVC+Spring+Mybatis框架整合Mqttt通信协议+ActiveMQ作为中间件进行消息的发布与订阅


单片机部分采用MQTT协议将主题消息发布到队列中,java部分也采用MQTT协议进行处理,整合MQTT协议, 具体这个资源是干什么的,请查看博客: https://blog.csdn.net/qq_34178998/article/details/93158429
资源截图
代码片段和文件信息
package com.zlw.comm.mqtt;

import com.alibaba.fastjson.JSONobject;
import com.zlw.comm.utils.FastJsonUtils;

public class MqttService {

public void startCase(String message){
JSONobject jb = FastJsonUtils.toJsonobject(message);
System.out.println(“收到32单片机消息:“ + message);
    }

}

/*public void onMessage(Message message) {
String responsexml = null;
if (message instanceof BytesMessage) {
ActiveMQBytesMessage bytesMessage = (ActiveMQBytesMessage) message;
byte[] bys = null;
try {
bys = new byte[(int) bytesMessage.getBodyLength()];
bytesMessage.readBytes(bys);
responsexml = new String(bys);
*//****************************此处为模拟数据**********************************************//*
RgModRecordAddWithJon rgAddWithJon = new RgModRecordAddWithJon();
rgAddWithJon.setDevId((long) 4);
rgAddWithJon.setModRecordData(FastJsonUtils.toJsonobject(responsexml));
rgAddWithJon.setModRecordUpTime(new Date());
rgAddWithJon.setDevApiKey(StringUtils.getUUId());
recordExtMapper.insertWithJosn(rgAddWithJon);
System.out.println(“收到32单片机消息:“ + responsexml);
} catch (JMSException e) {
e.printStackTrace();
}
} else {
TextMessage bm = (TextMessage) message;
        try {
            responsexml = bm.getText();
            System.out.println(“------------内容是:“ + responsexml);
        } catch (JMSException e) {
            logger.error(e.getMessage() e);
        }
}

}*/

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       1350  2019-06-18 11:14  zlw.classpath

     文件         22  2019-06-18 17:00  zlw.gitCOMMIT_EDITMSG

     文件        295  2019-06-18 11:14  zlw.gitconfig

     文件         73  2019-06-18 11:14  zlw.gitdescription

     文件         90  2019-06-18 13:13  zlw.gitFETCH_HEAD

     文件         23  2019-06-18 11:14  zlw.gitHEAD

     文件        478  2019-06-18 11:14  zlw.githooksapplypatch-msg.sample

     文件        896  2019-06-18 11:14  zlw.githookscommit-msg.sample

     文件       3327  2019-06-18 11:14  zlw.githooksfsmonitor-watchman.sample

     文件        189  2019-06-18 11:14  zlw.githookspost-update.sample

     文件        424  2019-06-18 11:14  zlw.githookspre-applypatch.sample

     文件       1638  2019-06-18 11:14  zlw.githookspre-commit.sample

     文件       1348  2019-06-18 11:14  zlw.githookspre-push.sample

     文件       4898  2019-06-18 11:14  zlw.githookspre-rebase.sample

     文件        544  2019-06-18 11:14  zlw.githookspre-receive.sample

     文件       1492  2019-06-18 11:14  zlw.githooksprepare-commit-msg.sample

     文件       3610  2019-06-18 11:14  zlw.githooksupdate.sample

     文件      25259  2019-06-21 09:36  zlw.gitindex

     文件        240  2019-06-18 11:14  zlw.gitinfoexclude

     文件        942  2019-06-18 17:00  zlw.gitlogsHEAD

     文件        942  2019-06-18 17:00  zlw.gitlogs
efsheadsmaster

     文件        173  2019-06-18 11:14  zlw.gitlogs
efs
emotesoriginHEAD

     文件        286  2019-06-18 13:53  zlw.gitlogs
efs
emotesoriginmaster

     文件         45  2019-06-18 13:54  zlw.gitobjects79d16d13f36fdb68f5a12c742cb4182eac721b5

     文件        106  2019-06-18 17:00  zlw.gitobjectscec052748c72b5f89cdccd782729f2c7a544925

     文件        648  2019-06-18 17:00  zlw.gitobjectsd65dc00434560f6be273d538427a7d2174b5122

     文件        110  2019-06-18 13:11  zlw.gitobjects1fdfffe0594a5cdc254f6f77703adf1a7f824aa

     文件        708  2019-06-18 13:54  zlw.gitobjects209bb03d30154b9a1027dc0fa6d47a326b76a7b6

     文件         46  2019-06-18 14:01  zlw.gitobjects21169d7a8f4cb7bc7392336e297146d1dd3da9b

     文件        390  2019-06-18 17:00  zlw.gitobjects2159ebc6de5b7ace6fc01b5b496e9a7a90a9036e

............此处省略589个文件信息

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件举报,一经查实,本站将立刻删除。

发表评论

评论列表(条)