netty Client 多IP about netty-4-user-guide-demos HOT 1 CLOSED

EventLoopGroup workerGroup = new NioEventLoopGroup();

		try {
			Bootstrap b = new Bootstrap();
			b.group(workerGroup);
			b.channel(NioSocketChannel.class);
			b.option(ChannelOption.SO_KEEPALIVE, true);
			b.handler(new ChannelInitializer<SocketChannel>() {
				@Override
				public void initChannel(SocketChannel ch) throws Exception {
					ch.pipeline().addLast("decoder", new MyDecoder());
					ch.pipeline().addLast("encoder", new MyEncoder());
					ch.pipeline().addLast(new MyClientHandler());

				}
			});

			Bootstrap b2 = new Bootstrap();
			b2.group(workerGroup);
			b2.channel(NioSocketChannel.class);
			b2.option(ChannelOption.SO_KEEPALIVE, true);
			b2.handler(new ChannelInitializer<SocketChannel>() {
				@Override
				public void initChannel(SocketChannel ch) throws Exception {
					ch.pipeline().addLast("decoder", new MyDecoder());
					ch.pipeline().addLast("encoder", new MyEncoder());
					ch.pipeline().addLast(new MyClientHandler());

				}
			});
			// 启动客户端
			ChannelFuture f = b2.connect(host, port).sync();
			ChannelFuture f2 = b2.connect(host, port).sync();

			while (true) {

				// 发送消息给服务器
				Msg msg = new Msg();
				MsgHeader msgHeader = new MsgHeader();
				msgHeader.setMsgType(MsgType.EMGW_LOGIN_REQ.getValue());
				String body = "床前明月光，疑是地上霜。举头望明月，低头思故乡。";

				byte[] bodyBytes = body.getBytes(Charset.forName("utf-8"));
				int bodySize = bodyBytes.length;
				msgHeader.setLen(bodySize);
				msg.setMsgHeader(msgHeader);
				msg.setBody(body);

				f.channel().writeAndFlush(msg);
				f2.channel().writeAndFlush(msg);
				Thread.sleep(2000);
			}
		} finally {
			workerGroup.shutdownGracefully();
		}