Netty客户端发送数据给服务器的两个通道(1)

服务器 0

import io.netty.channel.Channel;

import io.netty.channel.ChannelFuture;

import io.netty.channel.ChannelFutureListener;

import io.netty.channel.ChannelHandlerAdapter;

import io.netty.channel.ChannelHandlerContext;

import io.netty.channel.ChannelInitializer;

import io.netty.channel.ChannelOption;

import io.netty.channel.EventLoopGroup;

import io.netty.channel.nio.NioEventLoopGroup;

import io.netty.channel.socket.SocketChannel;

import io.netty.channel.socket.nio.NioSocketChannel;

import io.netty.handler.codec.json.JsonObjectDecoder;

import io.netty.handler.codec.string.StringDecoder;

import io.netty.handler.codec.string.StringEncoder;

import io.netty.util.CharsetUtil;

public class App {

private int SERVER_PORT = 20000;

public App() throws Exception {

new Server().start();

connectServer();

}

// Netty作为客户端,发起对服务器端的连接请求。

private void connectServer() {

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);

文末

初级工程师拿到需求会直接开始做,然后做着做着发现有问题了,要么技术实现不了,要么逻辑有问题。

而高级工程师拿到需求会考虑很多,技术的可行性?对现有业务有没有帮助?对现有技术架构的影响?扩展性如何?等等…之后才会再进行设计编码阶段。

而现在随着跨平台开发,混合式开发,前端开发之类的热门,Android开发者需要学习和掌握的技术也在不断的增加。

通过和一些行业里的朋友交流讨论,以及参考现在大厂面试的要求。我们花了差不多一个月时间整理出了这份Android高级工程师需要掌握的所有知识体系。你可以看下掌握了多少。

混合式开发,微信小程序。都是得学会并且熟练的

这些是Android相关技术的内核,还有Java进阶

高级进阶必备的一些技术。像移动开发架构项目实战等

Android前沿技术;包括了组件化,热升级和热修复,以及各种架构跟框架的详细技术体系

以上即是我们整理的Android高级工程师需要掌握的技术体系了。可能很多朋友觉得很多技术自己都会了,只是一些新的技术不清楚而已。应该没什么太大的问题。

而这恰恰是问题所在!为什么别人高级工程师能年限突破30万,而你只有十几万呢?

就因为你只需补充你自己认为需要的,但并不知道企业需要的。这个就特别容易造成差距。因为你的技术体系并不系统,是零碎的,散乱的。那么你凭什么突破30万年薪呢?

我这些话比较直接,可能会戳到一些人的玻璃心,但是我知道肯定会对一些人起到点醒的效果的。而但凡只要有人因为我的这份高级系统大纲以及这些话找到了方向,并且付出行动去提升自我,为了成功变得更加努力。那么我做的这些就都有了意义。

喜欢的话请帮忙转发点赞一下能让更多有需要的人看到吧。谢谢!

《Android学习笔记总结+移动架构视频+大厂面试真题+项目实战源码》点击传送门,即可获取!
我这些话比较直接,可能会戳到一些人的玻璃心,但是我知道肯定会对一些人起到点醒的效果的。而但凡只要有人因为我的这份高级系统大纲以及这些话找到了方向,并且付出行动去提升自我,为了成功变得更加努力。那么我做的这些就都有了意义。

喜欢的话请帮忙转发点赞一下能让更多有需要的人看到吧。谢谢!

《Android学习笔记总结+移动架构视频+大厂面试真题+项目实战源码》点击传送门,即可获取!

也许您对下面的内容还感兴趣: