Java バックグラウンド メッセージ プッシュを実装するための WebSocket の原則と基本知識

1. WebSocket とは何ですか? WebSocket プロトコルは、TCP に基づいた新しいネットワーク プロトコルです。ブラウザとサーバー間の全二重通信を実装し、サーバーがクライアントに情報を積極的に送信できるようにします。

2. 実装原理

WebSocket 接続の実装プロセスでは、WebSocket 接続リクエストをブラウザ経由で送信する必要があり、その後サーバーが応答を送信します。このプロセスは通常「ハンドシェイク」と呼ばれます。 WebSocket API では、ブラウザとサーバーはハンドシェイク アクションを実行するだけで、ブラウザとサーバーの間に高速チャネルが形成されます。データは両者間で直接送信できます。

3. 利点

以前のメッセージ プッシュ メカニズムでは、ブラウザーが特定の時間間隔でリクエストを自動的に発行し、サーバーのメッセージをアクティブにプルバックしていました。この種のメソッドは大量のリソースを消費します。これは本質的に http リクエストであり、非常に扱いにくいものです。 WebSocket は、ブラウザとサーバー間のハンドシェイクを完了します。接続が確立されると、サーバーはクライアントにデータをアクティブに送信でき、クライアントはいつでもサーバーにデータを送信できます。

4. WebSocketとSocketの違い

1.WebSocket:

WebSocket通信の確立フェーズはhttpプロトコルに依存します。最初のハンドシェイク フェーズは http プロトコルです。ハンドシェイクが完了すると、WebSocket プロトコルに切り替わり、http プロトコルから完全に分離されます。

1. 通信を確立するとき、クライアントは積極的に接続リクエストを開始し、サーバーは受動的にリッスンします。

2. 通信接続が確立されると、通信は「全二重」モードになります。言い換えれば、サーバーとクライアントの両方がいつでも自由にデータを送信できるため、サーバーがリアルタイム データを積極的にプッシュする必要があるビジネス シナリオに非常に適しています。

3. 
   対話モードは「リクエスト/レスポンス」モードではなくなり、通信プロトコルは開発者によって完全に設計されています。

4. 
   通信データはテキストデータやバイナリデータを直接高効率に伝送できる「フレーム」をベースとしています。もちろん、開発者はパッケージ化、開梱、番号付けなどの技術的な詳細も考慮する必要があります。

5. 2.ソケット:

サーバーは通信を監視し、受動的にサービスを提供します。クライアントは、通信を確立するためにサーバーへの接続要求を積極的に開始します。

6. すべての対話は次のとおりです: クライアントが積極的にリクエストを開始し (リクエスト)、サーバーが受動的に応答します (レスポンス)。

7. サーバーはクライアントにデータをアクティブにプッシュできません。

8. 
   通信されるデータはテキスト形式に基づいています。バイナリ データ (画像など) は、送信する前に、base64 などの手段を使用してテキストに変換する必要があります。

9. 
   

10. 5.WebSocketクライアント:

12

3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51

var websocket = null; var host = document.location.host;  var username = "${loginUsername}"; // 获得当前登录人员的userName   // alert(username) //判断当前浏览器是否支持WebSocket  if ('WebSocket' in window) {      alert("浏览器支持Websocket")     websocket = new WebSocket('ws://'+host+'/mm-dorado/webSocket/'+username);  } else {      alert('当前浏览器 Not support websocket')  //连接发生错误的回调方法  websocket.onerror = function() {  　　alert("WebSocket连接发生错误")    setMessageInnerHTML("WebSocket连接发生错误");  };      //连接成功建立的回调方法  websocket.onopen = function() { 　　alert("WebSocket连接成功")     setMessageInnerHTML("WebSocket连接成功");  }     //接收到消息的回调方法  websocket.onmessage = function(event) {     alert("接收到消息的回调方法")      alert("这是后台推送的消息："+event.data); 　　　　 websocket.close(); 　　　　alert("webSocket已关闭！") }     //连接关闭的回调方法  websocket.onclose = function() {      setMessageInnerHTML("WebSocket连接关闭");  }     //监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。  window.onbeforeunload = function() {      closeWebSocket();  }     //关闭WebSocket连接  function closeWebSocket() {      websocket.close();  }  //将消息显示在网页上     function setMessageInnerHTML(innerHTML) {         document.getElementById('message').innerHTML += innerHTML + '<br>';     }

