2. 程式人生 > >基於html5websocket java實現簡單通訊(雖然通了但是...你懂得)

基於html5websocket java實現簡單通訊(雖然通了但是...你懂得)

阿新 • • 發佈：2019-01-23

很早就想寫一下基於Html5 websocket通訊的但是一直沒有下手,今天心血來潮試了一下,原來以為是html5 socket的所以直接用以前自己弄得socket java服務來當服務端,百度了別人的html前臺的,結果不行...只好認慫,把別人的服務端程式碼也拷下來試下,結果一看原來是websocket...跟socket兩種性質。

然後試了下，通是通了，但是他的只能群發,我想要單播的,想了一下，想出了一個很笨很笨的方法,在連線的時候把使用者的Id作為唯一標識傳給服務端,服務端儲存,然後根據使用者要傳送的物件的id進行比對,相同就傳送.恩...效果是實現了.

恩，挺開心...突然瞥到關閉那邊,只是把連線移除,沒有把使用者移除,加上...測通

以下程式碼參考 http://blog.csdn.net/huangwuyi/article/details/12912283 要加兩個包catalina.jar、tomcat-coyote.jar 

如果報錯Java.lang.NoSuchMethodException: org.apache.catalina.deploy.WebXml addFilter 在Tomacat7的context.xml檔案裡的<Context>中加上<Loader delegate="true" />

前臺頁面:

<html> 
    <head> 
        <title>WebSoket Demo</title> 
        <script type="text/JavaScript"> 
            //驗證瀏覽器是否支援WebSocket協議
            if (!window.WebSocket) { 
                alert("WebSocket not supported by this browser!"); 
            } 
             var ws;
            function display() { 
                //var valueLabel = document.getElementById("valueLabel"); 
                //valueLabel.innerHTML = ""; 
                ws=new WebSocket("ws://localhost:8080/Socket/websocket"); 
                //監聽訊息
                ws.onmessage = function(event) { 
                    //valueLabel.innerHTML+ = event.data; 
                    log(event.data);
                }; 
                // 開啟WebSocket 
                ws.onclose = function(event) { 
                  //WebSocket Status:: Socket Closed
                }; 
                // 開啟WebSocket
                ws.onopen = function(event) { 
                   //WebSocket Status:: Socket Open
                    //// 傳送一個初始化訊息
                    ws.send("Hello, Server!"+"%%%4"); //連線websocket 傳遞userId
                }; 
                ws.onerror =function(event){
                    //WebSocket Status:: Error was reported
                };
            } 
            var log = function(s) {  
   if (document.readyState !== "complete") {  
       log.buffer.push(s);  
   } else {  
       document.getElementById("contentId").innerHTML += (s + "\n");  
   }  
}  
            function sendMsg(){
                var msg=document.getElementById("messageId");
                //alert(msg.value);
                ws.send(msg.value); 
            }
        </script> 
    </head> 
    <body onload="display();"> 
        <div id="valueLabel"></div> 
        <textarea rows="20" cols="30" id="contentId"></textarea>
        <br/>
        <input name="message" id="messageId"/>
        <button id="sendButton" onClick="javascript:sendMsg()" >Send</button>
    </body> 
</html>

傳送資訊的時候帶上id根據特定的格式拼湊,服務端拆分.

服務端:

web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="3.0" xmlns="http://java.sun.com/xml/ns/javaee"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
	http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd">
	<display-name></display-name>
	<servlet>
		<servlet-name>initServlet</servlet-name>
		<servlet-class>com.InitServlet</servlet-class>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>websocket</servlet-name>
		<servlet-class>com.TestWebSocketServlet</servlet-class>
	</servlet>
	<servlet-mapping>
		<servlet-name>websocket</servlet-name>
		<url-pattern>/websocket</url-pattern>
	</servlet-mapping>
</web-app>

InitServlet
package com;

import java.util.ArrayList;
import java.util.List;

