当前位置:网站首页>RMS to EAP is simply implemented through mqtt
RMS to EAP is simply implemented through mqtt
2022-07-05 10:07:00 【panda_ two hundred and twenty-five thousand and four hundred】
Tips : When the article is finished , Directories can be generated automatically , How to generate it, please refer to the help document on the right
List of articles
Preface
EAP yes MES Bridge with equipment ,EAP adopt SECS International standard protocol for data transmission with the machine . Our company RMS through SECS International standard protocol for data transmission with the machine , Just more should be in MES Business logic on the Internet , Put it in RMS On , It's not used so much in architecture EAP The division of labor is clear ,RMS Taking away the business logic and transforming it can also become EAP, I'll simply try
Tips : The following is the main body of this article , The following cases can be used for reference
One 、MQTT
1、 Using message queuing
MES And other systems send information to RMS,RMS The received message is passing SECS\GEM Communicate with semiconductor devices
advantage :
1、 Decouple the system , Improve response time , System functions converge inward , Opening to the outside world ;
2、 Split the asynchronous function of the system , Reduce functional coupling , Provide development efficiency ;
There are advantages and disadvantages , Specific information can be found online , That's not true
MQTT Protocol is a message queuing transmission protocol , Adopt subscription 、 Publishing mechanism , Subscribers receive only the data they have subscribed to , Non subscription data will not be received , It ensures the necessary data exchange , It also avoids the storage and processing caused by invalid data . Therefore, it has been widely used in the industrial Internet of things .
I'm using rabbitmq, because rabbitmq Support MQTT agreement , also MQTT The protocol also supports for Web Message push , It's easy to implement , Support both WEB, There are support clients , Or a general agreement , Any system can use this protocol to communicate with RMS Communications
Two 、 Use steps
1.rabbitmq Support MQTT agreement
The code is as follows ( Example ):
The first one is rabbitmq_mqtt Provides interaction with back-end services , Corresponding port 1883.
rabbitmq-plugins enable rabbitmq_mqtt
The second kind rabbitmq_web_mqtt Provide interaction with the front end , Corresponding port 15675.
rabbitmq-plugins enable rabbitmq_web_mqtt
2.RMS Listen for messages and send messages
stay RMS Add the code as follows ( Example ):
RMS Listen to messages sent by other systems , Through SECS\GEM Communicate with semiconductor devices , The machine returns the result and then passes MQTT Send the results to other systems
3.Web Listen for messages and send messages
The code is as follows ( Example ):
<script type="text/javascript">
// mqtt agreement rabbitmq service
var brokerIp = "10.20.36.64";
// mqtt Protocol port number
var port = 15675;
// Accept the subject of the push message
var topic = "test";
// mqtt Connect
client = new Paho.MQTT.Client(brokerIp, port, "/ws", "clientId_" + parseInt(Math.random() * 100, 10));
var options = {
timeout: 3, // Timeout time
keepAliveInterval: 30, // Heartbeat time
userName: "admin", // user name
password: "admin", // password
onSuccess: function () {
console.log((" Successful connection ~"));
client.subscribe("test1", {
qos: 1 });
},
onFailure: function (message) {
alert(message.errorMessage);
console.log((" The connection fails ~" + message.errorMessage));
}
};
// in consideration of https The situation of
if (location.protocol == "https:") {
options.useSSL = true;
}
client.connect(options);
console.log((" Already connected to " + brokerIp + ":" + port));
// Disconnect event
client.onConnectionLost = function (responseObject) {
console.log(" Lose connection - " + responseObject.errorMessage);
};
// Receive message event
client.onMessageArrived = function (message) {
alert("222:"+message.payloadString);
console.log(" Accept the theme : " + message.destinationName + " The news of : " + message.payloadString);
$("#arrivedDiv").append("<br/>" + message.payloadString);
var count = $("#count").text();
count = Number(count) + 1;
$("#count").text(count);
};
// Push to a specific topic
function sendMessage() {
var a = $("#message").val();
if (client.isConnected()) {
var message = new Paho.MQTT.Message(a);
message.destinationName = topic;
client.send(message);
alert(message);
}
else {
alert("isConnected:" + client.isConnected());
}
}
</script>
4.RMS and WEB After the client starts
test WEB End
test RMS End
rabbitmq In the queue, there will be mqtt- The first line , When you close the client , The queue also disappeared .
summary
Record every bit of it
边栏推荐
- Resolve the horizontal (vertical) sliding conflict between viewpager and WebView
- Idea debugs com intellij. rt.debugger. agent. Captureagent, which makes debugging impossible
- Is it really reliable for AI to make complex decisions for enterprises? Participate in the live broadcast, Dr. Stanford to share his choice | qubit · viewpoint
- ArcGIS Pro creating features
- The popularity of B2B2C continues to rise. What are the benefits of enterprises doing multi-user mall system?
- Kotlin compose and native nesting
- The most comprehensive promotion strategy: online and offline promotion methods of E-commerce mall
- Data visualization platform based on template configuration
- The king of pirated Dall · e? 50000 images per day, crowded hugging face server, and openai ordered to change its name
- TDengine 离线升级流程
猜你喜欢
美图炒币半年亏了3个亿,华为被曝在俄罗斯扩招,AlphaGo的同类又刷爆一种棋,今日更多大新闻在此...
Apache dolphin scheduler system architecture design
The most comprehensive promotion strategy: online and offline promotion methods of E-commerce mall
(1) Complete the new construction of station in Niagara vykon N4 supervisor 4.8 software
Wechat applet - simple diet recommendation (4)
Analysis on the wallet system architecture of Baidu trading platform
百度评论中台的设计与探索
单片机原理与接口技术(ESP8266/ESP32)机器人类草稿
Unity粒子特效系列-毒液喷射预制体做好了,unitypackage包直接用 - 上
卷起來,突破35歲焦慮,動畫演示CPU記錄函數調用過程
随机推荐
MySQL character type learning notes
Roll up, break 35 - year - old Anxiety, animation Demonstration CPU recording Function call Process
Analysis on the wallet system architecture of Baidu trading platform
About getfragmentmanager () and getchildfragmentmanager ()
How to improve the operation efficiency of intra city distribution
【C语言】动态内存开辟的使用『malloc』
Openes version query
TDengine ×英特尔边缘洞见软件包 加速传统行业的数字化转型
Roll up, break through 35 year old anxiety, and animate the CPU to record the function call process
Develop and implement movie recommendation applet based on wechat cloud
揭秘百度智能测试在测试自动执行领域实践
. Net delay queue
TDengine可通过数据同步工具 DataX读写
How Windows bat script automatically executes sqlcipher command
The writing speed is increased by dozens of times, and the application of tdengine in tostar intelligent factory solution
Tongweb set gzip
Cut off 20% of Imagenet data volume, and the performance of the model will not decline! Meta Stanford et al. Proposed a new method, using knowledge distillation to slim down the data set
.Net之延迟队列
如何获取GC(垃圾回收器)的STW(暂停)时间?
Why don't you recommend using products like mongodb to replace time series databases?