13

我正在尝试使用此处描述的订阅功能。但是，在编辑时/assets/js/app.js，我收到此错误：

Uncaught ReferenceError: Room is not defined

所以，我不完全确定为什么，但它找不到我的模型。这是我的代码：

Room.subscribe(req, [{id: "5278861ab9a0d2cd0e000001"}], function (response) {
  console.log('subscribed?');
  console.log(response);
});

这是在 app.js 的上下文中

(function (io) {

  // as soon as this file is loaded, connect automatically, 
  var socket = io.connect();
  if (typeof console !== 'undefined') {
    log('Connecting to Sails.js...');
  }

  socket.on('connect', function socketConnected() {

    // Listen for Comet messages from Sails
    socket.on('message', function messageReceived(message) {

      ///////////////////////////////////////////////////////////
      // Replace the following with your own custom logic
      // to run when a new message arrives from the Sails.js
      // server.
      ///////////////////////////////////////////////////////////
      log('New comet message received :: ', message);
      //////////////////////////////////////////////////////

    });


    ///////////////////////////////////////////////////////////
    // Here's where you'll want to add any custom logic for
    // when the browser establishes its socket connection to 
    // the Sails.js server.
    ///////////////////////////////////////////////////////////
    log(
        'Socket is now connected and globally accessible as `socket`.\n' + 
        'e.g. to send a GET request to Sails, try \n' + 
        '`socket.get("/", function (response) ' +
        '{ console.log(response); })`'
    );
    ///////////////////////////////////////////////////////////

    // This is the part I added: 
    Room.subscribe(req, [{id: "5278861ab9a0d2cd0e000001"}], function (response) {
      console.log('subscribed?');
      console.log(response);
    });
    //


   });


  // Expose connected `socket` instance globally so that it's easy
  // to experiment with from the browser console while prototyping.
  window.socket = socket;


  // Simple log function to keep the example simple
  function log () {
    if (typeof console !== 'undefined') {
      console.log.apply(console, arguments);
    }
  }


})(

我会以正确的方式解决这个问题吗？我应该将其直接存储在app.js 中吗？

4

1 回答 1

28

要订阅模型实例，我使用以下实时模型事件模式，其中一些驻留在客户端，一些驻留在服务器上。请记住，客户端不能只订阅自己——你必须向服务器发送一个请求，让它知道你想被订阅——这是唯一安全的方法。（例如，您可能希望发布包含敏感信息的通知——您希望确保连接的套接字在订阅它们之前有权查看该信息。）

我将使用一个带有用户模型的应用程序示例。假设我想在现有用户登录时通知人们。

客户端（第一部分）

在客户端，为简单起见，我将使用文件夹app.js中的现有文件/assets/js（或/assets/linker/js文件夹，如果您--linker在构建应用程序时使用了开关。）

要将我的套接字请求发送到 内的服务器assets/js/app.js，我将使用该socket.get()方法。此方法模仿 AJAX “get”请求（即$.get()）的功能，但使用套接字而不是 HTTP。（仅供参考：您还可以访问socket.post()、socket.put()和socket.delete()）。

代码看起来像这样：

 
// Client-side (assets/js/app.js)
// This will run the `welcome()` action in `UserController.js` on the server-side.

//...

socket.on('connect', function socketConnected() {

  console.log("This is from the connect: ", this.socket.sessionid);

  socket.get(‘/user/welcome’, function gotResponse () {
    // we don’t really care about the response
  });

//...

服务器端（第一部分）

在 中的welcome()操作中UserController.js，现在User.subcribe()我们实际上可以使用该方法为该客户端（套接字）订阅通知。

 
// api/UserController.js

//...
  welcome: function (req, res) {
    // Get all of the users
    User.find().exec(function (err, users) {
      // Subscribe the requesting socket (e.g. req.socket) to all users (e.g. users)
      User.subscribe(req.socket, users);
    });
  }

//...

回到客户端（第二部分）......

我希望套接字“监听”我要从服务器发送的消息。为此，我将使用：

 
// Client-side (assets/js/app.js)
// This will run the `welcome()` action in `UserController.js` on the backend.

//...

socket.on('connect', function socketConnected() {

  console.log("This is from the connect: ", this.socket.sessionid);

  socket.on('message', function notificationReceivedFromServer ( message ) {
    // e.g. message ===
    // {
    //   data: { name: ‘Roger Rabbit’},
    //   id: 13,
    //   verb: ‘update’
    // }
  });

  socket.get(‘/user/welcome’, function gotResponse () {
    // we don’t really care about the response
  });

// ...

回到服务器端（第二部分）......

最后，我将开始在服务器端发送消息，方法是：User.publishUpdate(id);

 
// api/SessionController.js

//...
  // User session is created
  create: function(req, res, next) {

    User.findOneByEmail(req.param('email'), function foundUser(err, user) {
      if (err) return next(err);

      // Authenticate the user using the existing encrypted password...
      // If authenticated log the user in...

      // Inform subscribed sockets that this user logged in
      User.publishUpdate(user.id, {
        loggedIn: true,
        id: user.id,
        name: user.name,
        action: ' has logged in.'
      });
    });
  }
//...

您还可以查看构建 Sails 应用程序：Ep21 - 使用实时模型事件将 socket.io 和sails 与自定义控制器操作集成以获取更多信息。

于 2013-11-12T20:55:56.763 回答