import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;

import org.apache.catalina.websocket.MessageInbound;

public class InitServlet extends HttpServlet {

	private static final long serialVersionUID = 1L;
	private static List<MessageInbound> socketList;

	public void init(ServletConfig config) throws ServletException {
		InitServlet.socketList = new ArrayList<MessageInbound>();
		super.init(config);
		System.out.println("Server start============");
	}

	public static List<MessageInbound> getSocketList() {
		return InitServlet.socketList;
	}

}

TestWebSocketServlet
package com;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.util.ArrayList;
import java.util.List;

import javax.servlet.http.HttpServletRequest;

import org.apache.catalina.websocket.MessageInbound;
import org.apache.catalina.websocket.StreamInbound;
import org.apache.catalina.websocket.WebSocketServlet;
import org.apache.catalina.websocket.WsOutbound;

public class TestWebSocketServlet extends WebSocketServlet {

	/**
* 
*/
	private static final long serialVersionUID = 1L;
	// 儲存連結的容器
	private static List<WebSocketMessageInbound> connsList = new ArrayList<WebSocketMessageInbound>();

	// 儲存使用者資訊
	private static List<String> userIds = new ArrayList<String>();

	@Override
	protected StreamInbound createWebSocketInbound(String subProtocol, HttpServletRequest request) {
		// TODO Auto-generated method stub
		return new WebSocketMessageInbound();
	}

	public class WebSocketMessageInbound extends MessageInbound {

		@Override
		protected void onClose(int status) {
			// InitServlet.getSocketList().remove(this);
			super.onClose(status);
			System.out.println("onClose");
			int i=0;
			//比對連線,刪除使用者唯一標識
			for(MessageInbound messageInbound : InitServlet.getSocketList()){
				if(this.equals(messageInbound)){
					userIds.remove(i);
					break;
				}
				i++;
				
			}
			InitServlet.getSocketList().remove(this);
		}

		@Override
		protected void onOpen(WsOutbound outbound) {
			System.out.println("onOpen");
			super.onOpen(outbound);
			InitServlet.getSocketList().add(this);
		}

		@Override
		protected void onBinaryMessage(ByteBuffer message) throws IOException {
			// TODO Auto-generated method stub
			System.out.println("onBinaryMessage");
		}

		@Override
		protected void onTextMessage(CharBuffer message) throws IOException {
			// TODO Auto-generated method stub
			System.out.println("onTextMessage=" + message);
			//獲取使用者id
			if (message.toString().indexOf("Hello, Server") > -1) {
				String idString = message.toString().split("%%%")[1];
				userIds.add(idString);
			}
			// this.getWsOutbound().writeTextMessage(CharBuffer.wrap("===="));
			// this.getWsOutbound().writeTextMessage(message);
			// 傳送給所有連結的
			// for (MessageInbound messageInbound : InitServlet.getSocketList())
			// {
			// CharBuffer buffer = CharBuffer.wrap(message);
			// WsOutbound outbound = messageInbound.getWsOutbound();
			// outbound.writeTextMessage(buffer);
			// outbound.flush();
			// }
			int i = 0;
			if (message.toString().indexOf("Hello, Server") <0)
				for (String item : userIds) {
					//根據使用者傳來id比對,確定傳送目標
					String str = message.toString().split("id")[1];
					if (item.equals(str)) {
						CharBuffer buffer = CharBuffer.wrap(message);
						WsOutbound outbound = InitServlet.getSocketList().get(i).getWsOutbound();
						outbound.writeTextMessage(buffer);
						outbound.flush();
					}
					i++;
				}
		}
	}
}

改一下儲存資料的結構,用list太麻煩,還是用map直接根據使用者id作為key,連結作為value,傳送的時候直接根據key獲取

Test

package com;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import javax.servlet.http.HttpServletRequest;

