知识原理还是依旧可以使用滴。

我理解这应该是netty 开发之处，作者设计如此的原因。

从本质上讲，我理解因为异步非阻塞的效率更高。

这是你要的图

就照着代码读了一遍，跟没讲一样

创建项目又不是非得固定一种方式。

ws地址对吗

实现类有些问题吧

channelGroup是自己定义的一个用来存在channel的变量，需要自己维护。

<dependency>

    <groupId>io.netty</groupId>

    <artifactId>netty</artifactId>

    <version>3.10.5.Final</version>

</dependency>

就是连接传递信息的

我遇到过一次是因为线程溢出，连接创建后执行完业务逻辑没有断开，导致一直在创建连接，最后线程溢出，创建连接要伴随断开连接，这是我遇到的问题希望对你有所帮助

类的关系： frame是个 WebSocketFrame 
public abstract class WebSocketFrame extends DefaultByteBufHolder 

而WebSocketFrame 实现：
public class DefaultByteBufHolder implements ByteBufHolder {
    private final ByteBuf data;

    public DefaultByteBufHolder(ByteBuf data) {
        if (data == null) {
            throw new NullPointerException("data");
        } else {
            this.data = data;
        }
    }

    public ByteBuf content() {
        if (this.data.refCnt() <= 0) {
            throw new IllegalReferenceCountException(this.data.refCnt());
        } else {
            return this.data;
        }
    }

    public ByteBufHolder copy() {
        return new DefaultByteBufHolder(this.data.copy());
    }

    public ByteBufHolder duplicate() {
        return new DefaultByteBufHolder(this.data.duplicate());
    }

    public int refCnt() {
        return this.data.refCnt();
    }

    public ByteBufHolder retain() {
        this.data.retain();
        return this;
    }

    public ByteBufHolder retain(int increment) {
        this.data.retain(increment);
        return this;
    }

    public boolean release() {
        return this.data.release();
    }

    public boolean release(int decrement) {
        return this.data.release(decrement);
    }

    public String toString() {
        return StringUtil.simpleClassName(this) + '(' + this.content().toString() + ')';
    }
}

前一次回答里2个类名标注了粗体字，不知何故类名都不见了。

这里需要用到redis的消息发布和订阅。当客户端A和服务器1建立netty连接时，根据当前连接的管道名称进行redis消息订阅，假设客户端A和服务器1之间的管道名称为A1。当客户端B连接到服务器2又想与服务器1通信时，客户端B可以根据A1向redis发布消息，因为在这之前服务器1已经消息订阅了A1，这样服务器1就可以接收到客户端B的消息。

我也遇到了，你解决了吗

这里设置的呗，只支持TextWebSocketFrame

很确定，是可以用的。我在公司的项目就用到了

把你的代码粘贴出来 ，

刚开始的WS请求是封装在HTTP里的，HTTP头部包含Upgrade:websocket。必须处理此HTTP请求

ws://localhost:8888/websocket

少了一个冒号

netty每次换程序时都需要手动把进程kill，不然就会报错

private void sendHttpResponse(ChannelHandlerContext ctx, FullHttpRequest req,
                              DefaultFullHttpResponse res) {
    if (res.status().code() != 200) {
        ByteBuf buf = Unpooled.copiedBuffer(res.status().toString(), CharsetUtil.UTF_8);
        res.content().writeBytes(buf);
        buf.release();
    }
    //服务端向客户端发送数据
    ChannelFuture f = ctx.channel().writeAndFlush(res);
    if (res.status().code() != 200) {
        f.addListener(ChannelFutureListener.CLOSE);
    }
}

使用decoderResult就好了

netty5 基于aio，异步非阻塞，但是后来有bug撤回了

我也遇到这个问题了，只能在linux上跑？

这是原来的代码,这个讲师代码少抄了