webSocket如何在自己的工程中使用？

「爱情、让人受尽委屈。」 2022-05-22 09:22 314阅读 0赞

现在在写一个工程，是关于监控摄像头的，它的工作过程用下图表示：

![70][]

摄像头自动识别车牌号后，就是post到java后端(厂家叫中心服务器)，　现在是如何将识别的车牌返到前端去呢？

因为按照SSM的规则，在java后端处理完摄像头的post后，用return返回时，它是返到摄像头那边，而不是返到前端了。

为了解决这个问题，我只好在前端与java后端之间架起webSocket通信。

如何做得呢？

第一步：应该在pom中加一个

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

</dependency>

＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

第二步：在前端的html页面（或是jsp页面）这样写：

$(function()\{   
　var websocket = null;  
 //判断当前浏览器是否支持WebSocket  
 if ('WebSocket' in window) \{  
 websocket = new WebSocket("ws://localhost:9999/guanXiangCamera/websocket");  
 \}else \{  
 alert('当前浏览器 Not support websocket')  
 \}  
 //连接发生错误的回调方法  
 websocket.onerror = function () \{  
 setMessageInnerHTML("WebSocket连接发生错误");  
 \};  
 //连接成功建立的回调方法  
 websocket.onopen = function () \{  
 //setMessageInnerHTML("WebSocket连接成功");  
 \}  
 //接收到消息的回调方法  
 websocket.onmessage = function (event) \{  
 setMessageInnerHTML(event.data);  
 \}  
 //连接关闭的回调方法  
 websocket.onclose = function () \{  
 //setMessageInnerHTML("WebSocket连接关闭");  
 \}  
 //监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。  
 window.onbeforeunload = function () \{  
 //closeWebSocket();  
 \}  
 //将消息显示在网页上  
 function setMessageInnerHTML(innerHTML) \{  
 document.getElementById('message').innerHTML += innerHTML + '<br/>';  
 \}  
 //关闭WebSocket连接  
 function closeWebSocket() \{  
 websocket.close();  
 \}  
 //发送消息  
 function send() \{  
 var message = "测试一下，看能不能发！"  
 websocket.send(message);

上面的程序，其实你只想接收一个后台向前端的推送，只要这个就行，其它的都可以不要代码，只要一个函数的“架子”。

//接收到消息的回调方法  
 websocket.onmessage = function (event) \{  
 setMessageInnerHTML(event.data);

＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

第三步：在java的后端，新建一个类：

package com.google.controller;  
  
import java.io.IOException;  
import java.util.concurrent.CopyOnWriteArraySet;  
  
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 WebSocketTest \{  
//静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。  
private static int onlineCount = 0;  
//concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。  
//若要实现服务端与单一客户端通信的话，可以使用Map来存放，其中Key可以为用户标识  
private static CopyOnWriteArraySet<WebSocketTest> webSocketSet =  
new CopyOnWriteArraySet<WebSocketTest>();  
//与某个客户端的连接会话，需要通过它来给客户端发送数据  
private Session session;  
public Session getSession()\{  
return this.session;  
\}  
/\*\*  
 \* 连接建立成功调用的方法  
 \* @param session 可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据  
 \*/  
@OnOpen  
public void onOpen(Session session)\{  
this.session = session;  
webSocketSet.add(this); //加入set中  
addOnlineCount(); //在线数加1  
System.out.println("有新连接加入！当前在线人数为" + getOnlineCount());  
\}  
/\*\*  
 \* 连接关闭调用的方法  
 \*/  
@OnClose  
public void onClose()\{  
webSocketSet.remove(this); //从set中删除  
subOnlineCount(); //在线数减1  
System.out.println("有一连接关闭！当前在线人数为" + getOnlineCount());  
\}  
/\*\*  
 \* 收到客户端消息后调用的方法  
 \* @param message 客户端发送过来的消息  
 \* @param session 可选的参数  
 \*/  
@OnMessage  
public void onMessage(String message, Session session) \{  
//System.out.println("来自客户端的消息:" + message);  
//群发消息  
for(WebSocketTest item: webSocketSet)\{  
try \{  
item.sendMessage(message);  
\} catch (IOException e) \{  
e.printStackTrace();  
continue;  
\}  
\}  
\}  
/\*\*  
 \* 发生错误时调用  
 \* @param session  
 \* @param error  
 \*/  
@OnError  
public void onError(Session session, Throwable error)\{  
System.out.println("发生错误");  
error.printStackTrace();  
\}  
/\*\*  
 \* 这个方法与上面几个方法不一样。没有用注解，是根据自己需要添加的方法。  
 \* @param message  
 \* @throws IOException  
 \*/  
public void sendMessage(String message) throws IOException\{  
this.session.getBasicRemote().sendText(message);  
//this.session.getAsyncRemote().sendText(message);  
\}  
public static synchronized int getOnlineCount() \{  
return onlineCount;  
\}  
  
public static synchronized void addOnlineCount() \{  
WebSocketTest.onlineCount++;  
\}  
  
public static synchronized void subOnlineCount() \{  
WebSocketTest.onlineCount--;  
\}

＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

第四步：最重要的来了，要在自己的程序中，有推送，该如何做呢？

只需要使用它的这个类就行了：

![70 1][]

这样就可以把内容传到前台了。

要注意的事项是：　（１）前端的提交，应该提交到 WebSocketTest 类中，而不是提交到你的业务类中，

（２）后端接受前端提交的webSocket类时，用注解@ServerEndpoint接收。例如：  
@ServerEndpoint("/websocket")

public class WebSocketTest \{\}

[70]: /images/20220522/feaf2e425b3347ca86f6c9dd72fb44b4.png
[70 1]: /images/20220522/05328ebbbd42415f86d408554b0eb9b0.png