V2EX = way to explore V2EX 是一个关于分享和探索的地方
Sign Up Now For Existing Member Sign In
This topic created in 1859 days ago, the information mentioned may be changed or developed.
从网上 下了个 netty demo 想修改它的自定义消息类 Message 有点懵逼 不知道怎么下手
-----------------------------------------------------------------------------------------------
是想在保持心跳连接的基础上 添加上传文件
-----------------------------------------------------------------------------------------------
心跳的 demo 发送消息
ctx.writeAndFlush(
Message.MessageBase.newBuilder()
.setClientId(CLIENTID)
.setCmd(Command.CommandType.PUSH_DATA)
.setData("发送业务数据中。。。")
.build()
);
-----------------------------------------------------------------------------------------------
上传文件的 demo
FileUploadFile uploadFile = new FileUploadFile();
File file = new File("D:\\testFile\\无标题项目.aep");//
String fileMd5 = file.getName();// 文件名
uploadFile.setFile(file);
uploadFile.setFile_md5(fileMd5);
uploadFile.setStarPos(0);// 文件开始位置
new FileUploadClient().connect(FILE_PORT, "127.0.0.1", uploadFile);
-----------------------------------------------------------------------------------------------
请大佬们 留下 qq 或者微信 让我咨询一下 谢谢大佬们 qaq
-----------------------------------------------------------------------------------------------
是想在保持心跳连接的基础上 添加上传文件
-----------------------------------------------------------------------------------------------
心跳的 demo 发送消息
ctx.writeAndFlush(
Message.MessageBase.newBuilder()
.setClientId(CLIENTID)
.setCmd(Command.CommandType.PUSH_DATA)
.setData("发送业务数据中。。。")
.build()
);
-----------------------------------------------------------------------------------------------
上传文件的 demo
FileUploadFile uploadFile = new FileUploadFile();
File file = new File("D:\\testFile\\无标题项目.aep");//
String fileMd5 = file.getName();// 文件名
uploadFile.setFile(file);
uploadFile.setFile_md5(fileMd5);
uploadFile.setStarPos(0);// 文件开始位置
new FileUploadClient().connect(FILE_PORT, "127.0.0.1", uploadFile);
-----------------------------------------------------------------------------------------------
请大佬们 留下 qq 或者微信 让我咨询一下 谢谢大佬们 qaq
5 replies 2021-03-25 17:54:08 +08:00
 | 1 xinhochen Mar 25, 2021 没看到 Encoder，不好说。 不过大体思路就是 setCmd()那里加一个 CommandType.FILE_UPLOAD，setData()里面把文件的 byte[]放进去。 要看 Encoder 的实现来考虑是否需要添加新的 Encoder，或者在现有 Encoder 中添加新逻辑 |
 | 2 RedBeanIce Mar 25, 2021 看一下 netty 的官方文档，里面有示例，不知道是不是你要的，GitHub 的 netty\example\src\main\java\io\netty\example\http\upload\HttpUploadServerHandler.java |
 | 3 YzSama Mar 25, 2021 把文件 转成 流。包装到 data 里面。cmd 定义个 文件上传的命令。 |
 | 4 sujunjie520 OP @xinhochen 问题就是那个 Encoder 里面的代码有点看不懂 总之感谢大佬了 |
| 5 sujunjie520 OP @YzSama 我也是这个思路 qaq 问题是 cmd 就是那个消息类里的代码 看不懂 不知道咋下手 |
Select Language