EventLoopGroup group = new NioEventLoopGroup();// 设置的连接group。
Bootstrap bootstrap = new Bootstrap().group(group).option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000) // 超时时间。
.channel(NioSocketChannel.class).handler(new ChannelInitializer() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(new JsonObjectDecoder());
ch.pipeline().addLast(new StringEncoder(CharsetUtil.UTF_8));// String解码。
ch.pipeline().addLast(new StringDecoder(CharsetUtil.UTF_8));// String解码。
ch.pipeline().addLast(new MyChannelHandlerAdapter());//
}
});
try {
System.out.println(“客户端连接服务器…”);
ChannelFuture channelFuture = bootstrap.connect(“127.0.0.1”, SERVER_PORT)
.addListener(new ChannelFutureListener() {
public void operationComplete(ChannelFuture future) throws Exception {
if (future.isSuccess()) {
// 第一种方法。
// Netty在这里发送数据。
// sendDataToServer(future.channel());
}
}
}).sync();
// 等待连接关闭。
channelFuture.channel().closeFuture().sync();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
-
发送数据到服务器端。
-
@throws Exception
*/
private void sendDataToServer(Channel channel) throws Exception {
Date date = new Date(System.currentTimeMillis());
SimpleDateFormat sdf = new SimpleDateFormat(“MM-dd,HH:mm:ss:SSS”);
while (true) {
date.setTime(System.currentTimeMillis());
channel.writeAndFlush(“客户端@” + sdf.format(date));
System.out.println(“客户端发送数据:” + sdf.format(date));
Thread.sleep(1000);
}
}
private class MyChannelHandlerAdapter extends ChannelHandlerAdapter {
// 连接激活。
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
super.channelActive(ctx);
System.out.println(“channelActive:” + ctx.channel().remoteAddress());
// 第二种方法。
// 连接可用激活后，Netty开始往服务器端发送数据。
sendDataToServer(ctx.channel());
}
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
super.channelInactive(ctx);
System.out.println(“channelInactive:” + ctx.channel().remoteAddress());
}
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
super.channelRead(ctx, msg);
}
@Override
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
super.channelReadComplete(ctx);
System.out.println(ctx.channel().remoteAddress() + “读写完成”);
}
}
public static void main(String[] args) {
try {
new App();
} catch (Exception e) {
e.printStackTrace();
}
}
// 服务器端。演示作为服务器接受来自客户端的数据。
private class Server extends Thread {
private ServerSocket serverSocket;
public Server() throws Exception {
serverSocket = new ServerSocket(SERVER_PORT);
}
@Override
public void run() {
自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。
深知大多数初中级Android工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则近万的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！
因此收集整理了一份《2024年Android移动开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。
既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Android开发知识点，真正体系化！
由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！
如果你觉得这些内容对你有帮助，可以扫码获取！！（备注：Android）
如何成为Android高级架构师！
架构师必须具备抽象思维和分析的能力，这是你进行系统分析和系统分解的基本素质。只有具备这样的能力，架构师才能看清系统的整体，掌控全局，这也是架构师大局观的形成基础。 你如何具备这种能力呢？一是来自于经验，二是来自于学习。
架构师不仅要具备在问题领域上的经验，也需要具备在软件工程领域内的经验。也就是说，架构师必须能够准确得理解需求，然后用软件工程的思想，把需求转化和分解成可用计算机语言实现的程度。经验的积累是需要一个时间过程的，这个过程谁也帮不了你，是需要你去经历的。
但是，如果你有意识地去培养，不断吸取前人的经验的话，还是可以缩短这个周期的。这也是我整理架构师进阶此系列的始动力之一。
成为Android架构师必备知识技能
对应导图的学习笔记(由阿里P8大牛手写，我负责整理成PDF笔记）
部分内容展示
《设计思想解读开源框架》
-
目录
-
热修复设计
-
插件化框架设计
《360°全方面性能优化》
-
设计思想与代码质量优化
-
程序性能优化
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！文章来源地址https://www.toymoban.com/news/detail-851405.html
-1712667244968)]文章来源：https://www.toymoban.com/news/detail-851405.html
-
设计思想与代码质量优化
[外链图片转存中…(img-rbdAo7CG-1712667244968)] -
程序性能优化
[外链图片转存中…(img-OUJWWXgo-1712667244968)]
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！
到了这里，关于Netty客户端发送数据给服务器的两个通道(1)的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
