博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Netty-5-客户端的创建并且接受服务端的数据
阅读量:4304 次
发布时间:2019-05-27

本文共 1497 字,大约阅读时间需要 4 分钟。

下面的示例内容是创建了两个客户端,以NetAssist作为服务端,服务端向哪个客户端发信息,哪个客户端就把自己的IP地址返回给服务端

1.首先创建一个InboundHandler,来处理输入进来的信息

public class MyClientHandler1 extends ChannelInboundHandlerAdapter {	@Override	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {		ByteBuf bb = (ByteBuf) msg;		int len = bb.readableBytes();		byte[] bytes = new byte[len];		bb.readBytes(bytes);		System.out.println("读到的内容:" + new String(bytes, "utf-8"));		String result = ctx.channel().localAddress().toString();		ByteBuf rr = Unpooled.copiedBuffer(result.getBytes());		ctx.writeAndFlush(rr);	}}

2.创建一个客户端,启动main方法

public class TestClient1 {	public static void main(String[] args) throws InterruptedException {		EventLoopGroup group = new NioEventLoopGroup();		Bootstrap b = new Bootstrap();		b.group(group).channel(NioSocketChannel.class).handler(new MyClientHandler1());		ChannelFuture f = b.connect("127.0.0.1", 9999).sync();		f.channel().closeFuture().sync();	}}

3.再创建一个客户端,也启动main方法

public class TestClient2 {	public static void main(String[] args) throws InterruptedException {		EventLoopGroup group = new NioEventLoopGroup();		Bootstrap b = new Bootstrap();		b.group(group).channel(NioSocketChannel.class).handler(new MyClientHandler1());		ChannelFuture f = b.connect("127.0.0.1", 9999).sync();		f.channel().closeFuture().sync();	}}

使用网络助手作为服务端进行调试,将客户端选择1图所示,点击发送,会返回1图连接的客户端地址,客户端选择2图所示,点击发送,会返回2图连接的客户端地址

在这里插入图片描述
其实和之前的文章没什么太大区别,只不过这是客户端,之前的是服务端,值得一提的是文章并没有演示客户端连接服务端的时候,客户端先发送到服务端,因为和之前的文章是一样的,可以直接从active方法中进行这一操作

转载地址:http://svhws.baihongyu.com/

你可能感兴趣的文章
suse创建的虚拟机,修改ip地址
查看>>
linux的挂载的问题,重启后就挂载就没有了
查看>>
docker原始镜像启动容器并创建Apache服务器实现反向代理
查看>>
docker容器秒死的解决办法
查看>>
管理网&业务网的一些笔记
查看>>
openstack报错解决一
查看>>
openstack报错解决二
查看>>
linux source命令
查看>>
openstack报错解决三
查看>>
乙未年年终总结
查看>>
子网掩码
查看>>
第一天上班没精神
查看>>
启动eclipse报错:Failed to load the JNI shared library
查看>>
eclipse安装插件的两种方式在线和离线
查看>>
linux下源的相关笔记(suse)
查看>>
linux系统分区文件系统划分札记
查看>>
Linux(SUSE 12)安装Tomcat
查看>>
Linux(SUSE 12)安装jboss4并实现远程访问
查看>>
Neutron在给虚拟机分配网络时,底层是如何实现的?
查看>>
netfilter/iptables全攻略
查看>>