6.WebSocketサーバー(Javaバックグラウンド):

1.コアクラス:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93

package com.mes.util; import java.io.IOException; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import javax.websocket.OnClose; import javax.websocket.OnError; import javax.websocket.OnMessage; import javax.websocket.OnOpen; import javax.websocket.Session; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; import org.springframework.stereotype.Component; import org.springframework.stereotype.Service; import com.google.gson.JsonObject; import net.sf.json.JSONObject; @ServerEndpoint("/webSocket/{username}")       public class WebSocket {          private static int onlineCount = 0;          private static Map<string websocket> clients = </string>new ConcurrentHashMap<string websocket>(); </string>         private Session session;          private String username;                     @OnOpen         public void onOpen(@PathParam("username") String username, Session session) throws IOException {                     this.username = username;              this.session = session;                             addOnlineCount();              clients.put(username, this);             System.out.println("已连接");         }                 @OnClose         public void onClose() throws IOException {              clients.remove(username);              subOnlineCount();          }                 @OnMessage         public void onMessage(String message) throws IOException {                     JSONObject jsonTo = JSONObject.fromObject(message);              String mes = (String) jsonTo.get("message");                          if (!jsonTo.get("To").equals("All")){ if (!jsonTo.get("To").equals("All" )){                 sendMessageTo(mes, jsonTo.get("To").toString());              }else{ }else{                 sendMessageAll("给所有人");              } }         }                 @OnError         public void onError(Session session, Throwable error) {              error.printStackTrace(); error.printStackTrace();          }                 public void sendMessageTo(String message, String To) throws IOException {              // session.getBasicRemote().sendText(message); // session.getBasicRemote().sendText(message);              //session.getAsyncRemote().sendText(message); //session.getAsyncRemote().sendText(message);              for (WebSocket item : clients.values()) { for (WebSocket item : client.values()) {                 if (item.username.equals(To) )                      item.session.getAsyncRemote().sendText(message);              }          }                     public void sendMessageAll(String message) throws IOException {              for (WebSocket item : clients.values()) {                  item.session.getAsyncRemote().sendText(message);              }          }                 public static synchronized int getOnlineCount() {              return onlineCount;          }                 public static synchronized void addOnlineCount() {              WebSocket.onlineCount++;          }                 public static synchronized void subOnlineCount() {              WebSocket.onlineCount--;          }                 public static synchronized Map<string websocket> getClients() { </string>             return clients;          }  }

2. 独自のコードを呼び出します:

1 2 3 4 5

WebSocket ws = new WebSocket(); JSONObject jo = new JSONObject(); jo.put("message", "这是后台返回的消息！"); jo.put("To",invIO.getIoEmployeeUid()); ws.onMessage(jo.toString());

7. 必要な Maven 依存関係:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

<!-- webSocket 开始--> <dependency></dependency>     <groupid>javax.websocket</groupid>     <artifactid>javax.websocket-api</artifactid>     <version></version>1.1     <scope>provided</scope> <dependency></dependency>     <groupid>javax</groupid>     <artifactid>javaee-api</artifactid>     <version></version>7.0     <scope>provided</scope> <!-- webSocket 结束-->

関連記事:

Java での WebSocket メッセージ プッシュ

WebSocket に基づく WEB メッセージ プッシュ フレームワーク

関連ビデオ:

WebSocket ビデオ チュートリアル

以上がJava バックグラウンド メッセージ プッシュを実装するための WebSocket の原則と基本知識の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。