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

avatar
作者
筋斗云
阅读量:2

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

自我介绍一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。

深知大多数初中级Android工程师,想要提升技能,往往是自己摸索成长或者是报班学习,但对于培训机构动则近万的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!

因此收集整理了一份《2024年Android移动开发全套学习资料》,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友,同时减轻大家的负担。

img

img

img

img

既有适合小白学习的零基础资料,也有适合3年以上经验的小伙伴深入学习提升的进阶课程,基本涵盖了95%以上Android开发知识点,真正体系化!

由于文件比较大,这里只是将部分目录截图出来,每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频,并且会持续更新!

如果你觉得这些内容对你有帮助,可以扫码获取!!(备注:Android)

最后

分享一份工作1到5年以上的Android程序员架构进阶学习路线体系,希望能对那些还在从事Android开发却还不知道如何去提升自己的,还处于迷茫的朋友!

  • 阿里P7级Android架构师技术脑图;查漏补缺,体系化深入学习提升

  • **全套体系化高级架构视频;**七大主流技术模块,视频+源码+笔记

有任何问题,欢迎广大网友一起来交流

《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取!

yZMzOf-1713397903963)]

  • **全套体系化高级架构视频;**七大主流技术模块,视频+源码+笔记

[外链图片转存中…(img-kP9syxYB-1713397903963)]

有任何问题,欢迎广大网友一起来交流

《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取!

广告一刻

为您即时展示最新活动产品广告消息,让您随时掌握产品活动新动态!