ANetty for Android 是基于Netty二次封装的Android链路通讯库,用以快速开发高性能,高可靠性的网络交互。在保证易于开发的同时还保证其应用的性能,稳定性和伸缩性。
<dependency>
<groupId>com.king.anetty</groupId>
<artifactId>anetty</artifactId>
<version>1.0.3</version>
<type>pom</type>
</dependency>
implementation 'com.king.anetty:anetty:1.0.3'
<dependency org='com.king.anetty' name='anetty' rev='1.0.3'>
<artifact name='$AID' ext='pom'></artifact>
</dependency>
allprojects {
repositories {
maven { url 'https://dl.bintray.com/jenly/maven' }
}
}
代码示例
ANetty暂并不提供Netty服务端封装库,因为在真实的场景中,服务端一般都依赖项目对应的业务。为了方便演示客户端效果,有个简易的服务端demo,直接以Java的形式直接运行ANettyServer即可启动Netty服务
Netty服务端:
//初始化并启动服务
new ANettyServer().start(String host,int port);
Netty客户端:
//初始化Netty
mNetty = new ANetty(new Netty.OnChannelHandler() {
@Override
public void onMessageReceived(ChannelHandlerContext ctx,String msg) {
//TODO 接收到消息
}
@Override
public void onExceptionCaught(ChannelHandlerContext ctx,Throwable e) {
}
}, true);
//设置连接监听
mNetty.setOnConnectListener(new Netty.OnConnectListener() {
@Override
public void onSuccess() {
//TODO 连接成功
}
@Override
public void onFailed() {
//TODO 连接失败
}
@Override
public void onError(Exception e) {
//TODO 连接异常
Log.e(ANetty.TAG,e.getMessage());
}
});
//设置发送消息监听
mNetty.setOnSendMessageListener(new Netty.OnSendMessageListener() {
@Override
public void onSendMessage(Object msg, boolean success) {
//TODO 发送消息,根据success判断是否发送成功
}
@Override
public void onException(Throwable e) {
//TODO 异常
}
});
//初始化后,连接Netty
mNetty.connect(String host,int port);
更多使用详情,请查看app中的源码使用示例
EasyChat 一款即时通讯APP
- OnChannelHandler接口内方法新增ChannelHandlerContext参数
- 新增setOnSendMessageListener方法
- 更新Netty依赖至4.1.43.Final
- 移除support依赖
- 更新Netty依赖至4.1.42.Final
- ANetty初始版本
如果您喜欢ANetty,或感觉ANetty帮助到了您,可以点右上角“Star”支持一下,您的支持就是我的动力,谢谢 😃
您也可以扫描下面的二维码,请作者喝杯咖啡 ☕
Name: Jenly
Email: jenly1314#gmail.com / jenly1314#vip.qq.com
CSDN: jenly121
博客园: jenly
Github: jenly1314
加入QQ群: 20867961