0

以下のように Primus websocket サービスをセットアップしました。

http = require('http');
server = http.createServer();

Primus = require('primus');
primus = new Primus(server, {
  transformer: 'websockets',
  pathname: 'ws'
});

primus.on('connection', function connection(spark) {
  console.log("client has connected");
  spark.write("Herro Client, I am Server");
  spark.on('data', function(data) {
    console.log('PRINTED FROM SERVER:', data);
    spark.write('receive '+data)
  });
  spark.on('error', function(data) {
    console.log('PRINTED FROM SERVER:', data);
    spark.write('receive '+data)
  });
});



server.listen(5431);
console.log("Server has started listening");

それは正常に動作します。上記のコードでは、spark.write応答メッセージをユーザーに送信するために使用しています。今、ミドルウェアで使用できるように変換したいと考えています。コードは次のようになります。

primus.use('name', function (req, res, next) {
  doStuff();
});

doStuff() メソッドで、spark インスタンスからクライアントにメッセージを送り返すにはどうすればよいですか?

4

1 に答える 1