var mqttServer=require('mosca');
var mysql=require('mysql');
var mqttsetting={
port:11111,
};
var sqldata='';
var connecttion=mysql.createConnection({
host :'localhost',
port :3306,
database :'db',
user :'root',
password:'123456',
});
sqlcon();
var server = new mqttServer.Server(mqttsetting);
server.on('ready', setup);
function setup() {
console.log('Mosca server is up & running'+mqttsetting.port);
}
server.on('clientConnected', function (client) {
console.log('Client Connected: ', client.id);
});
server.on('clientDisconnected', function (client) {
console.log('Client Disconnected: ', client.id);
});
/***消息发布****/
server.on('published', function (packet, client) {
console.log('Published: ', packet.topic.toString()+client+packet.payload.toString());
//switch (packet.topic) {
// case 'test':
//console.log("payload: ", packet.payload.toString());
//sqldata="INSERT INTO test_msg SET msg="+connecttion.escape(packet.payload.toString());
//insertmsg();
//var msg = {
//topic: 'repeat',
//payload: packet.payload,
//qos: 0,
//retain: false
//server.publish(msg, function () {
//console.log('repeat! ');
//break;
});
function sqlcon()
{
connecttion.connect(function(err){
if(err) console.log('connect error');
else
console.log('connect success');
});
}
function insertmsg()
{
connecttion.query(sqldata,function(err,result)
{
if(err) console.log('INSERT error');
else
{
console.log('INSERT success');
}
});
}