Отправка сообщения конкретным подключенным пользователям с помощью webSocket?

вот простой чат-сервер частных / прямых сообщений.

package.json

{
  "name": "chat-server",
  "version": "0.0.1",
  "description": "WebSocket chat server",
  "dependencies": {
    "ws": "0.4.x"
  }
}

server.js

var webSocketServer = new (require('ws')).Server({port: (process.env.PORT || 5000)}),
    webSockets = {} // userID: webSocket

// CONNECT /:userID
// wscat -c ws://localhost:5000/1
webSocketServer.on('connection', function (webSocket) {
  var userID = parseInt(webSocket.upgradeReq.url.substr(1), 10)
  webSockets[userID] = webSocket
  console.log('connected: ' + userID + ' in ' + Object.getOwnPropertyNames(webSockets))

  // Forward Message
  //
  // Receive               Example
  // [toUserID, text]      [2, "Hello, World!"]
  //
  // Send                  Example
  // [fromUserID, text]    [1, "Hello, World!"]
  webSocket.on('message', function(message) {
    console.log('received from ' + userID + ': ' + message)
    var messageArray = JSON.parse(message)
    var toUserWebSocket = webSockets[messageArray[0]]
    if (toUserWebSocket) {
      console.log('sent to ' + messageArray[0] + ': ' + JSON.stringify(messageArray))
      messageArray[0] = userID
      toUserWebSocket.send(JSON.stringify(messageArray))
    }
  })

  webSocket.on('close', function () {
    delete webSockets[userID]
    console.log('deleted: ' + userID)
  })
})

- инструкции

чтобы проверить это, выполните команду npm install установить ws. Затем, чтобы запустить чат-сервер, запустите node server.js (или npm start) на одной вкладке терминала. Затем на другой вкладке терминала запустите wscat -c ws://localhost:5000/1, где 1 - это идентификатор пользователя подключающегося пользователя. Затем на третьей вкладке терминала запустите wscat -c ws://localhost:5000/2, а затем, чтобы отправить сообщение от пользователя 2 до 1 введите ["1", "Hello, World!"].

недостатки

этот чат-сервер очень просто.

• настойчивость

  он не хранит сообщения в базе данных, таких как PostgreSQL. Таким образом, пользователь, которому вы отправляете сообщение, должен быть подключен к серверу для его получения. В противном случае, сообщение будет потеряно.

• безопасность

  это небезопасный.

  • если я знаю URL сервера и идентификатор пользователя Алисы, то я могу олицетворять Алису, т. е. подключаться к серверу как к ней, позволяя мне получать ее новые входящие сообщения и отправлять сообщения от нее любому пользователю, чей идентификатор пользователя я также знаю. Чтобы сделать его более безопасным, измените сервер, чтобы он принимал ваш маркер доступа (вместо вашего идентификатора пользователя) при подключении. Затем сервер может получить Ваш идентификатор пользователя из маркера доступа и пройти проверку подлинности вы.

  • я не уверен, что он поддерживает WebSocket Secure (wss://) соединения, так как я только проверил его на localhost, и я не уверен, как безопасно подключиться от localhost.

Я хотел бы поделиться тем, что я сделал. Надеюсь, это не будет пустой тратой времени.

Я создал таблицу базы данных, содержащую поле ID, IP, имя пользователя, logintime и logouttime. Когда пользователь входит в logintime будет currect unixtimestamp. И когда соединение запускается в базе данных websocket проверяет наличие самого большого logintime. Это будет прийти пользователь вошел в систему.

и когда пользователь выходит из системы он будет хранить currect logouttime. Пользователь станет тем, кто оставил приложение.

всякий раз, когда появляется новое сообщение, Websocket ID и IP сравниваются и отображается соответствующее имя пользователя. Ниже приведен пример кода...

// when a client connects
function wsOnOpen($clientID) {
      global $Server;
      $ip = long2ip( $Server->wsClients[$clientID][6] );

      require_once('config.php');
      require_once CLASSES . 'class.db.php';
      require_once CLASSES . 'class.log.php';

      $db = new database();
      $loga = new log($db);

      //Getting the last login person time and username
      $conditions = "WHERE which = 'login' ORDER BY id DESC LIMIT 0, 1";
      $logs = $loga->get_logs($conditions);
      foreach($logs as $rows) {

              $destination = $rows["user"];
              $idh = md5("$rows[user]".md5($rows["time"]));

              if ( $clientID > $rows["what"]) {
                      $conditions = "ip = '$ip', clientID = '$clientID'  

                      WHERE logintime = '$rows[time]'";
                      $loga->update_log($conditions);
             }
      }
      ...//rest of the things
}