import org.apache.catalina.websocket.MessageInbound;
import org.apache.catalina.websocket.StreamInbound;
import org.apache.catalina.websocket.WebSocketServlet;
import org.apache.catalina.websocket.WsOutbound;

public class Test extends WebSocketServlet {

	/**
* 
*/
	private static final long serialVersionUID = 1L;

	
	//儲存使用者和連結
	private static Map<String, MessageInbound> maps = new ConcurrentHashMap<String, MessageInbound>();

	@Override
	protected StreamInbound createWebSocketInbound(String subProtocol, HttpServletRequest request) {
		// TODO Auto-generated method stub
		return new WebSocketMessageInbound();
	}

	public class WebSocketMessageInbound extends MessageInbound {

		@Override
		protected void onClose(int status) {
			// InitServlet.getSocketList().remove(this);
			super.onClose(status);
			System.out.println("onClose");
		}

		@Override
		protected void onOpen(WsOutbound outbound) {
			System.out.println("onOpen");
			super.onOpen(outbound);
			InitServlet.getSocketList().add(this);
		}

		@Override
		protected void onBinaryMessage(ByteBuffer message) throws IOException {
			// TODO Auto-generated method stub
			System.out.println("onBinaryMessage");
		}

		@Override
		protected void onTextMessage(CharBuffer message) throws IOException {
			// TODO Auto-generated method stub
			System.out.println("onTextMessage=" + message);
			// 獲取使用者id
			if (message.toString().indexOf("Hello, Server") > -1) {
				String idString = message.toString().split("%%%")[1];
				maps.put(idString, InitServlet.getSocketList().get(0));
				InitServlet.getSocketList().remove(0);
			}
			if (message.toString().indexOf("Hello, Server") < 0) {
				//根據使用者id作為key獲取連結
				String str = message.toString().split("id")[1];
				CharBuffer buffer = CharBuffer.wrap(message);
				if (maps.get(str) != null) {
					WsOutbound outbound = maps.get(str).getWsOutbound();
					outbound.writeTextMessage(buffer);
					outbound.flush();
				}
			}
		}
	}
}




相關推薦

基於html5websocket java實現簡單通訊(雖然通了但是...你懂得)

很早就想寫一下基於Html5 websocket通訊的但是一直沒有下手,今天心血來潮試了一下,原來以為是html5 socket的所以直接用以前自己弄得socket java服務來當服務端,百度了別人的html前臺的,結果不行...只好認慫,把別人的服務端程式碼也拷下來試下

Java 基於TCP/IP 實現簡單的 socket 通訊

Server.java package com.learn; import java.io.BufferedReader; import java.io.IOException; import

PKI學習之路（一）------------------------java實現簡單的socket通訊

專案地址：https://github.com/gongxianshengjiadexiaohuihui/PKI 關於什麼是socket通訊，我會寫一篇部落格去敘述 這次我們主要實現client和server通過socket進行通訊 server程式碼 package com.ggp

基於Java實現簡單Http伺服器之一

        本文將詳細介紹如何基於java語言實現一個簡單的Http伺服器，文中將主要介紹三個方面的內容：1）Http協議的基本知識、2）java.net.Socket類、3）java.net.ServerSocket類，讀完本文後你可以把這個伺服器用多執行緒的技術重新編

Java實現簡單的本機TCP協議雙向通訊

在完成了傳送端與接收端的連線以後，可以進行雙方的雙向通訊，這裡的例子是SeverDemo在收到訊息後回覆一條訊息給ClientDemo。程式碼：ClientDemo.javaimport java.io.IOException; import java.io.InputStr

Java實現簡單的Socket伺服器與客戶端字串通訊（適合初學者閱讀）

       近段時間，頻繁看到很多學生做畢業設計用到了Socket通訊技術，問題非常多，特寫一個小例子，希望對馬上畢業的同學有所幫助。如果希望學習的更加深入，需要掌握的知識有：面向物件、多執行緒、Socket通訊、IO流、異常處理 伺服器端程式碼： import java

