検索

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

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

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

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

2. 実装原理

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

3. 利点

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

4. WebSocketとSocketの違い

1.WebSocket:

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

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

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


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


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

    5. 2.ソケット:

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

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

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


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


    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 = 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. 独自のコードを呼び出します:

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>

    <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>

<!-- webSocket 结束-->
関連記事:

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

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

関連ビデオ:

WebSocket ビデオ チュートリアル

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

Java json ajax maven Static String NULL if for Session Error int void class public private Event var map function 事件 this location innerHTML alert http websocket
声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
前の記事：Java：オブジェクトロック「同期」とグローバルロックの詳細説明次の記事：Java：オブジェクトロック「同期」とグローバルロックの詳細説明

関連記事

続きを見る