From 9eeb7829dc17a40386b640493fc6eac7a1607b54 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=AB=98=E4=BF=9D=E5=AE=89?= <1409538202@qq.com> Date: Thu, 18 Dec 2025 10:19:14 +0800 Subject: [PATCH] =?UTF-8?q?=E6=97=A0=E4=BB=BB=E4=BD=95=E6=94=B9=E5=8A=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../realtime/packets/AutoSoftwarePacket.java | 1 - .../server/handler/AutoSoftwareHandler.java | 24 +++++++++++++++++-- .../server/handler/PrivateMessageHandler.java | 1 - 3 files changed, 22 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/realtime/packets/AutoSoftwarePacket.java b/src/main/java/com/realtime/packets/AutoSoftwarePacket.java index 97bd353..80c6c88 100644 --- a/src/main/java/com/realtime/packets/AutoSoftwarePacket.java +++ b/src/main/java/com/realtime/packets/AutoSoftwarePacket.java @@ -11,7 +11,6 @@ import java.util.List; @EqualsAndHashCode(callSuper = true) @Data public class AutoSoftwarePacket extends BasePackets { - private String merMessage; @Override public Byte getCommand() { return Command.SOFT_CALL_MSG; diff --git a/src/main/java/com/realtime/packets/server/handler/AutoSoftwareHandler.java b/src/main/java/com/realtime/packets/server/handler/AutoSoftwareHandler.java index c8226ce..edffe9c 100644 --- a/src/main/java/com/realtime/packets/server/handler/AutoSoftwareHandler.java +++ b/src/main/java/com/realtime/packets/server/handler/AutoSoftwareHandler.java @@ -1,25 +1,45 @@ package com.realtime.packets.server.handler; +import com.alibaba.fastjson2.JSONObject; import com.realtime.packets.AutoSoftwarePacket; +import com.realtime.packets.PingPongPacket; +import com.realtime.packets.SendMsgPackets; +import com.realtime.utils.SessionUtils; +import io.netty.buffer.ByteBuf; +import io.netty.channel.Channel; import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.SimpleChannelInboundHandler; +import io.netty.handler.codec.http.websocketx.TextWebSocketFrame; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; +import java.nio.charset.StandardCharsets; +import java.util.Objects; + @Slf4j @Component @ChannelHandler.Sharable @RequiredArgsConstructor(onConstructor = @__(@Autowired)) public class AutoSoftwareHandler extends SimpleChannelInboundHandler { + @Override protected void channelRead0(ChannelHandlerContext channelHandlerContext, AutoSoftwarePacket connectPacket) throws Exception { - - + Channel chanel = SessionUtils.getChannel(connectPacket.getReceiver()); + ByteBuf buff = getBuff(channelHandlerContext, connectPacket); + Objects.requireNonNull(chanel).writeAndFlush(new TextWebSocketFrame(buff)); + System.out.println("发送私聊消息"); } + ByteBuf getBuff(ChannelHandlerContext channelHandlerContext, AutoSoftwarePacket autoSoftwarePacket) { + ByteBuf byteBuf = channelHandlerContext.alloc().buffer(); + byte[] bytes = JSONObject.toJSONString(autoSoftwarePacket).getBytes(StandardCharsets.UTF_8); + byteBuf.writeBytes(bytes); + return byteBuf; + } + } diff --git a/src/main/java/com/realtime/packets/server/handler/PrivateMessageHandler.java b/src/main/java/com/realtime/packets/server/handler/PrivateMessageHandler.java index e6d247a..a5696bf 100644 --- a/src/main/java/com/realtime/packets/server/handler/PrivateMessageHandler.java +++ b/src/main/java/com/realtime/packets/server/handler/PrivateMessageHandler.java @@ -39,7 +39,6 @@ public class PrivateMessageHandler extends SimpleChannelInboundHandler