Spring Boot+Netty+Websocket实现后台向前端推送信息

学过 Netty 的都知道，Netty 对 NIO 进行了很好的封装，简单的 API，庞大的开源社区。深受广大程序员喜爱。基于此本文分享一下基础的 netty 使用。实战制作一个 Netty + websocket 的消息推送小栗子。

netty服务器

public interface PushMsgService {
    /***推送给指定用户*/
    void pushMsgToOne(String userId, String msg);

    /***推送给所有用户*/
    void pushMsgToAll(String msg);
}

@Service
public class PushMsgServiceImplimplementsPushMsgService {
    @Override
    public void pushMsgToOne(String userId, String msg) {
        Channelchannel = NettyConfig.getChannel(userId);
        if (Objects.isNull(channel)) {
            thrownewRuntimeException("未连接socket服务器");
        }
        channel.writeAndFlush(newTextWebSocketFrame(msg));
    }

    @Override
    public void pushMsgToAll(String msg) {
        NettyConfig.getChannelGroup().writeAndFlush(newTextWebSocketFrame(msg));
    }
}