java實現websocket，前臺都後臺demo

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

下文的簡潔程式碼即建立了一個 WebSocket 的服務端，@ServerEndpoint("/echo")註釋端點表示將 WebSocket 服務端執行在 ws://[Server 端 IP 或域名]:[Server 埠]/websockets/echo 的訪問端點，

客戶端瀏覽器已經可以對 WebSocket 客戶端 API 發起 HTTP 長連線了。

使用 ServerEndpoint 註釋的類必須有一個公共的無引數建構函式，

@onMessage 註解的 Java 方法用於接收傳入的 WebSocket 資訊，這個資訊可以是文字格式，也可以是二進位制格式。
OnOpen 在這個端點一個新的連線建立時被呼叫。引數提供了連線的另一端的更多細節。Session 表明兩個 WebSocket 端點對話連線的另一端，可以理解為類似 HTTPSession 的概念。
OnClose 在連線被終止時呼叫。引數 closeReason 可封裝更多細節，如為什麼一個 WebSocket 連線關閉。
更高階的定製如 @Message 註釋，MaxMessageSize 屬性可以被用來定義訊息位元組最大限制，在示例程式中，如果超過 6 個位元組的資訊被接收，就報告錯誤和連線關閉。
maven配置：

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

服務端程式碼：

import java.io.IOException;
import java.io.InputStream;


import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;


@ServerEndpoint("/echo")//這裡的註解在springboot中需要宣告一個config類
public class WebSocketHandle {
	
	private Process process;
	private InputStream inputStream;
	
	/**
	 * 新的WebSocket請求開啟
	 */
	@OnOpen
	public void onOpen(Session session) {
		try {
			// 執行tail -f命令
			process = Runtime.getRuntime().exec("tail -f /var/log/syslog");
			inputStream = process.getInputStream();
			
			// 一定要啟動新的執行緒，防止InputStream阻塞處理WebSocket的執行緒
			TailLogThread thread = new TailLogThread(inputStream, session);
			thread.start();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	/**
	 * WebSocket請求關閉
	 */
	@OnClose
	public void onClose() {
		try {
			if(inputStream != null)
				inputStream.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
		if(process != null)
			process.destroy();
	}
	
	@OnError
	public void onError(Throwable thr) {
		thr.printStackTrace();
	}
}

config類：

@Configuration
public class WebSocketConfig {
    @Bean
    public ServerEndpointExporter serverEndpointExporter(){
        return new ServerEndpointExporter();
    }
}

處理訊息的執行緒：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;


import javax.websocket.Session;


public class TailLogThread extends Thread {
	
	private BufferedReader reader;
	private Session session;
	
	public TailLogThread(InputStream in, Session session) {
		this.reader = new BufferedReader(new InputStreamReader(in));
		this.session = session;
		
	}
	
	@Override
	public void run() {
		String line;
		try {
			while((line = reader.readLine()) != null) {
				// 將實時日誌通過WebSocket傳送給客戶端，給每一行新增一個HTML換行
				session.getBasicRemote().sendText(line + "<br>");
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

當 Browser 和 WebSocketServer 連線成功後，會觸發 onopen 訊息；如果連線失敗，傳送、接收資料失敗或者處理資料出現錯誤，
browser 會觸發 onerror 訊息；當 Browser 接收到 WebSocketServer 傳送過來的資料時，就會觸發 onmessage 訊息，引數 evt
中包含 Server 傳輸過來的資料；當 Browser 接收到 WebSocketServer 端傳送的關閉連線請求時，就會觸發 onclose 訊息。
我們可以看出所有的操作都是採用非同步回撥的方式觸發，這樣不會阻塞 UI，可以獲得更快的響應時間，更好的使用者體驗
web端程式碼：

<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>tail log</title>
</head>
<body>
	<div id="log-container" style="height: 450px; overflow-y: scroll; background: #aaa; color: #aaa; padding: 10px;">
		<div>
		</div>
	</div>
    <script type="text/jscript" src="./jquery-3.3.1.min.js"></script>
<script>
	$(document).ready(function() {
		// 指定websocket路徑
		var websocket = new WebSocket('ws://localhost:8080/echo');
		websocket.onmessage = function(event) {
			// 接收服務端的實時日誌並新增到HTML頁面中
			$("#log-container div").append(event.data);
			// 滾動條滾動到最低部
			$("#log-container").scrollTop($("#log-container div").height() - $("#log-container").height());
		};
	});
</script>
</body>
</html>

java實現websocket，前臺都後臺demo

java實現websocket，前臺都後臺demo

【木木與呆呆的專欄】Java程式設計師，專注Java程式設計技術，開發以後臺為主前臺為輔，目前投身Hadoop大資料以及Ranger安全開發，活躍在大資料開源社群，同時推薦多種高效便捷的開發工具，分享自己的各種經驗技巧總結。

java實現websocket 終極指南

四、Netty實現webSocket，實現伺服器與瀏覽器（HTML）線上聊天功能

java實現爬蟲，爬取網易歌單資訊

小程式與java實現websocket通訊

java實現順序，二分，分塊查詢

Java實現websocket與微信小程式連線

Java 實現棧，佇列

通過Java實現HMAC，將字串雜湊成為全部由字母組成的密文串

## java實現支付寶掃碼支付Demo原始碼

JAVA實現websocket

Jquery EasyUI +Ajax +Json +一般處理程式實現資料的前臺與後臺的互動 --- 善良公社專案

ssm框架下，前臺與後臺的資料互動

Kafka 使用Java實現資料的生產和消費demo

Java實現websocket 的兩種方法

[演算法入門]快速排序非遞迴方法（Java實現），大家一起來找茬啊～

java實現String，date，timestamp相互轉換

NodeJS實現WebSocket，太容易了吧！！

ID3演算法的java實現(轉載，修改)

java實現websocket，前臺都後臺demo

相關推薦