一、前置说明

  本文实现思路和代码参考:

闪电侠-Netty 入门与实战：仿写微信 IM 即时通讯系统
闪电侠-Github代码源码

二、Netty主要知识点

2.1 ChannelHandler生命周期

图2-1 ChannelHandler生命周期.png

2.2 Handler、Option、Attr

  ServerBootStrap.option参数适用于正在侦听连接的服务器套接字(服务器通道)，ServerBootStrap.childOption参数适用于在服务器套接字接受连接后创建的套接字。

Netty：option和childOption参数设置说明

2.3 writeAndFlush方法

  ctx(ChannelHandlerContext)的writeAndFlush是从当前handler直接发出这个消息，而channel的writeAndFlush是从整个pipline最后一个outhandler发出。

2.4 粘包/拆包(半包)

  粘包/拆包图示如下所示：

图2.2 粘包/拆包.png

  接收端收到的第一个包，正常。
  接收端收到的第二个包，就是一个粘包。 将发送端的第二个包、第三个包，粘在一起了。
  接收端收到的第三个包，第四个包，就是半包。将发送端的的第四个包，分开成了两个了。

Netty 粘包/半包原理与拆包实战（史上最全）

三、客户端单聊实现思路

图3-1 客户端单聊流程图.png

图3-2 指令图示.png

图片来源-闪电侠-Netty 入门与实战：仿写微信 IM 即时通讯系统
小闪对话：微信聊天长连设计的探讨（一）

  指令列表如下所示：

四、客户端单聊实现

4.1 通信协议设计(ByteBuf)

4.2 部分代码讲解

  详细代码请参考:

Github源码-客户端互聊

//指定魔数
public static final int MAGIC_NUMBER = 0x12345678;
//指令-数据Map
private static final Map<Byte, Class<? extends Packet>> packetTypeMap;
//序列化算法Map
private static final Map<Byte, Serializer> serializerMap;

static {
    packetTypeMap = new HashMap<>();
    packetTypeMap.put(Command.LOGIN_REQUEST, LoginRequestPacket.class);
    packetTypeMap.put(Command.LOGIN_RESPONSE, LoginResponsePacket.class);
    packetTypeMap.put(Command.MESSAGE_REQUEST, MessageRequestPacket.class);
    packetTypeMap.put(Command.MESSAGE_RESPONSE, MessageResponsePacket.class);

    serializerMap = new HashMap<>();
    Serializer serializer = new JSONSerializer();
    serializerMap.put(serializer.getSerializerMethod(), serializer);
}

/**
 * userID ---- Channel 对应
 */
private static final Map<String,Channel> userIdChannelMap = new ConcurrentHashMap<>();

public static void bindSession(Session session,Channel channel){
    userIdChannelMap.put(session.getUserId(),channel);
    //设置channel attr属性
    channel.attr(ProtocolAttributes.SESSION).set(session);
}

public static void unBindSession(Channel channel){
    if (hasLogin(channel)){
        userIdChannelMap.remove(getSession(channel).getUserId());
        channel.attr(ProtocolAttributes.SESSION).set(null);
    }
}

五、功能测试

  先启动NettyServer服务端，再启动NettyClient和NettyClient2客户端。客户端输入用户名返回服务端生成的用户ID。

图5-1 客户端NettyClient登录.png

图5-2 客户端NettyClient2登录.png

图5-3 服务端NettyServer响应客户端登录.png

  客户端NettyClient输入用户world用户ID，空格后输入消息内容。

图5-4 客户端NettyClient发送消息.png

图5-5 客户端NettyClient2接收消息.png