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

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

php是最好的语言オリジナル: 2018-08-03 11:35:183027ブラウズ

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

2. 実装原理

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

3. 利点

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

4. WebSocketとSocketの違い

1.WebSocket:

通信を確立するとき、クライアントは積極的に接続リクエストを開始し、サーバーは受動的にリッスンします。
通信接続が確立されると、通信は「全二重」モードになります。言い換えれば、サーバーとクライアントの両方がいつでも自由にデータを送信できるため、サーバーがリアルタイムデータを積極的にプッシュする必要があるビジネスシナリオに非常に適しています。
対話モードは「リクエスト/レスポンス」モードではなくなり、通信プロトコルは開発者によって完全に設計されています。
通信データはテキストデータやバイナリデータを直接高効率に伝送できる「フレーム」をベースとしています。もちろん、開発者はパッケージ化、開梱、番号付けなどの技術的な詳細も考慮する必要があります。
2.ソケット:

すべての対話は次のとおりです: クライアントが積極的にリクエストを開始し (リクエスト)、サーバーが受動的に応答します (レスポンス)。
サーバーはクライアントにデータをアクティブにプッシュできません。
通信されるデータはテキスト形式に基づいています。バイナリデータ (画像など) は、送信する前に、base64 などの手段を使用してテキストに変換する必要があります。
5.WebSocketクライアント:

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.コアクラス:

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 = new ConcurrentHashMap<String, WebSocket>();

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() {

return clients;

}

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

WebSocket ws = new WebSocket();

JSONObject jo = new JSONObject();

jo.put("message", "这是后台返回的消息！");

jo.put("To",invIO.getIoEmployeeUid());

ws.onMessage(jo.toString());

7. 必要な Maven 依存関係:

<dependency>

<groupId>javax.websocket</groupId>

<artifactId>javax.websocket-api</artifactId>

<version>1.1</version>

<scope>provided</scope>

</dependency>

<dependency>

<groupId>javax</groupId>

<artifactId>javaee-api</artifactId>

<version>7.0</version>

<scope>provided</scope>

</dependency>

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

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

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

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

4. WebSocketとSocketの違い

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

7. 必要な Maven 依存関係:

関連記事

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

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