nodejs+mqtt协议的聊天室

作者：

在

安装nodejs

yum install libtool automake autoconf gcc-c++ openssl-devel  
wget https://nodejs.org/dist/v0.12.7/node-v0.12.7.tar.gz
tar zxvf node-v0.12.7.tar.gz
cd node-v0.12.7
./configure
make
make install

检测是否安装成功

node -v

选择安装mqtt broker

这里选择mosca,在项目目录执行

npm install mosca --save

会生成目录node_modules，目录包含项目所需要的模块，里面已经有mosca模块。

服务端代码

var mosca = require("mosca");
var broker = new mosca.Server({});
var express = require("express");
var http = require("http");
var app = express()
var srv = http.createServer(app)
var path = require("path");
app.use(express.static(path.dirname(require.resolve("mosca")) + "/public"))
app.listen(3000)

运行

sudo npm install forever -g
forever start -l app.log -o out.log -e err.log -a mqtt/app.js

客户端测试

新建index.html

<html>
  <head>
    <script src="/mqtt.js"></script>
  </head>
  <body>
    <script>      
var client = mqtt.connect();      
client.subscribe("mqtt/demo");      
client.on("message", function(topic, payload) {        
alert([topic, payload].join(": "));        
client.end();      
});      
client.publish("mqtt/demo", "hello world!");   
 </script>
  </body>
</html>

来自为知笔记(Wiz)

更多文章