溫馨提示×
您好，登錄后才能下訂單哦！
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》
您好，登錄后才能下訂單哦！
本篇內(nèi)容介紹了“Netty中怎么實(shí)現(xiàn)websocket發(fā)消息”的有關(guān)知識，在實(shí)際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！
<dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>4.1.25.Final</version> </dependency>
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8" />
<title></title>
</head>
<body>
<div>發(fā)送消息:</div>
<input type="text" id="msgContent"/>
<input type="button" value="點(diǎn)我發(fā)送" onclick="CHAT.chat()"/>
<div>接受消息：</div>
<div id="receiveMsg" ></div>
<script type="application/javascript">
window.CHAT = {
socket: null,
init: function() {
if (window.WebSocket) {
CHAT.socket = new WebSocket("ws://192.168.31.160:8088/ws");
CHAT.socket.onopen = function() {
console.log("連接建立成功...");
},
CHAT.socket.onclose = function() {
console.log("連接關(guān)閉...");
},
CHAT.socket.onerror = function() {
console.log("發(fā)生錯誤...");
},
CHAT.socket.onmessage = function(e) {
console.log("接受到消息：" + e.data);
var receiveMsg = document.getElementById("receiveMsg");
var html = receiveMsg.innerHTML;
receiveMsg.innerHTML = html + "<br/>" + e.data;
}
} else {
alert("瀏覽器不支持websocket協(xié)議...");
}
},
chat: function() {
var msg = document.getElementById("msgContent");
CHAT.socket.send(msg.value);
}
};
CHAT.init();
</script>
</body>
</html>import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
public class WSServer {
public static void main(String[] args) throws Exception {
//定義一對線程組
// 主線程組, 用于接受客戶端的連接，但是不做任何處理，跟老板一樣，不做事
EventLoopGroup mainGroup = new NioEventLoopGroup();
// 從線程組, 老板線程組會把任務(wù)丟給他，讓手下線程組去做任務(wù)
EventLoopGroup subGroup = new NioEventLoopGroup();
try {
// netty服務(wù)器的創(chuàng)建, ServerBootstrap 是一個啟動類
ServerBootstrap server = new ServerBootstrap();
server.group(mainGroup, subGroup) // 設(shè)置主從線程組
.channel(NioServerSocketChannel.class) // 設(shè)置nio的雙向通道
.childHandler(new WSServerInitialzer()); //// 子處理器，用于處理workerGroup
// 啟動server，并且設(shè)置8088為啟動的端口號，同時啟動方式為同步
ChannelFuture future = server.bind(8088).sync();
future.channel().closeFuture().sync();
} finally {
// 監(jiān)聽關(guān)閉的channel，設(shè)置位同步方式
mainGroup.shutdownGracefully();
subGroup.shutdownGracefully();
}
}
}import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
import io.netty.handler.stream.ChunkedWriteHandler;
public class WSServerInitialzer extends ChannelInitializer<SocketChannel> {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
// websocket 基于http協(xié)議，所以要有http編解碼器
pipeline.addLast(new HttpServerCodec());
// 對寫大數(shù)據(jù)流的支持
pipeline.addLast(new ChunkedWriteHandler());
// 對httpMessage進(jìn)行聚合，聚合成FullHttpRequest或FullHttpResponse
// 幾乎在netty中的編程，都會使用到此hanler
pipeline.addLast(new HttpObjectAggregator(1024*64));
// ====================== 以上是用于支持http協(xié)議 ======================
// ====================== 以下是支持httpWebsocket ======================
/**
* websocket 服務(wù)器處理的協(xié)議，用于指定給客戶端連接訪問的路由 : /ws
* 本handler會幫你處理一些繁重的復(fù)雜的事
* 會幫你處理握手動作： handshaking（close, ping, pong） ping + pong = 心跳
* 對于websocket來講，都是以frames進(jìn)行傳輸?shù)模煌臄?shù)據(jù)類型對應(yīng)的frames也不同
*/
pipeline.addLast(new WebSocketServerProtocolHandler("/ws"));
// 自定義的handler
pipeline.addLast(new ChatHandler());
}
}import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import io.netty.util.concurrent.GlobalEventExecutor;
/**
*
* @Description: 處理消息的handler
* TextWebSocketFrame： 在netty中，是用于為websocket專門處理文本的對象，frame是消息的載體
*/
public class ChatHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {
// 用于記錄和管理所有客戶端的channle
private static ChannelGroup clients =
new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
@Override
protected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg)
throws Exception {
// 獲取客戶端傳輸過來的消息
String content = msg.text();
System.out.println("接受到的數(shù)據(jù)：" + content);
//類似于for循環(huán)
clients.writeAndFlush(
new TextWebSocketFrame(
"[服務(wù)器在]" + LocalDateTime.now()
+ "接受到消息, 消息為：" + content));
}
/**
* 當(dāng)客戶端連接服務(wù)端之后（打開連接）
* 獲取客戶端的channle，并且放到ChannelGroup中去進(jìn)行管理
*/
@Override
public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
clients.add(ctx.channel());
}
@Override
public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
// 當(dāng)觸發(fā)handlerRemoved，ChannelGroup會自動移除對應(yīng)客戶端的channel
// clients.remove(ctx.channel());
System.out.println("客戶端斷開，channle對應(yīng)的長id為："
+ ctx.channel().id().asLongText());
System.out.println("客戶端斷開，channle對應(yīng)的短id為："
+ ctx.channel().id().asShortText());
}
}運(yùn)行index.html
發(fā)送消息，如下server端返回消息
“Netty中怎么實(shí)現(xiàn)websocket發(fā)消息”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！
免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。
億速云公眾號
手機(jī)網(wǎng)站二維碼