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   数据库操作，消息的发送和接收，模拟同步