我正在尝试在nodejs中构建一个小应用程序来发布和订阅.我被困在如何从客户端发布.这是我的代码.
这是我的服务器代码(server.js)
var express = require('express'),app = express(),http = require('http'),server = http.createServer(app); app.use(express.bodyParser()); app.get('/',function(req,res) { res.sendfile(__dirname + '/public/index.html'); }); app.post('/publish/:channel/:event/',res) { console.log("**************************************"); var params = req.params; console.log(req.params); console.log(req.body); var data = req.body; console.log("**************************************"); var result = io.sockets.emit(params.channel,{event:params.event,data:data}); //console.log(result); console.log("**************************************"); res.sendfile(__dirname + '/public/index.html'); }); //include static files app.use(express.static(__dirname + '/public')); server = server.listen(3000); var io = require('socket.io').listen(server); io.sockets.on('connection',function (s) { socket = s socket.emit('c1',{ hello: 'world' }); socket.on('test',function (data) { socket.emit('c1',{ hello: 'world' }); console.log('test');console.log(data); }); });
这是客户端代码
var narad = {}; narad.url = 'http://192.168.0.46:3000'; narad.lisentingChannels = {} var socket = io.connect(narad.url); function Channel(channelName) { this.channelName = channelName; //serviceObject is the object of this.events = {}; }; Channel.prototype.bind = function (event,callback) { this.events[event] = callback; }; narad.subscribe = function (channelName) { var channel = new Channel(channelName) this.lisentingChannels[channelName] = channel; socket.on(channelName,this.callbackBuilder(channel)) return this.lisentingChannels[channelName]; } narad.callbackBuilder = function (channel) { return function (data) { var callback = channel.events[data["event"]]; callback(data.data); } }
解决方法
您可以在客户端和服务器websocket连接上使用emit方法,取自
Socket.io:
var socket = io.connect(narad.url); socket.emit('publish','message');
然后在您的服务器上收听消息:
socket.on('publish',function (data) { // Emit the published message to the subscribers socket.emit('subscribers',data); console.log(data); });
这样您就可以使用websockets的双向通信,而无需使用某些POST API.
原文地址:https://www.jb51.cc/js/157800.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。