blocks|key|1900140|text|您正试图颠倒控制流程。方法是让你的控制器实现一个你的服务器可以用来传递控制的接口(+API)。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1900141|一个简单的例子是：|1900142|在mycontroller.js中|offset|length|style|CODE|1900143|//+no+require+needed+here,+at+least,+I+don't+think+so

//+Controller+agrees+to+implement+the+function+called+"respond"
module.exports.respond+=+function(socket_io){
++++//+this+function+expects+a+socket_io+connection+as+argument

++++//+now+we+can+do+whatever+we+want:
++++socket_io.on('news',function(newsreel){

++++++++//+as+is+proper,+protocol+logic+like
++++++++//+this+belongs+in+a+controller:

++++++++socket.broadcast.emit(newsreel);
++++});
}|code-block|syntax|javascript|1900144|现在在server.js中|1900145|var+io+=+require('socket.io').listen(80);
var+controller+=+require('./mycontroller');

io.sockets.on('connection',+controller.respond+);|1900146|这个例子很简单，因为控制器API看起来就像一个socket.io回调函数。但是，如果您想要将其他参数传递给控制器呢？例如io对象本身或表示端点的变量？为此，您需要更多的工作，但这并不是很多。这基本上与我们经常用来打破或创建闭包的技巧相同:函数生成器：|1900147|1900148|module.exports.respond+=+function(endpoint,socket){
++++//+this+function+now+expects+an+endpoint+as+argument

++++socket.on('news',function(newsreel){

++++++++//+as+is+proper,+protocol+logic+like
++++++++//+this+belongs+in+a+controller:

++++++++endpoint.emit(newsreel);+//+broadcast+news+to+everyone+subscribing
+++++++++++++++++++++++++++++++++++++//+to+our+endpoint/namespace
++++});
}|1900149|现在在服务器上，我们需要做更多的工作才能通过端点：|1900150|var+io+=+require('socket.io').listen(80);
var+controller+=+require('./mycontroller');

var+chat+=+io
++.of('/chat')
++.on('connection',+function+(socket)+{
++++++controller.respond(chat,socket);
++});|1900151|注意，我们直接传递了socket，但是我们通过闭包捕获了chat。这样，您就可以拥有多个端点，每个端点都有自己的控制器：|1900152|var+io+=+require('socket.io').listen(80);
var+news_controller+=+require('./controllers/news');
var+chat_controller+=+require('./controllers/chat');

var+news+=+io
++.of('/news')
++.on('connection',+function+(socket)+{
++++++news_controller.respond(news,socket);
++});

var+chat+=+io
++.of('/chat')
++.on('connection',+function+(socket)+{
++++++chat_controller.respond(chat,socket);
++});|1900153|实际上，您甚至可以为每个端点使用多个控制器。请记住，除了订阅事件之外，控制器不会做任何事情。监听的是服务器：|1900154|var+io+=+require('socket.io').listen(80);
var+news_controller+=+require('./controllers/news');
var+chat_controller+=+require('./controllers/chat');

var+chat+=+io
++.of('/chat')
++.on('connection',+function+(socket)+{
++++++news_controller.respond(chat,socket);
++++++chat_controller.respond(chat,socket);
++});|1900155|它甚至适用于普通的socket.io+(没有端点/名称空间)：|1900156|var+io+=+require('socket.io').listen(80);
var+news_controller+=+require('./controllers/news');
var+chat_controller+=+require('./controllers/chat');

io.sockets.on('connection',+function+(socket)+{
++++news_controller.respond(socket);
++++chat_controller.respond(socket);
});|1900157|entityMap^0|0|0|1|F|0|0|3|9|0|0|1O|2|0|1|F|0|0|0|0|A|6|S|4|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|1F|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|1G|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|1H|8|@$F|1I|G|1J|H|I]]|9|@]|A|$]]|$1|J|3|K|5|L|7|1K|8|@]|9|@]|A|$M|N]]|$1|O|3|P|5|6|7|1L|8|@$F|1M|G|1N|H|I]]|9|@]|A|$]]|$1|Q|3|R|5|L|7|1O|8|@]|9|@]|A|$M|N]]|$1|S|3|T|5|6|7|1P|8|@$F|1Q|G|1R|H|I]]|9|@]|A|$]]|$1|U|3|E|5|6|7|1S|8|@$F|1T|G|1U|H|I]]|9|@]|A|$]]|$1|V|3|W|5|L|7|1V|8|@]|9|@]|A|$M|N]]|$1|X|3|Y|5|6|7|1W|8|@]|9|@]|A|$]]|$1|Z|3|10|5|L|7|1X|8|@]|9|@]|A|$M|N]]|$1|11|3|12|5|6|7|1Y|8|@$F|1Z|G|20|H|I]|$F|21|G|22|H|I]]|9|@]|A|$]]|$1|13|3|14|5|L|7|23|8|@]|9|@]|A|$M|N]]|$1|15|3|16|5|6|7|24|8|@]|9|@]|A|$]]|$1|17|3|18|5|L|7|25|8|@]|9|@]|A|$M|N]]|$1|19|3|1A|5|6|7|26|8|@]|9|@]|A|$]]|$1|1B|3|1C|5|L|7|27|8|@]|9|@]|A|$M|N]]|$1|1D|3|-4|5|6|7|28|8|@]|9|@]|A|$]]]|1E|$]]

