基本结构

<modules>
        <!-- 基础包-->
        <module>common</module>
        <!-- 核心包 依赖common-->
        <module>core</module>
        <!--服务端 依赖core-->
        <module>server</module>
        <!--客户端 依赖core -->
        <module>client</module>
    </modules>

public class MyServerInitailizer extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel socketChannel) throws Exception {
        ChannelPipeline channelPipeline= socketChannel.pipeline();
        channelPipeline.addLast(new HttpServerCodec());
        channelPipeline.addLast(new ChunkedWriteHandler());
        channelPipeline.addLast(new HttpObjectAggregator(8192));
        channelPipeline.addLast(new WebSocketServerProtocolHandler("/ws"));
        channelPipeline.addLast(new CommandHander());// 核心处理类
    }
}

@CliHander(command = "HDEL")
public class HDELcli extends AbstractCli {
    @Override
    public void executeCli(ChannelHandlerContext channelHandlerContext, String command) {

        List<String> values = getValues(command);
        if (values.size() < 3) {
            channelHandlerContext.channel().writeAndFlush(new TextWebSocketFrame("ERR wrong number of arguments for 'HDEL' command"));
        }
        int db = ConnectData.SELECT_DB_STORAGE.getUseDB(channelHandlerContext.channel().id().asLongText());
        Value<Map<String, String>> hashData = SystemConfig.dbData.getHashData(db, values.get(0));
        StringBuilder msg = new StringBuilder();
        for (int i = 2; i < values.size(); i++) {
            String result = hashData.getValue().remove(values.get(i));
            if (result == null) {
                msg.append("0\r\n");
            } else {
                msg.append("1\r\n");
            }
        }
        channelHandlerContext.channel().writeAndFlush(new TextWebSocketFrame(msg.toString()));

    }
}