EventLoopGroup group = new NioEventLoopGroup();
Bootstrap bootstrap = new Bootstrap()
.group(group)
.channel(NioSocketChannel.class)
.remoteAddress(address, port)
.handler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) {
ch.pipeline().addLast(
new RedisMessageEncoder(),
new RedisMessageDecoder(),
new RedisClientHandler()
);
}
});
Channel channel = bootstrap.connect().sync().channel();
RedisRequest request = new RedisRequest(Command.SET, key, value);
channel.writeAndFlush(request);
public class RedisClientHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
RedisResponse response = (RedisResponse) msg;
}
}