You are trying to invert the flow of control. The way to do it is for your controller to implement an interface (an API) that your server can use to pass control to.

A simple example would be:

In <code>mycontroller.js</code>

<pre><code>// no require needed here, at least, I don't think so

// Controller agrees to implement the function called "respond"
module.exports.respond = function(socket_io){
 // this function expects a socket_io connection as argument

 // now we can do whatever we want:
 socket_io.on('news',function(newsreel){

 // as is proper, protocol logic like
 // this belongs in a controller:

 socket.broadcast.emit(newsreel);
 });
}
</code></pre>

Now in <code>server.js</code>:

<pre><code>var io = require('socket.io').listen(80);
var controller = require('./mycontroller');

io.sockets.on('connection', controller.respond );
</code></pre>

This example is simple because the controller API looks exactly like a socket.io callback. But what if you want to pass other parameters to the controller? Like the <code>io</code> object itself or the variables representing end points? For that you'd need a little more work but it's not much. It's basically the same trick we often use to break out of or create closures: function generators:

In <code>mycontroller.js</code>

<pre><code>module.exports.respond = function(endpoint,socket){
 // this function now expects an endpoint as argument

 socket.on('news',function(newsreel){

 // as is proper, protocol logic like
 // this belongs in a controller:

 endpoint.emit(newsreel); // broadcast news to everyone subscribing
 // to our endpoint/namespace
 });
}
</code></pre>

Now on the server we'd need a bit more work in order to pass the end point:

<pre><code>var io = require('socket.io').listen(80);
var controller = require('./mycontroller');

var chat = io
 .of('/chat')
 .on('connection', function (socket) {
 controller.respond(chat,socket);
 });
</code></pre>

Notice that we pass <code>socket</code> straight through but we capture <code>chat</code> via a closure. With this you can have multiple endpoints each with their own controllers:

<pre><code>var io = require('socket.io').listen(80);
var news_controller = require('./controllers/news');
var chat_controller = require('./controllers/chat');

var news = io
 .of('/news')
 .on('connection', function (socket) {
 news_controller.respond(news,socket);
 });

var chat = io
 .of('/chat')
 .on('connection', function (socket) {
 chat_controller.respond(chat,socket);
 });
</code></pre>

Actually, you can even use multiple controllers for each endpoint. Remember, the controllers don't do anything apart from subscribing to events. It's the server that's doing the listening:

<pre><code>var io = require('socket.io').listen(80);
var news_controller = require('./controllers/news');
var chat_controller = require('./controllers/chat');

var chat = io
 .of('/chat')
 .on('connection', function (socket) {
 news_controller.respond(chat,socket);
 chat_controller.respond(chat,socket);
 });
</code></pre>

It even works with plain socket.io (no endpoints/namespaces):

<pre><code>var io = require('socket.io').listen(80);
var news_controller = require('./controllers/news');
var chat_controller = require('./controllers/chat');

io.sockets.on('connection', function (socket) {
 news_controller.respond(socket);
 chat_controller.respond(socket);
});
</code></pre>

blocks|key|1900236|text|你可以很容易地做到这一点，你只需要在app.js中编写套接字连接，然后你就可以在你想要的任何地方使用套接字|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1900237|在app.js文件中放入如下代码|offset|length|style|CODE|1900238|+var+http+=+require('http').createServer(app);
+const+io+=+require('socket.io')(http);++

+io.sockets.on("connection",+function+(socket)+{
+//+Everytime+a+client+logs+in,+display+a+connected+message
+console.log("Server-Client+Connected!");

+socket.join("_room"+%2B+socket.handshake.query.room_id);

+socket.on('connected',+function+(data)+{

+++});
});

const+socketIoObject+=+io;
module.exports.ioObject+=+socketIoObject;|code-block|syntax|javascript|1900239|在任何文件或控制器中，您都可以像下面这样导入对象|1900240|+const+socket+=+require('../app');+//import+socket++from+app.js

++++++//you+can+emit+or+on+the+events+as+shown+
+socket.ioObject.sockets.in("_room"+%2B+req.body.id).emit("msg",+"How+are+You+?");|1900241|entityMap^0|0|1|6|0|0|0|0^^$0|@$1|2|3|4|5|6|7|S|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|T|8|@$D|U|E|V|F|G]]|9|@]|A|$]]|$1|H|3|I|5|J|7|W|8|@]|9|@]|A|$K|L]]|$1|M|3|N|5|6|7|X|8|@]|9|@]|A|$]]|$1|O|3|P|5|J|7|Y|8|@]|9|@]|A|$K|L]]|$1|Q|3|-4|5|6|7|Z|8|@]|9|@]|A|$]]]|R|$]]

