42 lines
1.6 KiB
Java
42 lines
1.6 KiB
Java
package cn.itcast.client;
|
|
|
|
import cn.itcast.protocol.MessageCodecSharable;
|
|
import cn.itcast.protocol.ProcotolFrameDecoder;
|
|
import io.netty.bootstrap.Bootstrap;
|
|
import io.netty.channel.Channel;
|
|
import io.netty.channel.ChannelInitializer;
|
|
import io.netty.channel.nio.NioEventLoopGroup;
|
|
import io.netty.channel.socket.SocketChannel;
|
|
import io.netty.channel.socket.nio.NioSocketChannel;
|
|
import io.netty.handler.logging.LogLevel;
|
|
import io.netty.handler.logging.LoggingHandler;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
@Slf4j
|
|
public class ChatClient {
|
|
public static void main(String[] args) {
|
|
NioEventLoopGroup group = new NioEventLoopGroup();
|
|
LoggingHandler LOGGING_HANDLER = new LoggingHandler(LogLevel.DEBUG);
|
|
MessageCodecSharable MESSAGE_CODEC = new MessageCodecSharable();
|
|
try {
|
|
Bootstrap bootstrap = new Bootstrap();
|
|
bootstrap.channel(NioSocketChannel.class);
|
|
bootstrap.group(group);
|
|
bootstrap.handler(new ChannelInitializer<SocketChannel>() {
|
|
@Override
|
|
protected void initChannel(SocketChannel ch) throws Exception {
|
|
ch.pipeline().addLast(new ProcotolFrameDecoder());
|
|
ch.pipeline().addLast(LOGGING_HANDLER);
|
|
ch.pipeline().addLast(MESSAGE_CODEC);
|
|
}
|
|
});
|
|
Channel channel = bootstrap.connect("localhost", 9020).sync().channel();
|
|
channel.closeFuture().sync();
|
|
} catch (Exception e) {
|
|
// log.error("client error", e);
|
|
} finally {
|
|
group.shutdownGracefully();
|
|
}
|
|
}
|
|
}
|