nodejs 数据库操作,消息的发送和接收,模拟同步
var deasync = require('deasync'); //导入模板 var mysql=require('mysql'); var Stomp = require('stompjs'); var wordname=null; var url=null; var row1=null; var row2=null; var conn=mysql.createConnection( { host:'localhost', user:'root', password:'Aa1234', database:'ec_spc', port:3306 } ); conn.connect(); select();//数据库的操作 wordname=new String(row1[0].WORD_NAME);//取得字段值 url=new String(row2[0].BAITAI_URL);//取得字段值 sendMessage(wordname,url);//发送消息 function select(){ var selectSql1="select * from spc_word_mst where WORD_ID=? limit 0,1 " var selectSql2="select * from spc_baitai_mst where BAITAI_ID=? limit 0,1" //SPC_Result_JH var key1='001'; var key2='001'; var sync1=true; var sync2=true; conn.query(selectSql1,[key1],function(error,rows){ if(error) console.log(error) row1=rows; sync1=false; }); while(sync1){deasync.sleep(400);} conn.query(selectSql2,[key2],function(error1,rows){ if(error1) console.log(error1) row2=rows; sync2=false; }); while(sync2){deasync.sleep(400);} return row1; return row2; } function sendMessage(wordname,url) { // Use raw TCP sockets // 用原始的tcp接口 var client = Stomp.overTCP('localhost', 61613); // uncomment to print out the STOMP frames //client.debug = console.log; var connectCallback = function(frame) { console.log ('Connected! sending some message'); client.send('/queue/FirstQueue', {}, "wordname:" + wordname+",url:"+url); }; var errorCallback = function(error){ console.log(error.headers.message); }; client.connect('admin', 'admin', connectCallback,connectCallback); }
前提 启动activemq
接收消息
var Stomp=require('stompjs'); var args=process.argv.slice(2); //get param from bat var flag=args[0];// get flag var key_=args[1];// get key var clientTime=new Date().toLocaleString(); var client=Stomp.overTCP('localhost',61613); var connectCallBack=function(frame) { console.log ('Connected! sending some message'); client.send('/queue/FirstQueue', {}, "flag:" + flag+",key:"+key_+",clientTime:"+clientTime); } var errorCallBack=function(error) { console.log(error.headers.message); } client.connect('admin','admin',connectCallBack,errorCallBack);
nodejs 数据库操作,消息的发送和接收,模拟同步。nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步nodejs 数据库操作,消息的发送和接收,模拟同步
相关文章
- Nodejs简单数据库操作
- nodeJs——开发自己的脚手架
- 理解NodeJS多进程
- Nodejs获取网络数据并生成Excel表格详解编程语言
- Nodejs的运行原理-模块载入篇详解编程语言
- [nodejs] nodejs开发个人博客(三)载入页面详解编程语言
- [nodejs] nodejs开发个人博客(二)入口文件详解编程语言
- NodeJS Stream 二:什么是 Stream详解编程语言
- Node.js 使用 MongoDB 数据库实现数据存储(nodejs连接mongodb)
- nodejs教程之入门
- NodeJS制作爬虫全过程
- NodeJS学习笔记之MongoDB模块
- 基于NodeJS的前后端分离的思考与实践(四)安全问题解决方案