Nodejs 在 pub/sub 中从客户端发布

Posted 2023-04-18

【中文标题】Nodejs 在 pub/sub 中从客户端发布

【英文标题】：Nodejs Publish from Client in pub/sub

【发布时间】：2012-10-13 06:38:54

【问题描述】：

我正在尝试在 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/', function(req, 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);
  

【问题讨论】：

请帮助我们在您的代码中添加一些解释和/或 cmets，特别是在您的客户端套接字回调函数中。您希望您的客户在哪里以及以何种方式发布数据？

您似乎正在尝试使用POST 路由来允许客户端发布事件；对吗？

【参考方案1】：

您可以在客户端和服务器 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。