Node.js はデータ Push_node.js?1.1.2 を実装します

シナリオ: バックエンド更新データがクライアントにプッシュされます (Java 部分は Tomcat サーバーを使用します)。

ポーリング、Comet、WebSocket など、バックエンド プッシュ データには多くのソリューションがあります。

1. ポーリングはバックエンドの開発コストが最も低く、従来の方法で Ajax リクエストを処理し、データを返します。これは最も安全であるため、研究室のプロジェクトでは常にポーリングが使用されていました。そして最も信頼性の高い方法です。ただし、ポーリングによる通信リソースの浪費は無視できません。データが変更されるかどうかに関係なく、リクエストは通常​​どおり送信および応答され、各 HTTP リクエストには長いヘッダー情報が含まれます。

2. Comet の概念は、クライアントがリクエストを送信した後、接続がタイムアウトするか、バックエンドがデータを返してから接続を再確立するまで接続を維持します。実際に消費されるのはサーバーのリソースです。

3. WebSocket は、HTML5 で提供される全二重通信技術であり、「ハンドシェイク」によってクライアントとサーバー間の通信を実現し、現在サポートされている小さなヘッダーを持ちます。ブラウザは以下の通りです。

WebSocket と Comet を組み合わせて使用​​し、IE8 などのブラウザでは Comet メソッドを使用してダウングレード処理を行うのが理想的です。ただし、この方法では、バックエンドはリクエストを処理するための 2 つのロジック、つまり WebSocket と Comet を実装する必要があります。したがって、この記事で Node.js を追加するのは、実際の状況では、WebSocket (または Comet) の処理ロジックを Node.js 部分に移し、バックエンドに「迷惑」を与えないようにするためです。フロントエンド開発者がプッシュ エンドユーザー開発者になるのは簡単ではありません。 Node.js は、ブラウザと Java ビジネス ロジック層の間の通信の中間層として機能し、クライアントと Tomcat を接続し、Socket (WebSocket ではなく Socket であり、バックエンドは Socket インターフェイスを実装する必要があります) を介して Tomcat と通信します。

クライアント側では、WebSocket と Comet は Socket.io を通じて実装されます。Socket.io は、ブラウザーのバージョンやクライアントごとに適切な実装方法 (WebSocket、ロングプルなど) を選択します。 Socket.io の導入により、WebSocket (またはロングプル..) 接続の処理が非常に簡単になります:

<script src="static/js/socket.io.js"></script>

間の接続の確立。クライアントと Node.js サーバーは最初のステップにすぎません。次に、Node.js サーバーと Java ビジネスの論理層接続を確立する必要があります。このとき、Node.js サーバーはクライアントとして機能し、TCP 接続を送信します。 Tomcat へのリクエスト。接続が成功すると、Node.js サーバーと Tomcat は全二重チャネルを確立します。同様に、Node.js サーバーから Tomcat に転送されるクライアントのリクエストの数。 Tomcat によってプッシュされたデータも、Node.js サーバーを介して各クライアントに配信されます。

var socket = io.connect('127.0.0.1:8181');
 // 发送数据至服务器
socket.emit('fromWebClient', jsonData);
// 从服务器接收数据
 socket.on('pushToWebClient', function (data) {
  // do sth.
 });

ここで問題が発生します。つまり、WebSocket 接続と Socket 接続が確立された後、2 つの接続は相互にブロックされます。 Tomcat は、どの WebSocket 接続がデータを送信したかを知りません。また、Node.js も、Tomcat に送信されるセッション ID を使用して、どのクライアントであるかを識別できます。

クライアントが Node.js との WebSocket 接続を確立すると、各接続には、socketIO と呼ばれるインスタンスが含まれます。各ソケットIO には、接続を一意に識別するための id 属性があります。ソケット ID を使用して、各ソケット IO とソケット ID の間のマッピング関係を保存するマッピング テーブルを Node.js サーバーに作成し、Tomcat にデータを送信するときに Java 部分が一連の処理を実行します。処理し、各クライアントが必要とするさまざまなデータをカプセル化し、それを返します。返されたデータは、socket_id と対応する関係を持っている必要があります。Node.js サーバーが Tomcat によって送信されたデータを受信すると、そのデータはさまざまなソケット IO を介してさまざまなクライアントに配布されます。前述のマッピング テーブルを介して。

var http = require('http'),
  app = http.createServer().listen('8181'),
  io = require('socket.io').listen(app);
io.sockets.on('connection', function (socketIO) {
  // 从客户端接收数据
  socketIO.on('fromWebClient', function (webClientData) {
    // do sth.
  });
  // 客户端断开连接
  socketIO.on('disconnect', function () {
    console.log('DISCONNECTED FROM CLIENT');
  });    
  // 向客户端发送数据
  socketIO.emit('pushToWebClient', jsonData);  
});

Node.js サーバー コード:

上記のコードでは、Node.js サーバーが受け取るものなど、一部のロジックが省略されています。 Tomcat データにはプッシュされたデータとリクエストに応答したデータの 2 種類があり、ここではプッシュされたデータが一律に処理されます。

通信を処理する場合、Node.js から Tomcat に送信されるデータは String 形式ですが、Tomcat から受信したデータは Buffer オブジェクト (8 進数) であるため、これを String に変換してから JSON に変換する必要があります。顧客側に送ります。

var http = require('http'),
   net = require('net'),
   app = http.createServer().listen('8181'),
   io = require('socket.io').listen(app),
   nodeServer = new net.Socket();
 // 连接到Tomcat
 nodeServer.connect(8007, '127.0.0.1', function() {
   console.log('CONNECTED');
 });
// 存储客户端的WebSocket连接实例
 var aSocket = {};
 // 同客户端建立连接
 io.sockets.on('connection', function (socketIO) {
  // 从客户端接收数据，然后发送至Tomcat
   socketIO.on('fromWebClient', function (webClientData) {    
    // 存储至映射表
     aSocket[socketIO.id] = socketIO;
    // 发送至Tomcat的数据中添加socket_id
    webClientData['sid'] = socketIO.id;    
    // 发送String类型的数据至Tomcat
    nodeServer.write(JSON.stringify(webClientData));    
   });
   // 客户端断开连接
   socketIO.on('disconnect', function () {
    console.log('DISCONNECTED FROM CLIENT');
   });  
});
 // 从Tomcat接收数据
 nodeServer.on('data', function (data) { 
   var jsonData = JSON.parse(data.toString());  
   // 分发数据至客户端
   for (var i in jsonData.list) {
     aSocket[jsonData.list[i]['sid']].emit('pushToWebClient', jsonData.list[i].data);
  }
 });

この記事では、そのような 2 つの接続の簡単な例を示しているだけです。特定のビジネスには多くのことを追加する必要があります。 Node.js がプロジェクトに導入されたため、フロントエンドはデータ処理、キャッシュ、さらには多くのビジネス ロジックの追加など、より多くのタスクを実行する必要があります。

上記は Node.js データ Push_node.js?1.1.2 の内容です。さらに関連する内容については、PHP 中国語 Web サイト (www.php.cn) に注目してください。