var express = require('express') |
, routes = require('./routes') |
, http = require('http') |
, path = require('path') |
, socketio = require('socket.io') |
, mqtt = require('mqtt'); |
// Express server |
var app = express(); |
// Http server |
var server = http.createServer(app); |
// Socket.io |
var io = socketio.listen(server); |
// all environments |
app.set('port', process.env.PORT || 3000); |
app.set('views', __dirname + '/views'); |
app.set('view engine', 'jade'); |
app.use(express.favicon()); |
app.use(express.logger('dev')); |
app.use(express.bodyParser()); |
app.use(express.methodOverride()); |
app.use(app.router); |
app.use(express.static(path.join(__dirname, 'public'))); |
// development only |
if ('development' == app.get('env')) { |
app.use(express.errorHandler()); |
} |
app.get('/', routes.index); |
io.sockets.on('connection', function(socket) { |
var client = mqtt.createClient(); |
socket.on('publish', function(topic, message) { |
client.publish(topic, message); |
}); |
socket.on('subscribe', function (topic) { |
client.subscribe(topic); |
}); |
client.on('message', function(topic, message) { |
socket.emit('message', topic, message); |
}); |
}); |
server.listen(app.get('port'));
一篇好的git共享代码: https://github.com/adamvr/bearded-dangerzone/blob/master/app.js |
- 浏览: 357390 次
- 性别:
- 来自: 天津
最新评论
-
小小西芹菜:
想要建立实时web,推荐GoEasy的web实时推送,他们是专 ...
用node.js(socket.io)实现数据实时推送 -
gaoyaohuachina:
教训的是!
修改linux的用户名 -
hongtoushizi:
gaoyaohuachina 写道不明白你在干吗,改名字直接新 ...
修改linux的用户名 -
gaoyaohuachina:
不明白你在干吗,改名字直接新建一个用户,把原来用户user d ...
修改linux的用户名 -
wukele:
Mark....
总结比较常用实用的js库
相关推荐
mqtt-realtime-chart-server是一个Express.js-MQTT-Socket.io应用程序,可与结合使用。 产品特点 服务器 发布并订阅MQTT主题(例如,电压) 使用websockets将收到的消息转发给客户端 客户 多系列折线图实时数据...
描述该Node.js实现的代理是从MQTT和Influx数据库到socket.io的桥梁。 该服务器是MQTT代理的代理,并中继连接的客户端请求的所有消息。 我还可以从一个或多个涌入数据库中提取历史数据。 socker.io的使用允许从...
实现 MQTT-to-socket.io 桥以将 MQTT 主题公开给 Socket.io 的 mqtt.js 客户端 过滤器的节点红色流 以下是向 MQTT 计数器主题 (get/ESP8266/counterValue) 添加过滤值主题 (get/ESP8266/filterValue) 的 Node-Red ...
mqtt-connected-socket.io
通过Socket.io将Android手机传感器数据发送到NodeJS服务器和Web界面/ GUI的界面 概括 用于运行脚本 这允许通过命令行读取传感器(以及更多) Node js运行child_process以从内置运动传感器读取数据,并通过socket....
Web界面和服务器,用于使用Node.js和Socket.io发布/订阅MQTT消息,以实现家庭自动化。 index.html页面使用Web套接字通过node.js连接到侦听服务器WebMQonttrol_server.js 。 服务器创建与MQTT代理的连接,并从/向连接...
现在,Ninja Blocks不再存在了,该项目将使您能够利用Ninja Block将Socket.IO,MQTT和webhooks(TBD)的RF433消息桥接到另一个系统。它是如何工作的其实很简单。 忍者斗篷通过序列发布消息到Beagleboard。 该模块...
特性:支持 MQTT V3.1/V3.1.1 协议QoS0, QoS1, QoS2 发布和订阅TCP/SSL Socket 支持自动重连Keepalive 和 ping/pong示例:%% connect to broker {ok, C} = emqttc:start_link([{host, "localhost"}, {client...
情报局 AIOJS是一个简单JavaScript库,用于通过mqtt协议管理物联网设备。 入门
nesh-sfd-demo SFD 2015的Node,Express,Socket.io,HighChart演示 该项目与Aryan Limjap(@hadronp)完成的Arduino,Python,Mqtt实现配对。 @请参阅
MQTT 服务器:EMQX Broker 4.1、NodeJS、Express、Socket.io、MongoDB MQTT 客户端:SDK: MTQQ.js,Vue、JavaScript 等 用户登录 -> 从数据库检索用户是否存在:存在则检查密码,不存在则创建用户 客户端发送消息 ->...
Node.js 我在此存储库中使用了Node.js,Express.js,Socket.io和Mqtt.js和Mysql。这里我们有: Node.js和Express.js基础使用Express.js和Socket.io的简单Mqtt客户端使用Express.js和Socket.io的简单聊天应用...贡献...
该示例使用 Flask Web 框架用 Python 编写,订阅了一个 MQTT 主题,遥测从代理 mosquitto 发布到该主题,并使用 socket.io 将消息推送到浏览器。 结果显示在 html 框中。 安装 sudo pip install Flask sudo pip ...
这是一个JavaScript框架,用于通过socket.io桥可视化来自MQTT的实时数据。 用法 TL; DR; 参见示例文件夹! Animera.js标准化了您网站上的图形元素如何连接到数据源并响应实时数据进行动画处理。 我们将响应实时...
:warning: 到目前为止,它只支持 MQTT 和 WebSockets(原生、Socket.IO 和自定义实现)。 什么是格力? Glee 是一个规范优先的框架,可帮助您构建服务器端应用程序。 它利用 AsyncAPI 规范来提高您的工作效率: ...
支持的协议: HTTP,Socket.io,Websocket,MQTT,CoAP,AMQP和XMPP。 版本2.0 我们已经将Meshblu完全重写为许多小型组件或微服务。 此Meshblu 1.0存储库正在保留以供历史参考。 所有新的Meshblu组件都以meshblu-...
MQTT.js#251 ... COM / lunixbochs / subli
-(socket.io) MongoDB,用于存储从位于Torre的气象站获得的数据以及从NC发出的警报消息到塔-(猫鼬)V0.9 该版本的系统已于2018年1月25日在里约克拉里奥进行的体验中进行了测试。 它仍有待生产。V0.9.1 此版本...
目录结构 以太网:SOCKET API(如BSD和WIZCHIP( / W5300 / W5200 / W5100 / )驱动程序互联网 : DHCP客户端DNS客户端FTP客户端FTP服务器SNMP代理/陷阱SNTP客户端TFTP客户端HTTP服务器MQTT客户端其他将被添加。...
MQTT(例如Mosquitto) 安装 npm install --global nano-stream-x 用法 启动流式Web服务器 nano-stream-x 服务器将默认运行在http://127.0.0.1:3000 。 通过传入host或port参数来覆盖这些默认值: nano-stream-x ...