java實現簡單的四則運算

四則運算 計算器本文出自 “十裏稻花香” 博客，請務必保留此出處http://5880861.blog.51cto.com/5870861/1943836java實現簡單的四則運算

java實現簡單二維迷宮（2）

blog 成員 new 構建 push port ava amp use 這次是改良版本。 將地圖封裝，老鼠封裝。是對Java基礎的一個練習吧。 這次實現也遇到了一些問題。主要是棧。封裝的mouse類中有成員變量i,j代表了老鼠的坐標。將mouse類對象m入棧的時候，總是入

Java實現簡單文件過濾器

想要 空格 遞歸 port 文件過濾 list rgs lis http 輸入路徑查找該路徑下的指定文件類型的文件 代碼思路： 想要循環遍歷文件夾下所有子文件夾，就要用到遞歸。 首先判斷路徑是否存在： 　　是：獲取文件 　　　　判斷是否文件夾： 　　　　　　是：調用自身

java實現簡單的單點登錄 （轉）

hresult 調查公司 exe ftp 說我 負數 是我 create 統一 摘要：單點登錄（SSO）的技術被越來越廣泛地運用到各個領域的軟件系統當中。本文從業務的角度分析了單點登錄的需求和應用領域；從技術本身的角度分析了單點登錄技術的內部機制和實現手段，並且給出Web-

java 實現簡單的短信發送

下載 har ase 設置 request enc value pri ring 現在中國網建上註冊一個自己的賬戶， 然後裏面有代碼案例，也有相應的下載jar包的地址 代碼如下： public class Message { public static void main

消息隊列 (2) java實現簡單的RabbtMQ

java實現 java cal png bit close 項目 rri XML 假設有如下問題： 　　1.如果消費者連接中斷，這期間我們應該怎麽辦？ 　　2.如何做到負載均衡？ 　　3.如何有效的將數據發送到相關的接收者？就是怎麽樣過濾 　　4.如何保證消費者收到完整正確

java 實現udp通訊

ket 地址 upd void ESS util dst 服務端 unknown 需求：應用A（通常有多個）和應用B（1個）進行 socket通訊，應用A必須知道應用B的ip地址（在應用A的配置文件中寫死的），這個時候就必須把應用B的ip設成固定ip（但是某些時候如更換路由

JAVA實現簡單控制檯五子棋遊戲

GobangMain這個類是遊戲的主方法，主要用於控制遊戲的執行，值得注意的是輸入的座標的格式是3,4的樣式，不能是其他的格式，也不能出現空格。 package com.qf.Gobang; import java.util.Scanner; import org.omg.COR

java實現簡單的MVC框架

.title { background: blue; height: 50px; line-height: 50px; border: 1px solid; color: red } 一、mvc的模式如下圖所示 二、基於路徑訪問的控制器 控制器BaseServlet類如下 package c

Java實現簡單的資料結構(五)

(5)二叉樹 public class BinaryTreeNode { private Comparable data; private BinaryTreeNode root; private BinaryTreeNode left; private BinaryTreeN

Java實現簡單的資料結構(四)

(4)Queue import org.junit.Test; public class Queue { private int size = 0; private LinkedList linkedList = new LinkedList(); /** * 入隊方法

Java實現簡單的資料結構(三)

(3)Stack package com.coding.basic; import org.junit.Test; public class Stack { private ArrayList elementData = new ArrayList(); /** * 壓棧

Java實現簡單的資料結構(二)

2.LinkedList import java.util.NoSuchElementException; import org.junit.Test; public class LinkedList implements List { private Node first;

Java實現簡單的資料結構(一)

利用Java語言實現簡單的資料結構,Java中動態擴容的ArrayList,LinkedList,Stack,Queue以及二叉樹 1.ArrayList import java.util.Arrays; import org.junit.Test; public class A