ホームページ > 記事 > Java > Java で webSocket Web チャットルームを作成する方法 (コード付き)

Java で webSocket Web チャットルームを作成する方法 (コード付き)

不言オリジナル: 2018-09-19 17:39:163801ブラウズ

この記事の内容は、Java で webSocket の Web チャットルームを作成する方法に関するものです (コード付き)。必要な友人が参考になれば幸いです。

1. webSocket とは

WebSocket は、ネットワーク通信プロトコルおよび永続化プロトコルです。 RFC6455 はその通信規格を定義しています。

WebSocket は、HTML5 が提供し始めた、単一の TCP 接続上で全二重通信を行うためのプロトコルです。

2. webSocket を使用する理由

従来の Web 通信では http テクノロジが使用され、http プロトコルはステートレス、コネクションレス、一方向のアプリケーション層プロトコルです。リクエストは 1 つのレスポンスにのみ対応します。通信リクエストはクライアントによってのみ発行され、サーバーはリクエストに応答します。したがって、サーバーは応答の送信において非常に受動的であり、サーバーのステータスが継続的に変化する場合、サーバーがクライアントに応答をタイムリーに積極的にプッシュできないという事実が生じます。それを手に入れるために。非同期 ajax を頻繁に使用してリクエストを継続的に取得してロングポーリングを実装すると、特にパフォーマンスが消費され、非効率的になります。（握手をし続けるか、長く生き続けるか）。

また、webSocket を使用すると、サーバーとクライアント間の全二重通信が可能になり、一度接続が確立される限り、接続を維持できます。接続が確立されると、双方は複数のハンドシェイクを必要とせずに相互に通信できます。

3. WEB チャットルームの実装

pom.xml を追加し、jar パッケージを導入します

<dependency>
      <groupId>javax</groupId>
         <artifactId>javaee-api</artifactId>
         <version>7.0</version>
         <scope>provided</scope>
 </dependency>

2. html とjs ファイル

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>在线聊天室</title>
<script type="text/javascript" src="./static/jquery-3.2.0.min.js"></script>
<!-- 最新版本的 Bootstrap 核心 CSS 文件 -->
<link rel="stylesheet" href="https://cdn.bootcss.com/bootstrap/3.3.7/css/bootstrap.min.css" integrity="sha384-BVYiiSIFeK1dGmJRAkycuHAHRg32OmUcww7on3RYdg4Va+PmSTsz/K68vbdEjh4u" crossorigin="anonymous">
<!-- 最新的 Bootstrap 核心 JavaScript 文件 -->
<script src="https://cdn.bootcss.com/bootstrap/3.3.7/js/bootstrap.min.js" integrity="sha384-Tc5IQib027qvyjSMfHjOMaLkfuWVxZxUPnCJA7l2mCWNIpG9mGCD8wGNIcPD7Txa" crossorigin="anonymous"></script>
</head>
<body>
  <div>
    <div><span>聊天室</span>
         <button class="btn btn-warning" onclick="doClose();">退出聊天</button>
    </div>
    <div><textarea class="form-control" style="width: 40%;" rows="3" id="contentInp"></textarea></div><hr/>
    <div><button class="btn btn-danger" onclick="doClear();">清空会话框</button></div>
    <div id="content">开始聊天<br/></div>
  </div>
</body>
<script type="text/javascript">
   var ws = new WebSocket("ws://localhost:8080/ws/websocket"); //controller层url
   $(function(){
       $("#contentInp").keyup(function(evt){
           if(evt.which == 13){ //enter键发送消息
               var htm = $("#contentInp").val();
               doSend(htm);
               $("textarea").empty();
           }
       });
   })
   
   ws.onopen = function(){
       appendHtm("连接成功！");
   }
   
   // 从服务端接收到消息，将消息回显到聊天记录区
   ws.onmessage = function(evt){
       appendHtm(evt.data);
   }
   
   ws.onerror = function(){
       appendHtm("连接失败！");
   }
   
   ws.onclose = function(){
       appendHtm("连接关闭！");
   }
   
   function appendHtm(htm){
       ($("#content")[0]).innerHTML += htm +"<br/>" 
   }
   
   // 注销登录
   function doClose(){
       ws.close();
   }
   
   // 发送消息
   function doSend(htm){
      // ($("#content")[0]).innerHTML += htm +"<br/>" 
       ws.send(htm);
   }
   
   function doClear(){
       $("#content").empty();
   }
</script>
</html>

3.バックエンドJavaコード

package controller;

import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;

import javax.net.ssl.SSLSession;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint("/websocket")
public class WebScoketServer {

    private static Integer onlineNum = 0; //当前在线人数，线程必须设计成安全的
    private static CopyOnWriteArraySet<WebScoketServer> arraySet = new CopyOnWriteArraySet<WebScoketServer>(); //存放每一个客户的的WebScoketServer对象，线程安全
    private Session session;
    
    /**
     * 连接成功
     * @param session 会话信息
     */
    @OnOpen
    public void onOpen(Session session) {
        this.session =session;
        arraySet.add(this);
        this.addOnlineNum();
        System.out.println("有一个新连接加入，当前在线 "+this.getOnLineNum()+" 人");
    }
    
    /**
     * 连接关闭
     */
    @OnClose
    public void onClose() {
        arraySet.remove(this);
        this.subOnlineNum();
        System.out.println("有一个连接断开，当前在线 "+this.getOnLineNum()+" 人");
    }
    
    /**
     * 连接错误
     * @param session
     * @param error
     */
    @OnError
    public void onError(Session session, Throwable error) {
        System.err.println("发生错误！");
        error.printStackTrace();
    }
    
    /**
     * 发送消息,不加注解，自己选择实现
     * @param msg
     * @throws IOException
     */
    public void onSend(String msg) throws IOException {
        this.session.getBasicRemote().sendText(msg);
    }
    
    /**
     * 收到客户端消息回调方法
     * @param session
     * @param msg
     */
    @OnMessage
    public void onMessage(Session session, String msg) {
        System.out.println("消息监控："+msg);
        for (WebScoketServer webScoketServer : arraySet) {
            try {
                webScoketServer.onSend(msg);
            } catch (IOException e) {
                e.printStackTrace();
                continue;
            }
        }
    }
    /**
     * 增加一个在线人数
     */
    private synchronized void addOnlineNum() {
        onlineNum++;
    }
    
    /**
     * 减少一个在线人数
     */
    private synchronized void subOnlineNum() {
        onlineNum--;
    }
    
    private Integer getOnLineNum() {
        return onlineNum;
    }
}

以上がJava で webSocket Web チャットルームを作成する方法 (コード付き)の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

Java html5 ajax html xml JS 异步 http websocket

声明：

この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

前の記事：Javaプログラムを使用してDocker Imageを作成する方法とプロセス次の記事：Javaプログラムを使用してDocker Imageを作成する方法とプロセス

続きを見る

Java で webSocket Web チャット ルームを作成する方法 (コード付き)

1. webSocket とは

2. webSocket を使用する理由

3. WEB チャット ルームの実装

関連記事

Java で webSocket Web チャットルームを作成する方法 (コード付き)

3. WEB チャットルームの実装