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 数据库操作,消息的发送和接收,模拟同步
- [No00008C]图解SQL的各种连接join让你对SQL的连接一目了然
- mysql:批量更新
- MySQL备份原理详解
- MySQL备份原理详解
- PostgreSQL 聚合函数共享申请的内存空间
- mysql-cluster集群原理介绍和搭建步骤(四个data/sql节点)
- mysql source导入多个文件/较大的sql文件/在线互转数据
- MySQL数据库性能优化之存储引擎选择
- memcached安装和启动
- MySQL 数据库性能优化之SQL优化
- JAVA客户端调用memcached
- MySQL 数据库性能优化之索引优化
- MySQL 数据库性能优化之表结构优化
- MySQL 数据库性能优化之缓存参数优化
- 如何获取SQL Server数据库连接字符串的某些部分
- mssql数据库导出表明字段名和说明到Excel
- redis学习笔记(8)---微线图sparkline
- 使用Xmemcached客户端操作Memcached缓存系统
- 从库crash一直自动重启(mysqld got signal 11)问题解决
- mysql中case、when、if、then的用法