Netty實現聊天通訊（4.0）
阿新 • • 發佈：2018-12-30
package com.test.netty4;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.http.FullHttpRequest;
public interface IHttpService {
void handleHttpRequest(ChannelHandlerContext ctx, FullHttpRequest request);
}
package com.test.netty4;
import io.netty
package com.test.netty4;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap
package com.test.netty4;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.FullHttpRequest;
import io.netty.handler.codec.http.websocketx.WebSocketFrame;
public class WebSocketServerHandler extends SimpleChannelInboundHandler<Object> {
@SuppressWarnings("unused")
private IWebSocketService websocketService;
private IHttpService httpService;
public WebSocketServerHandler(IWebSocketService websocketService, IHttpService httpService) {
super();
this.websocketService = websocketService;
this.httpService = httpService;
}
/*
* @see
* io.netty.channel.SimpleChannelInboundHandler#channelRead0(io.netty.channel
* .ChannelHandlerContext, java.lang.Object)
*/
@Override
protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
if (msg instanceof FullHttpRequest) {
httpService.handleHttpRequest(ctx, (FullHttpRequest) msg);
} else if (msg instanceof WebSocketFrame) {
websocketService.handleFrame(ctx, (WebSocketFrame) msg);
}
}
/*
* @see io.netty.channel.ChannelInboundHandlerAdapter#channelReadComplete(io.netty.channel.ChannelHandlerContext)
*/
@Override
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
ctx.flush();
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
}
}
2、html頁面程式碼
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<title></title>
</head>
</head>
<script type="text/javascript">
var socket;
if(!window.WebSocket){
window.WebSocket = window.MozWebSocket;
}
if(window.WebSocket){
socket = new WebSocket("ws://localhost:9999");
socket.onmessage = function(event){
appendln("接收:" + event.data);
};
socket.onopen = function(event){
appendln("WebSocket 連線已建立");
};
socket.onclose = function(event){
appendln("WebSocket 連線已關閉");
};
}else{
alert("瀏覽器不支援WebSocket協議");
}
function send(message){
if(!window.WebSocket){return;}
if(socket.readyState == WebSocket.OPEN){
socket.send(message);
appendln("傳送:" + message);
}else{
alert("WebSocket連線建立失敗");
}
}
function appendln(text) {
var ta = document.getElementById('responseText');
ta.value += text + "\r\n";
}
function clear() {
var ta = document.getElementById('responseText');
ta.value = "";
}
</script>
<body>
<form onSubmit="return false;">
<input type = "text" name="message" value="你好啊"/>
<br/><br/>
<input type="button" value="傳送 WebSocket 請求訊息" onClick="send(this.form.message.value)"/>
<hr/>
<h3>服務端返回的應答訊息</h3>
<textarea id="responseText" style="width: 800px;height: 300px;"></textarea>
</form>
</body>
</html>
3、啟動 WebSocketServer 的main方法，然後開啟多個html頁面，即可實現聊天互通。更
此處是基於netty-all-4.1.12.Final.jar實現的。更詳細的介紹可自行網路搜尋。