企业官网建设流程全解析

需要做个网站,wordpress调用插件,设计师一般多少岁被淘汰,有了页游源代码如何做网站Channel 在 Netty 中代表一个网络连接#xff0c;它的生命周期包括以下几个主要状态#xff1a;注册(Registered)#xff1a;Channel 被注册到 EventLoop 上激活(Active)#xff1a;Channel 连接建立并就绪非激活(Inactive)#xff1a;Channel 连接断开注销(Unregistered)…Channel在Netty中代表一个网络连接它的生命周期包括以下几个主要状态注册(Registered)Channel 被注册到 EventLoop 上激活(Active)Channel 连接建立并就绪非激活(Inactive)Channel 连接断开注销(Unregistered)Channel 从 EventLoop 中注销这些状态变化会触发 ChannelHandler 中的相应生命周期方法如 channelRegistered()、channelActive() 等。Handler的生命周期Handler是数据处理的核心组件它们也有清晰的生命周期添加handlerAdded() 在 Handler 被添加到 ChannelPipeline 时调用移除handlerRemoved() 在Handler从ChannelPipeline 移除时调用异常exceptionCaught() 在处理过程中发生异常时调用服务器启动流程创建服务器引导类使用 ServerBootstrap 配置服务器参数设置线程模型指定 Boss 线程组和 Worker 线程组配置Channel选择 NioServerSocketChannel 等实现添加处理器配置 ChannelInitializer 来设置每个新连接的处理链绑定端口调用 bind() 方法启动服务器并监听端口我们可以把这个过程想象成组装和使用一台机器首先准备好零件创建组件然后按照说明书组装配置连接接通电源启动服务机器开始工作处理数据最后关闭电源拆解维护关闭资源。整个过程有条不紊每个组件都知道自己什么时候该做什么事情。实时通讯技术方案选型在构建需要实时数据交互的应用时有三种主流技术方案Ajax轮训原理客户端定时向服务器发送请求检查是否有新数据。优势实现简单兼容性极佳几乎所有浏览器都支持服务器逻辑直观。劣势产生大量无效请求浪费资源实时性受轮询间隔限制延迟明显高并发时可能造成服务器压力。Long pull长轮询原理客户端发送请求后服务器保持连接不立即响应直到有新数据或超时才返回客户端收到后立即发起新请求。优势减少无效请求实时性较轮询有所提升兼容性良好。劣势服务器需维持大量连接高并发场景资源消耗大仍有一定延迟。WebSocket原理建立单一TCP连接后提供持久双向通信通道双方可随时发送数据。优势真正的实时双向通信延迟低协议开销小适合频繁数据交换资源消耗相对较低。劣势实现复杂度较高部分老旧浏览器不支持某些网络环境可能受限。在我们要构建的即时通讯服务中WebSocket无疑是最佳选择它能最好地满足我们对实时性的要求。值得一提的是Netty提供了对WebSocket的原生支持和优化实现这让我们能够轻松构建可扩展且高效的实时通讯系统省去了处理底层通信细节的繁琐工作更专注于业务逻辑的实现。代码实现本节将围绕前后端关键实现展开给大家展示如何基于Netty开发即时通讯服务。前端本文侧重于后端服务的构建因此前端只展示核心通信代码。以下代码实现了与Netty服务器建立WebSocket连接、消息收发及状态管理的关键功能为后续后端实现提供了交互基础。// 1. WebSocket连接全局配置 globalData: { // WebSocket服务器连接地址 chatServerUrl: ws://127.0.0.1:875/ws, // 全局WebSocket连接对象 CHAT: null, // 标记WebSocket连接状态 chatSocketOpen: false, }, // 2. 应用启动时初始化WebSocket连接 onLaunch: function() { // 程序启动时连接聊天服务器 this.doConnect(false); }, // 3. 核心方法建立WebSocket连接 doConnect(isFirst) { // 重连时显示提示 if (isFirst) { uni.showToast({ icon: loading, title: 断线重连中..., duration: 2000 }); } var me this; // 仅当用户已登录时才连接WebSocket if (me.getUserInfoSession() ! null me.getUserInfoSession() ! me.getUserInfoSession() ! undefined) { // 创建WebSocket连接 me.globalData.CHAT uni.connectSocket({ url: me.globalData.chatServerUrl, complete: () {} }); // 4. 连接成功事件处理 me.globalData.CHAT.onOpen(function(){ // 更新连接状态标记 me.globalData.chatSocketOpen true; console.log(ws连接已打开socketOpen me.globalData.chatSocketOpen); // 构建初始化消息(消息类型0表示连接初始化) var chatMsg { senderId: me.getUserInfoSession().id, msgType: 0 } var dataContent { chatMsg: chatMsg } var msgPending JSON.stringify(dataContent); // 发送初始化消息通知服务器用户身份 me.globalData.CHAT.send({ data: msgPending }); }); // 5. 连接关闭事件处理 me.globalData.CHAT.onClose(function(){ me.globalData.chatSocketOpen false; console.log(ws连接已关闭socketOpen me.globalData.chatSocketOpen); }); // 6. 接收消息事件处理 me.globalData.CHAT.onMessage(function(res){ console.log(App.vue 收到服务器内容 res.data); // 处理接收到的消息 me.dealReceiveLastestMsg(JSON.parse(res.data)); }); // 7. 连接错误事件处理 me.globalData.CHAT.onError(function(){ me.globalData.chatSocketOpen false; console.log(WebSocket连接打开失败请检查); }); } }, // 8. 发送WebSocket消息的通用方法 sendSocketMessage(msg) { // 检查连接状态只有在连接开启时才发送 if (this.globalData.chatSocketOpen) { uni.sendSocketMessage({ data: msg }); } else { uni.showToast({ icon: none, title: 您已断开聊天服务器的连接 }) } }, // 9. 处理接收到的消息 dealReceiveLastestMsg(msgJSON) { console.log(msgJSON); var chatMsg msgJSON.chatMsg; var chatTime msgJSON.chatTime; var senderId chatMsg.senderId; var receiverType chatMsg.receiverType; console.log(chatMsg.receiverType receiverType); var me this; // 获取发送者的用户信息 var userId me.getUserInfoSession().id; var userToken me.getUserSessionToken(); var serverUrl me.globalData.serverUrl; // 请求发送者详细信息 uni.request({ method: POST, header: { headerUserId: userId, headerUserToken: userToken }, url: serverUrl /userinfo/get?userId senderId, success(result) { if (result.data.status 200) { var currentSourceUserInfo result.data.data; me.currentSourceUserInfo currentSourceUserInfo; // 根据消息类型设置显示内容 var msgShow chatMsg.msg; if (chatMsg.msgType 2) { msgShow [图片] } elseif (chatMsg.msgType 4) { msgShow [视频] } elseif (chatMsg.msgType 3) { msgShow [语音] } // 保存最新消息到本地存储 me.saveLastestMsgToLocal(senderId, currentSourceUserInfo, msgShow, chatTime, msgJSON); } } }) }, // 10. 将最新消息保存到本地存储 saveLastestMsgToLocal(sourceUserId, sourceUser, msgContent, chatTime, msgJSON) { // 构造最新消息对象 var lastMsg { sourceUserId: sourceUserId, // 源头用户聊天对象 name: sourceUser.nickname, face: sourceUser.face, msgContent: msgContent, chatTime: chatTime, unReadCounts: 0, communicationType: 1, // 1:单聊2:群聊 } // 获取本地存储的聊天列表 var lastestUserChatList uni.getStorageSync(lastestUserChatList); if (lastestUserChatList null || lastestUserChatList undefined || lastestUserChatList ) { lastestUserChatList []; } // 更新或新增消息记录 var dealMsg false; for (var i 0; i lastestUserChatList.length; i) { var tmp lastestUserChatList[i]; if (tmp.sourceUserId lastMsg.sourceUserId) { // 已存在聊天记录更新最新消息 lastestUserChatList.splice(i, 1, lastMsg); dealMsg true; break; } } if (!dealMsg) { // 新的聊天对象添加到列表开头 lastestUserChatList.unshift(lastMsg); } // 保存更新后的聊天列表 uni.setStorageSync(lastestUserChatList, lastestUserChatList); // 通知UI更新 uni.$emit(reRenderReceiveMsgInMsgVue, domeafavor); uni.$emit(receiveMsgInMsgListVue, msgJSON); }, // 11. 关闭WebSocket连接 closeWSConnect() { this.globalData.CHAT.close(); }后端万事要开头始于导入依赖。Ps这里大家在实操的时候去Maven仓库找最新版本不一定非要和我的版本一样dependency groupIdio.netty/groupId artifactIdnetty-all/artifactId version4.2.0.Final/version /dependency1.首先创建服务器启动类这是整个Netty服务器的入口点负责配置和启动WebSocket服务器。import com.pitayafruits.netty.websocket.WSServerInitializer; 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; * netty 服务启动类 */ publicclassChatServer { publicstaticvoidmain(String[] args)throws InterruptedException { EventLoopGroupbossGroupnewNioEventLoopGroup(); EventLoopGroupworkerGroupnewNioEventLoopGroup(); try { ServerBootstrapservernewServerBootstrap(); server.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .childHandler(newWSServerInitializer()); ChannelFuturechannelFuture server.bind(875).sync(); channelFuture.channel().closeFuture().sync(); } finally { bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); } } }关键点采用Reactor模式使用两个线程池bossGroup和workerGroupbossGroup负责接受客户端连接workerGroup负责处理IO操作服务器绑定在875端口2.接下来创建通道初始化器负责配置每个新建立的连接的通道设置处理器链(Pipeline)。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; * 初始化器,channel注册后会执行里面相应的初始化方法 */ publicclassWSServerInitializerextendsChannelInitializerSocketChannel { Override protectedvoidinitChannel(SocketChannel socketChannel)throws Exception { ChannelPipelinepipeline socketChannel.pipeline(); pipeline.addLast(newHttpServerCodec()); pipeline.addLast(newChunkedWriteHandler()); pipeline.addLast(newHttpObjectAggregator(1024 * 64)); pipeline.addLast(newWebSocketServerProtocolHandler(/ws)); pipeline.addLast(newChatHandler()); } }关键点处理HTTP协议HttpServerCodec、ChunkedWriteHandler、HttpObjectAggregator处理WebSocket协议WebSocketServerProtocolHandler(/ws)指定WebSocket的路由为/ws添加自定义业务处理器ChatHandler处理具体的消息交互逻辑3.接着创建会话管理器管理用户ID与通道(Channel)之间的映射关系支持同一用户多端登录。Ps这个根据实际业务情况来如果不需要支持多端登录则不需要创建。import io.netty.channel.Channel; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; * 会话管理 */ publicclassUserChannelSession { privatestatic MapString, ListChannel multiSession newHashMap(); privatestatic MapString, String userChannelIdRelation newHashMap(); publicstaticvoidputUserChannelIdRelation(String userId, String channelId) { userChannelIdRelation.put(channelId, userId); } publicstatic String getUserIdByChannelId(String channelId) { return userChannelIdRelation.get(channelId); } publicstaticvoidputMultiChannels(String userId, Channel channel) { ListChannel channels getMultiChannels(userId); if (channels null || channels.size() 0) { channels newArrayList(); } channels.add(channel); multiSession.put(userId, channels); } publicstaticvoidremoveUserChannels(String userId, String channelId) { ListChannel channels getMultiChannels(userId); if (channels null || channels.size() 0) { return; } for (Channel channel : channels) { if (channel.id().asLongText().equals(channelId)) { channels.remove(channel); } } multiSession.put(userId, channels); } publicstatic ListChannel getMultiChannels(String userId) { return multiSession.get(userId); } }4.最后是创建消息处理器它是核心业务逻辑处理器负责处理客户端发送的WebSocket消息。大家可以注意到这里对于消息类型留了扩展的口子本次我们实现先只实现文字消息。import com.pitayafruits.enums.MsgTypeEnum; import com.pitayafruits.pojo.netty.ChatMsg; import com.pitayafruits.utils.JsonUtils; import com.pitayafruits.pojo.netty.DataContent; import com.pitayafruits.utils.LocalDateUtils; 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; import java.time.LocalDateTime; import java.util.List; * 自定义助手类 */ publicclassChatHandlerextendsSimpleChannelInboundHandlerTextWebSocketFrame { publicstaticChannelGroupclientsnewDefaultChannelGroup(GlobalEventExecutor.INSTANCE); Override protectedvoidchannelRead0(ChannelHandlerContext channelHandlerContext, TextWebSocketFrame textWebSocketFrame) throws Exception { Stringcontent textWebSocketFrame.text(); DataContentdataContent JsonUtils.jsonToPojo(content, DataContent.class); ChatMsgchatMsg dataContent.getChatMsg(); StringmsgText chatMsg.getMsg(); StringreceiverId chatMsg.getReceiverId(); StringsenderId chatMsg.getSenderId(); chatMsg.setChatTime(LocalDateTime.now()); IntegermsgType chatMsg.getMsgType(); ChannelcurrentChannel channelHandlerContext.channel(); StringcurrentChannelId currentChannel.id().asLongText(); if (msgType MsgTypeEnum.CONNECT_INIT.type) { UserChannelSession.putMultiChannels(senderId, currentChannel); UserChannelSession.putUserChannelIdRelation(currentChannelId, senderId); } elseif (msgType MsgTypeEnum.WORDS.type) { ListChannel receiverChannels UserChannelSession.getMultiChannels(receiverId); if (receiverChannels null || receiverChannels.size() 0 || receiverChannels.isEmpty()) { chatMsg.setIsReceiverOnLine(false); } else { chatMsg.setIsReceiverOnLine(true); for (Channel receiverChannel : receiverChannels) { ChannelfindChannel clients.find(receiverChannel.id()); if (findChannel ! null) { dataContent.setChatMsg(chatMsg); StringchatTimeFormat LocalDateUtils.format(chatMsg.getChatTime(), LocalDateUtils.DATETIME_PATTERN_2); dataContent.setChatTime(chatTimeFormat); findChannel.writeAndFlush( newTextWebSocketFrame( JsonUtils.objectToJson(dataContent))); } } } } currentChannel.writeAndFlush(newTextWebSocketFrame(currentChannelId)); } Override publicvoidhandlerAdded(ChannelHandlerContext ctx)throws Exception { ChannelcurrentChannel ctx.channel(); clients.add(currentChannel); } Override publicvoidhandlerRemoved(ChannelHandlerContext ctx)throws Exception { ChannelcurrentChannel ctx.channel(); StringuserId UserChannelSession.getUserIdByChannelId(currentChannel.id().asLongText()); UserChannelSession.removeUserChannels(userId, currentChannel.id().asLongText()); clients.remove(currentChannel); } Override publicvoidexceptionCaught(ChannelHandlerContext ctx, Throwable cause)throws Exception { Channelchannel ctx.channel(); channel.close(); clients.remove(channel); StringuserId UserChannelSession.getUserIdByChannelId(channel.id().asLongText()); UserChannelSession.removeUserChannels(userId, channel.id().asLongText()); } }再梳理一下完整流程1.服务器启动ChatServer创建并配置Netty服务器设置线程模型和端口2.通道初始化当有新连接时WSServerInitializer设置处理器链Pipeline3.连接建立ChatHandler.handlerAdded()将连接添加到ChannelGroup4.消息处理客户端先发送初始化消息建立用户ID与Channel的映射关系客户端后续发送聊天消息服务器查找接收者的Channel并转发消息5.连接断开ChatHandler.handlerRemoved()清理资源移除映射关系。效果演示小结至此我们已成功构建了一个基于Netty的即时通讯服务。虽然当前实现仍有一些局限如缺少离线消息存储机制、消息类型较为单一、未实现消息持久化等但本文 代码示例给大家展示了基于Netty构建聊天服务的核心架构与完整流程。基于现有示例可以轻松地扩展更多功能如添加消息队列实现离线消息推送、集成数据库实现消息持久化、增加群聊和多媒体消息支持等。希望本文能为各位读者提供实现思路也鼓励大家在这个基础上进行实践操作打造更加完善的即时通讯服务。