首页下载资源后端纯netty，没有websocket

ZIP纯netty，没有websocket

liuruiaaa5.9KB需要积分:1

资源文件列表:

netty.zip 大约有5个文件
  1. MyClientHandler.java 955B
  2. MyServer.java 2.57KB
  3. MyServerHandler.java 5.81KB
  4. MyServerTwoHandler.java 2.58KB
  5. MyClient.java 1.62KB

资源介绍:

纯netty，没有websocket
package io.renren.modules.test.netty; import cn.hutool.json.JSONUtil; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.util.CharsetUtil; import org.json.JSONObject; /** * 自定义的Handler需要继承Netty规定好的HandlerAdapter * 才能被Netty框架所关联，有点类似SpringMVC的适配器模式 * ChannelInboundHandlerAdapter(入站处理器) * ChannelOutboundHandler(出站处理器) * * ChannelInboundHandlerAdapter处理器常用的事件有： * 注册事件 fireChannelRegistered。 * 连接建立事件 fireChannelActive。 * 读事件和读完成事件 fireChannelRead、ChannelReadComplete。 * 异常通知事件 fireExceptionCaught。 * 用户自定义事件 fireEventTriggered。 * Channel 可写状态变化事件 fireChannelWritabilityChanged。 * 连接关闭事件 fireChannelInactive。 * 都有对对应的 * *ChannelOutboundHandler处理器常用的事件有： * 端口绑定 bind。 * 连接服务端 connect。 * 写事件 write。 * 刷新时间 flush。 * 读事件 read。 * 主动断开连接 disconnect。 * 关闭 channel 事件 close。 * **/ public class MyServerHandler extends ChannelInboundHandlerAdapter { @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { String s = JSONUtil.toJsonStr(msg); System.out.println("发送过来的原始msg："+s); ByteBuf byteBuf = (ByteBuf) msg; try { // 将接收到的ByteBuf转换为字符串 String messageStr = byteBuf.toString(CharsetUtil.UTF_8); // 解析接收到的JSON消息 JSONObject jsonMsg = new JSONObject(messageStr); // 获取消息中的各个字段 String msgId = jsonMsg.getString("msgId"); int msgType = jsonMsg.getInt("msgType"); String fromId = jsonMsg.getString("fromId"); long timestamp = jsonMsg.getLong("timestamp"); JSONObject extend = jsonMsg.getJSONObject("extend"); // 处理消息，根据msgType执行不同的业务逻辑 switch (msgType) { case 1001: handleMsgType1001(ctx, msgId, fromId, timestamp, extend); break; // 可以添加其他类型的处理逻辑 default: handleUnknownMessageType(ctx, msgType, msgId); break; } } catch (Exception e) { // 消息格式错误处理 System.err.println("接收到的消息格式错误：" + e.getMessage()); } finally { // 释放ByteBuf资源 byteBuf.release(); } } private void handleMsgType1001(ChannelHandlerContext ctx, String msgId, String fromId, long timestamp, JSONObject extend) { // 处理消息类型为1001的业务逻辑 String token = extend.getString("token"); // 可以根据具体业务逻辑进一步处理 System.out.println("处理消息类型为1001的业务逻辑，token=" + token); // 假设服务端回复一个确认消息给客户端 JSONObject response = new JSONObject(); response.put("msgId", msgId); response.put("type", "ack"); response.put("timestamp", System.currentTimeMillis()); ctx.writeAndFlush(Unpooled.copiedBuffer(response.toString(), CharsetUtil.UTF_8)); } private void handleUnknownMessageType(ChannelHandlerContext ctx, int msgType, String msgId) { // 处理未知类型的消息 System.out.println("收到未知类型的消息，msgType=" + msgType + ", msgId=" + msgId); // 可以根据具体情况进行处理，例如记录日志或发送错误消息给客户端 } // 处理数据消息 private void handleDataMessage(ChannelHandlerContext ctx, JSONObject jsonMsg) { // 处理数据逻辑，根据具体业务需求处理数据 } // 处理未知类型的消息 private void handleUnknownMessage(ChannelHandlerContext ctx, JSONObject jsonMsg) { // 处理未知类型的消息，可以记录日志或者发送错误响应给客户端 } // @Override // public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { //// //获取客户端发送过来的消息 // ByteBuf byteBuf = (ByteBuf) msg; // System.out.println("收到客户端" + ctx.channel().remoteAddress() + "发送的消息：" + byteBuf.toString(CharsetUtil.UTF_8)); // //获取到线程池eventLoop，添加线程，执行 //// ctx.channel().eventLoop().execute(new Runnable() { //// @Override //// public void run() { //// try { //// //长时间操作，不至于长时间的业务操作导致Handler阻塞 //// Thread.sleep(1000); //// ByteBuf byteBuf = (ByteBuf) msg; //// System.out.println("长时间的业务处理:"+"发送的消息：" + byteBuf.toString(CharsetUtil.UTF_8)); //// } catch (Exception e) { //// e.printStackTrace(); //// } //// } //// }); // // // } @Override public void channelReadComplete(ChannelHandlerContext ctx) throws Exception { //发送消息给客户端 ctx.writeAndFlush(Unpooled.copiedBuffer("服务端已收到消息，并给你发送一个消息：哈哈。。。", CharsetUtil.UTF_8)); } @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { //发生异常，关闭通道 ctx.close(); } }
100+评论
captcha

    相关资源

    1. Qt学习记录（十）项目：数字炸弹/猜数字游戏

      qq_42908901#移动开发ZIP12.93KB8月前
      资源摘要:Qt学习记录（十）项目：数字炸弹/猜数字游戏新手项目，佬们多多包含

    2. 计算机组成原理实验8位可控加减法电路设计，原码一位乘法器设计，MIPS运算器设计，汉字字库存储芯片扩展实验，寄存器文件设

      weixin_52948586#考试认证ZIP1.55MB8月前
      资源摘要:8位可控加减法电路设计，原码一位乘法器设计，MIPS运算器设计，汉字字库存储芯片扩展实验，寄存器文件设计，微程序地址转移逻辑设计.

    3. 数字滤波器的MATLAB与FPGA实现-AlteraVerilog版

      qq_58236183#硬件开发ZIP1.43MB8月前
      资源摘要:数字滤波器的MATLAB与FPGA实现-AlteraVerilog版

    4. libssh2库，内函编译好的32位和64位的动态库lib、dll，以及相关头文件

      Motseturtle#安全技术ZIP242.4KB8月前
      资源摘要:libssh2库，内函编译好的32位和64位的动态库lib、dll，以及相关头文件include文件夹:libssh2.hlibssh2_publickey.hlibssh2_sftp.hlib文件夹：libssh2_x64.ziplibssh2_x86.zip

    5. AndroidStudio期末设计天气预报APP源代码+实验报告

      chencxiaobai#移动开发ZIP25.71MB8月前
      资源摘要:​安卓APP期末设计作业项目为https://www.bilibili.com/video/BV1QE411i7oQ/?spm_id_from=333.999.0.0&vd_source=30298dec9326e02d1a6336b519833fc4实验报告包含背景、可行性分析、系统设计与实施和开发设计总结GradleVersion为5.1.1

    6. 《整合 Spring Boot 和 Netty 实现 WebSocket》 代码写的太完美了！存一个！

      liuruiaaa#后端ZIP6.55KB8月前
      资源摘要:《整合 Spring Boot 和 Netty 实现 WebSocket》 代码写的太完美了！存一个！资源来自:https://blog.csdn.net/dot_life/article/details/136575529

    7. QT利用QMovie实现动态加载、等待提示框

      u012959478#移动开发ZIP7.75KB8月前
      资源摘要:有时候要进行某项后台处理，但后台处理时间很长，需要提示用户等待，这时候做一个动态等待窗口，可以清晰展示当前操作的状态，以便用户能够理解和接受。本实例实现方式为获取一张gif的资源图，然后使用QMovie 在一个QLabel 控件上加载显示gif的waiting等待动态。

    8. C# 程序集的加载和卸载

      qq_38693757#操作系统ZIP101.83KB8月前
      资源摘要:帖子地址：https://blog.csdn.net/qq_38693757/article/details/140437283?spm=1001.2014.3001.5502
    站长QQ:九六九五七三七