You can do this very easily you have to only write socket connection in app.js and than you can use socket anywhere you want
In <code>app.js</code> file put code like below
<pre><code> var http = require('http').createServer(app);
 const io = require('socket.io')(http); 

 io.sockets.on(&quot;connection&quot;, function (socket) {
 // Everytime a client logs in, display a connected message
 console.log(&quot;Server-Client Connected!&quot;);

 socket.join(&quot;_room&quot; + socket.handshake.query.room_id);

 socket.on('connected', function (data) {

 });
});

const socketIoObject = io;
module.exports.ioObject = socketIoObject;
</code></pre>
In any file or in controller you can import that object like below
<pre><code> const socket = require('../app'); //import socket from app.js

 //you can emit or on the events as shown 
 socket.ioObject.sockets.in(&quot;_room&quot; + req.body.id).emit(&quot;msg&quot;, &quot;How are You ?&quot;);
</code></pre>

blocks|key|1686788|text|You+can+solve+this+problem+declaring+io+instance+as+global+variable.

at+the+last+line+of+my+app.js:+IoInstance+=+require("./socket.io")(server);

at+the+'./socket.io'+:
const+chatNamespace+=+require("./namespaces/chat");
const+notificationsNamespace+=+require("./namespaces/notifications");
const+auth+=+require("./middlewares/auth");

module.exports+=+(server)+=>+{
++const+io+=+require("socket.io").listen(server);

++io.of("/chats")
++++.use(auth)
++++.on("connect",+(socket)+=>+chatNamespace({+io,+socket+}));

++io.of("/notifications")
++++.use(auth)
++++.on("connect",+(socket)+=>+notificationsNamespace({+io,+socket+}));

++return+io;
};

then,+you+can+use+the+IoInstance+wherever+you+want,+event+into+your+controller.+Btw,+I+could+have+use+it+into+my+namespaces+as+well,+but+I've+just+realized+it+right+now.

example+of+implementation+in+the+testController.js:

module.exports+=+async+(req,+res)+=>+{
++IoInstance.of("/notifications")
++++.to("myUserId")
++++.emit("sendNotification",+["test",+"test1"]);
++return+res.send("oioi");
};|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|1686789|unstyled|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|G|8|@]|9|@]|A|$B|C]]|$1|D|3|-4|5|E|7|H|8|@]|9|@]|A|$]]]|F|$]]

<pre><code>You can solve this problem declaring io instance as global variable.

at the last line of my app.js: IoInstance = require(&quot;./socket.io&quot;)(server);

at the './socket.io' :
const chatNamespace = require(&quot;./namespaces/chat&quot;);
const notificationsNamespace = require(&quot;./namespaces/notifications&quot;);
const auth = require(&quot;./middlewares/auth&quot;);

module.exports = (server) =&gt; {
 const io = require(&quot;socket.io&quot;).listen(server);

 io.of(&quot;/chats&quot;)
 .use(auth)
 .on(&quot;connect&quot;, (socket) =&gt; chatNamespace({ io, socket }));

 io.of(&quot;/notifications&quot;)
 .use(auth)
 .on(&quot;connect&quot;, (socket) =&gt; notificationsNamespace({ io, socket }));

 return io;
};

then, you can use the IoInstance wherever you want, event into your controller. Btw, I could have use it into my namespaces as well, but I've just realized it right now.

example of implementation in the testController.js:

module.exports = async (req, res) =&gt; {
 IoInstance.of(&quot;/notifications&quot;)
 .to(&quot;myUserId&quot;)
 .emit(&quot;sendNotification&quot;, [&quot;test&quot;, &quot;test1&quot;]);
 return res.send(&quot;oioi&quot;);
};
</code></pre>

I only need <code>socket.io</code> to <code>emit</code> messages to <code>clients</code>, if a new object is inserted to database. So my idea was to emit the message directly from my controller’s <code>insert-method</code>. In my <code>server.js</code> file, i'm creating the <code>socket.io object</code> and try to make it accessible for other modules:
<pre><code>var server = require('http').createServer(app);
var io = require('socket.io').listen(server);

//make socket io accessible for other modules
module.exports.io = io;
</code></pre>
In my controller I have tried using socket.io in this way:
<pre><code>var io = require('../server').io;
...
io.sockets.on(&quot;connection&quot;, function(socket){
 passportSocketIo.filterSocketsByUser(io, function (user) {
 return user.workingAt === socket.handshake.user.workingAt;
 }).forEach(function(s){
 s.send(&quot;news&quot;, insertedObject);
 });
});
</code></pre>
And here I'm stuck. The &quot;connection&quot; event will never be fired and so the message will not be emitted. Is that the correct way to use <code>socket.io</code> in <code>separate</code> files? Unfortunately I cant find complex <code>socket.io</code> example.

Use socket.io in controllers

数据库

服务器

我只需要socket.io到emit消息到clients，如果一个新的对象被插入到数据库。因此，我的想法是直接从控制器的insert-method发出消息。在我的server.js文件中，我创建了socket.io object，并尝试让其他模块可以访问它：var server = require('http').cr...

问在控制器中使用socket.io
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在控制器中使用socket.ioEN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在控制器中使用socket.io
EN