WebSocket-java实现
生活随笔
收集整理的這篇文章主要介紹了
WebSocket-java实现
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
一、所需jar
二、創建websocket.jsp（注意此頁面鏈接，需要鏈接到自己的服務）
1 <%@ page language="java" import="java.util.*" pageEncoding="ISO-8859-1"%> 2 <% 3 String path = request.getContextPath(); 4 String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/"; 5 %> 6 7 <html><head><title>Web Socket Client</title></head> 8 <body> 9 <script type="text/javascript"> 10 var socket; 11 if (!window.WebSocket) { 12 window.WebSocket = window.MozWebSocket; 13 } 14 // Javascript Websocket Client 15 if (window.WebSocket) { 16 socket = new WebSocket("ws://192.168.1.168:8080/websocketDemo/ws?123123"); 17 socket.onmessage = function(event) { 18 var ta = document.getElementById('responseText'); 19 ta.value = ta.value + '\n' + event.data 20 }; 21 socket.onopen = function(event) { 22 var ta = document.getElementById('responseText'); 23 ta.value = "Web Socket opened!"; 24 }; 25 socket.onclose = function(event) { 26 var ta = document.getElementById('responseText'); 27 ta.value = ta.value + "Web Socket closed"; 28 }; 29 socket.onerror = function(event) { 30 onError(event); 31 }; 32 } else { 33 alert("Your browser does not support Web Socket."); 34 } 35 // Send Websocket data 36 function send(message) { 37 if (!window.WebSocket) { return; } 38 if (socket.readyState == WebSocket.OPEN) { 39 socket.send(message); 40 } else { 41 alert("The socket is not open."); 42 } 43 } 44 </script> 45 <h3>Send :</h3> 46 <form onsubmit="return false;"> 47 <input type="text" name="message" value="Hello World!"/><input type="button" value="Send Web Socket Data" onclick="send(this.form.message.value)" /> 48 <h3>Receive :</h3> 49 <textarea id="responseText" style="width:500px;height:300px;"></textarea> 50 </form> 51 </body> 52 </html> View Code三、創建服務類WebSocketServer.java
1 package com.sh.test; 2 3 import java.util.ArrayList; 4 import java.util.List; 5 6 import javax.servlet.jsp.tagext.TryCatchFinally; 7 import javax.websocket.OnClose; 8 import javax.websocket.OnError; 9 import javax.websocket.OnMessage; 10 import javax.websocket.OnOpen; 11 import javax.websocket.Session; 12 import javax.websocket.server.ServerEndpoint; 13 14 import org.springframework.asm.commons.TryCatchBlockSorter; 15 16 /** 17 * WebSocket服務 18 * 19 */ 20 @ServerEndpoint("/ws") 21 public class WebSocketServer{ 22 23 private static List<WebSocketServer> wslist = new ArrayList<WebSocketServer>(); 24 25 private Session session; 26 27 public WebSocketServer() { 28 } 29 /** 30 * 連接后執行 31 * @param session 32 */ 33 @OnOpen 34 public void onOpen(Session session) { 35 System.out.println("連接開啟"); 36 String str = session.getQueryString();//獲取開啟后的參數 鏈接?后面的字符串 37 wslist.add(this); 38 39 this.session = session; 40 } 41 42 /** 43 * 接到消息執行 44 * @param session 45 * @param msg 46 */ 47 @OnMessage 48 public void message(Session session, String msg) { 49 for(WebSocketServer wss : this.wslist) {//可循環對所有人廣播，也可單獨對一人廣播 50 if(wss.session != null && wss.session.isOpen()) { 51 wss.session.getAsyncRemote().sendText(wss.session.getId()+" send msg "+msg); 52 } 53 } 54 } 55 56 57 58 /** 59 * 關閉后執行執行 60 * @param session 61 */ 62 @OnClose 63 public void onClose(Session session) { 64 System.out.println("連接關閉"); 65 if(wslist.contains(this)) { 66 wslist.remove(this); 67 } 68 } 69 /** 70 * 關閉瀏覽器后執行 71 * @param t 72 */ 73 @OnError 74 public void onError(Throwable t) { 75 if(wslist.contains(this)) { 76 wslist.remove(this); 77 } 78 } 79 80 81 } View Code四、創建測試方法TestController.java
1 package com.sh.test; 2 3 import javax.servlet.http.HttpServletRequest; 4 import javax.servlet.http.HttpServletResponse; 5 6 import org.springframework.stereotype.Controller; 7 import org.springframework.web.bind.annotation.RequestMapping; 8 import org.springframework.web.bind.annotation.RequestMethod; 9 10 @Controller 11 public class TestController { 12 private void TestController() {} 13 @RequestMapping(value = "/ws", method = RequestMethod.GET) 14 public String ws(HttpServletRequest request, HttpServletResponse response) { 15 return "/websocket"; 16 } 17 18 } View Code五、使用TomCat7運行項目，即可通訊
http://192.168.1.168:8080/wstest/ws
?
轉載于:https://www.cnblogs.com/buggou/p/8251216.html
總結
以上是生活随笔為你收集整理的WebSocket-java实现的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 两个指针相减
- 下一篇： Oracle Spatial分区应用研究