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