JavaEE7 HTML5利用WebSocket实现即时通讯

Posted 2021-04-04 java1234

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了JavaEE7 HTML5利用WebSocket实现即时通讯相关的知识，希望对你有一定的参考价值。

转载自：

https://www.cnblogs.com/lingbing/p/6089331.html

HTML5给Web浏览器带来了全双工TCP连接websocket标准服务器的能力。

换句话说，浏览器能够与服务器建立连接，通过已建立的通信信道来发送和接收数据而不需要由HTTP协议引入额外其他的开销来实现。

在本教程中我们将在Java EE环境下实现一个简单的websockect服务器端来和客户端进行数据交互。

本教程需要以下环境：

JDK 1.7.0.21
tomcat 7

注: Java EE 7中才引入了WebSocket。

WebSocket服务器端

WebSocketServer 代码：

package com.bing.biz.websocket;
import java.io.IOException;
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;
 //该注解用来指定一个URI，客户端可以通过这个URI来连接到WebSocket。类似Servlet的注解mapping。无需在web.xml中配置。@ServerEndpoint("/webSocketServer/{userId}")public class WebSocketServer {  /** * 连接建立成功调用的方法 * @param session 可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据 * @throws IOException  */ @OnOpen public void onOpen(@PathParam("userId") String userId,Session session) throws IOException{ /* if(userId!=null){  if(!SocketUtils.hasConnection(userId)){ SocketUtils.put(userId,session); } else{ //相同用户只允许在一个地方登录（网页版内部判断）。 SocketUtils.sendMessage(userId,"forcelogout","该用户已在其他地方登录，此次登录将被强制退出。",0,"");  SocketUtils.remove(userId,session.getId()); SocketUtils.put(userId,session); } }*/ System.out.println("Client connected "+userId); }  /** * 连接关闭调用的方法 */ @OnClose public void onClose(@PathParam("userId") String userId,Session session)throws IOException{ //SocketUtils.remove(userId,session.getId()); System.out.println("Connection closed"); }  /** * 收到客户端消息后调用的方法 * @param message 客户端发送过来的消息 * @param session 可选的参数 * @throws IOException  */ @OnMessage public void onMessage(@PathParam("userId") String userId,String message, Session session) throws IOException { // Print the client message for testing purposes System.out.println("Received: " + message);  // Send the first message to the client session.getBasicRemote().sendText("This is the first server message");  // Send 3 messages to the client every 5 seconds int sentMessages = 0; while(sentMessages < 3){ session.getBasicRemote(). sendText("This is an intermediate server message. Count: " + sentMessages); sentMessages++; }  // Send a final message to the client session.getBasicRemote().sendText("This is the last server message"); }  /** * 发生错误时调用 * @param session * @param error */ @OnError public void onError(Session session, Throwable error){ error.printStackTrace(); }}

你可能已经注意到我们从 javax.websocket包中引入了一些类。

onOpen 和 onClose 方法分别被@OnOpen和@OnClose 所注解。这两个注解的作用不言自明：他们定义了当一个新用户连接和断开的时候所调用的方法。

onMessage 方法被@OnMessage所注解。这个注解定义了当服务器接收到客户端发送的消息时所调用的方法。注意：这个方法可能包含一个javax.websocket.Session可选参数（在我们的例子里就是session参数）。如果有这个参数，容器将会把当前发送消息客户端的连接Session注入进去。

本例中我们仅仅是将客户端消息内容打印出来，然后首先我们将发送一条开始消息，之后间隔5秒向客户端发送1条测试消息，共发送3次，最后向客户端发送最后一条结束消息。

WebSocket客户端

index.jsp代码：

<%@ page language="java" import="java.util.*" pageEncoding="utf-8"%><%String path = request.getContextPath();String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";%>
<!DOCTYPE html><html><head><title>Testing websockets</title></head><body> <div> <input type="submit" value="Start" onclick="start()" /> </div> <div id="messages"></div> <script type="text/javascript"> //建立websocket连接 var websocket = new WebSocket('ws://localhost:8080/bing/webSocketServer/bing');  websocket.onopen = function (evnt) { document.getElementById('messages').innerHTML = 'Connection established'; }; websocket.onmessage = function (evnt) { document.getElementById('messages').innerHTML += '<br />' + event.data; }; websocket.onerror = function (evnt) { }; websocket.onclose = function (evnt) { };  function start() { websocket.send('hello'); return false; }</script></body></html>