Android kotlin使用Netty网络框架实践（客户端、服务端）

2024-09-03 08:28
文章标签 android 使用 实践 服务端 框架 客户端 网络 kotlin netty

本文主要是介绍Android kotlin使用Netty网络框架实践（客户端、服务端），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

开发工具：Android studio 

语言:kotlin

设计原理：通讯协议：头+类型+长度+数据+尾，自定义编解码器，解析和包装发送数据流，以下贴出部分关键代码

说明：代码中封装了client和server端，可以点击按钮进行通讯，可以直接在项目中使用，尤其是处理了粘包和分包问题。

编译后的效果图:

注：结尾附上完整代码下载链接

1、配置build.gradle文件

 implementation("io.netty:netty-all:5.0.0.Alpha2")

2、主要代码

2.1 server端主要代码
    /*** 启动服务端*/fun start() {Executors.newSingleThreadScheduledExecutor().submit {XLogUtil.d( "********服务启动********")bossGroup =NioEventLoopGroup()workerGroup = NioEventLoopGroup()try {val channelInit = ChannelInitServer(serverManager)val serverBootstrap = ServerBootstrap()serverBootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel::class.java)//线程组设置为非阻塞.childHandler(channelInit).option(ChannelOption.SO_BACKLOG, 128)//连接缓冲池的大小.option(ChannelOption.TCP_NODELAY, true).option(ChannelOption.SO_KEEPALIVE, false)//设置长连接channelFuture = serverBootstrap.bind(Constant.SERVICE_POSR)channel = channelFuture?.channel()channelFuture!!.addListener { future: Future<in Void> ->if (future.isSuccess) {//服务启动成功XLogUtil.d("********服务启动成功********")MessageHandler.sendMessage(MessageType.SERVER_START_SUCCESS,"服务启动成功")} else {//服务启动失败XLogUtil.e("********服务启动失败********")MessageHandler.sendMessage(MessageType.SERVER_START_FAILED,"服务启动失败")}}} catch (e: Exception) {e.printStackTrace()XLogUtil.e( "NettyServer 服务异常:"+e.message)} finally {}}}
2.2 client端主要代码
    /*** 启动客户端*/fun start() {Executors.newSingleThreadScheduledExecutor().submit {XLogUtil.d("***********启动客户端***********")val group: EventLoopGroup = NioEventLoopGroup()try {val channelInit = ChannelInitClient(clientManager)val bootstrap = Bootstrap()bootstrap.group(group).channel(NioSocketChannel::class.java).remoteAddress(InetSocketAddress(address, port)).handler(channelInit).option(ChannelOption.TCP_NODELAY, true).option(ChannelOption.SO_KEEPALIVE, false)val channelFuture = bootstrap.connect().sync()channel = channelFuture.channel()channelFuture!!.addListener { future: Future<in Void> ->if (future.isSuccess) {//绑定成功XLogUtil.d("***********客户端连接成功***********")MessageHandler.sendMessage(MessageType.CLIENT_CONNECT_SUCCESS,"客户端连接成功")} else {//绑定失败XLogUtil.d("***********客户端连接失败***********")MessageHandler.sendMessage(MessageType.CLIENT_CONNECT_FAILED,"客户端连接失败")}}channel!!.closeFuture().sync()XLogUtil.d("***********客户端关闭成功***********")MessageHandler.sendMessage(MessageType.CLIENT_CLOSE_SUCCESS,"客户端关闭成功")} catch (e: Exception) {e.printStackTrace()MessageHandler.sendMessage(MessageType.CLIENT_EXCEPTION,"客户端异常：" + e.message)XLogUtil.e("NettyClient 客户端异常:" + e.message)} finally {try {group.shutdownGracefully().sync()} catch (e: InterruptedException) {e.printStackTrace()MessageHandler.sendMessage(MessageType.CLIENT_EXCEPTION,"客户端异常2：" + e.message)XLogUtil.e("NettyClient 客户端异常2:" + e.message)}}}}
 2.3 Server端线程
ChannelInitServer.kt
服务端数据收发线程
class ChannelInitServer internal constructor(adapter: MyServerHandler) :ChannelInitializer<SocketChannel?>() {private val adapter: MyServerHandlerinit {this.adapter = adapter}override fun initChannel(ch: SocketChannel?) {try {val channelPipeline: ChannelPipeline = ch!!.pipeline()//添加心跳机制，例：每3000ms发送一次心跳//channelPipeline.addLast(IdleStateHandler(3000, 3000, 3000, TimeUnit.MILLISECONDS))//添加数据处理（接收、发送、心跳）//FrameCodec 中处理粘包分包问题channelPipeline.addLast(FrameCodec())channelPipeline.addLast(adapter)} catch (e: Exception) {e.printStackTrace()}}
}
2.4 client 端线程
客户端数据收发线程
class ChannelInitClient internal constructor(adapter: MyClientHandler) :ChannelInitializer<Channel?>() {private val adapter: MyClientHandlerinit {this.adapter = adapter}override fun initChannel(ch: Channel?) {try {if (ch == null) {XLogUtil.e("ChannelInitClient Channel==null,initChannel fail")}val channelPipeline: ChannelPipeline = ch!!.pipeline()//添加心跳机制，例：每3000ms发送一次心跳// channelPipeline.addLast(IdleStateHandler(3000, 3000, 3000, TimeUnit.MILLISECONDS))//自定义编解码器，处理粘包分包问题channelPipeline.addLast(FrameCodec())//添加数据处理channelPipeline.addLast(adapter)} catch (e: Exception) {e.printStackTrace()}}
}
2.5 在Activity文件中调用
package com.android.agentimport android.annotation.SuppressLint
import android.content.Intent
import android.os.Build
import android.os.Bundle
import android.os.Environment
import android.os.Handler
import android.os.Message
import android.provider.Settings
import android.widget.Button
import android.widget.TextView
import androidx.appcompat.app.AppCompatActivity
import com.alibaba.fastjson.JSON
import com.android.agent.netty.NettyClient
import com.android.agent.netty.NettyServer
import com.android.agent.netty.message.MessageSend
import com.android.agent.netty.message.SettingIp
import com.android.agent.utils.Constant
import com.android.agent.xlog.XLogUtil
import com.android.agent.Rclass MainActivity : AppCompatActivity() {private var isTestServer = falseprivate var isTestClient = falseprivate var client: NettyClient? = nullprivate var server: NettyServer? = nullprivate var result = ""private var tvResult: TextView? = null@SuppressLint("MissingInflatedId")override fun onCreate(savedInstanceState: Bundle?) {super.onCreate(savedInstanceState)setContentView(R.layout.activity_main)if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.R) {if (!Environment.isExternalStorageManager()) {val intent = Intent(Settings.ACTION_MANAGE_ALL_FILES_ACCESS_PERMISSION);startActivity(intent);return;}}XLogUtil.d(">>>>>>>>>>welcome to  AndroidGif")tvResult = findViewById<TextView>(R.id.tv_text)findViewById<Button>(R.id.btnTestClient).setOnClickListener {XLogUtil.d(">>>>>>>>>>btnTestClient OnClick 启动"+!isTestClient)if (!isTestClient) {result = "";testNettyClient();} else {stopNettyClient();}isTestClient = !isTestClient;}findViewById<Button>(R.id.btnTestServer).setOnClickListener {XLogUtil.d(">>>>>>>>>>btnTestServer OnClicks 启动:"+!isTestServer)if (!isTestServer) {result = "";testNettyServer();} else {stopNettyServer();}isTestServer = !isTestServer;}findViewById<Button>(R.id.btnClientSend).setOnClickListener {client?.apply {XLogUtil.d("btnClientSend data")var setIp= SettingIp("192.168.11.185","192.168.11.1","255.255.255.0","8.8.8.8")var sendMsg= MessageSend("xxxxxxxxxxxx",3000,JSON.toJSONString(setIp))sentData(JSON.toJSONString(sendMsg),0x30) //charset("GBK")}}}private fun testNettyClient() {client = NettyClient(Constant.SERVICE_IP, Constant.SERVICE_POSR)
//        client.addHeartBeat(object : HeartBeatListener {
//            override fun getHeartBeat(): ByteArray {
//                val data = "心跳"
//                try {
//                    client.sentData("测试数据".toByteArray(charset("GBK")))
//                    return data.toByteArray(charset("GBK"))
//                } catch (e: UnsupportedEncodingException) {
//                    e.printStackTrace()
//                }
//                return "".toByteArray()
//            }
//        })client!!.setHandler(handler)client!!.start()}private fun stopNettyClient() {client?.apply {stop()}}private fun testNettyServer() {server = NettyServer.getInstance()server?.apply {
//            addHeartBeat(object : HeartBeatListener {
//                override fun getHeartBeat(): ByteArray {
//                    val data = "心跳"
//                    try {
//                        sentData("123".toByteArray(Charsets.UTF_8))//GBK
//                        return data.toByteArray(Charsets.UTF_8)
//                    } catch (e: UnsupportedEncodingException) {
//                        e.printStackTrace()
//                    }
//                    return "".toByteArray()
//                }
//            })setHandler(handler)start()}}private fun stopNettyServer() {server?.apply {stop()}}@SuppressLint("HandlerLeak")private val handler: Handler = object : Handler() {override fun handleMessage(msg: Message) {XLogUtil.d("收到信息:::" + msg.obj.toString())result += "\r\n"result += msg.objtvResult!!.text = "收到信息:$result"}}}

对应的布局文件：

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"xmlns:app="http://schemas.android.com/apk/res-auto"xmlns:tools="http://schemas.android.com/tools"android:layout_width="match_parent"android:layout_height="match_parent"android:orientation="vertical"tools:context="com.android.agent.MainActivity"><Buttonandroid:id="@+id/btnTestServer"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="测试服务端"android:layout_gravity="center_horizontal"android:layout_marginTop="50dp"/><Buttonandroid:id="@+id/btnTestClient"android:layout_width="wrap_content"android:layout_height="wrap_content"android:layout_gravity="center_horizontal"android:layout_marginTop="100dp"android:text="测试客户端"/><Buttonandroid:id="@+id/btnClientSend"android:layout_width="wrap_content"android:layout_height="wrap_content"android:layout_gravity="center_horizontal"android:layout_marginTop="100dp"android:text="客户端发送数据"/><TextViewandroid:id="@+id/tv_text"android:layout_width="wrap_content"android:layout_height="wrap_content"android:layout_gravity="center_horizontal"android:layout_marginTop="100dp"android:text="收到信息:"/></LinearLayout>
2.6 数据编码解码器

需要根据协议去定义自己的编解码器，处理粘包丢包问题

完整代码下载地址：https://download.csdn.net/download/banzhuantuqiang/89705769

这篇关于Android kotlin使用Netty网络框架实践（客户端、服务端）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1132510。

相关文章

Python并行处理实战之如何使用ProcessPoolExecutor加速计算

Python并行处理实战之如何使用ProcessPoolExecutor加速计算

《Python并行处理实战之如何使用ProcessPoolExecutor加速计算》Python提供了多种并行处理的方式,其中concurrent.futures模块的ProcessPoolExecu... 目录简介完整代码示例代码解释1. 导入必要的模块2. 定义处理函数3. 主函数4. 生成数字列表5.
阅读更多...
Python中help()和dir()函数的使用

Python中help()和dir()函数的使用

《Python中help()和dir()函数的使用》我们经常需要查看某个对象（如模块、类、函数等）的属性和方法,Python提供了两个内置函数help()和dir(),它们可以帮助我们快速了解代... 目录1. 引言2. help() 函数2.1 作用2.2 使用方法2.3 示例(1) 查看内置函数的帮助(
阅读更多...
Linux脚本(shell)的使用方式

Linux脚本(shell)的使用方式

《Linux脚本(shell)的使用方式》：本文主要介绍Linux脚本(shell)的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录概述语法详解数学运算表达式Shell变量变量分类环境变量Shell内部变量自定义变量：定义、赋值自定义变量：引用、修改、删
阅读更多...
Java使用HttpClient实现图片下载与本地保存功能

Java使用HttpClient实现图片下载与本地保存功能

《Java使用HttpClient实现图片下载与本地保存功能》在当今数字化时代,网络资源的获取与处理已成为软件开发中的常见需求,其中,图片作为网络上最常见的资源之一,其下载与保存功能在许多应用场景中都... 目录引言一、Apache HttpClient简介二、技术栈与环境准备三、实现图片下载与保存功能1.
阅读更多...
Python中使用uv创建环境及原理举例详解

Python中使用uv创建环境及原理举例详解

《Python中使用uv创建环境及原理举例详解》uv是Astral团队开发的高性能Python工具,整合包管理、虚拟环境、Python版本控制等功能,：本文主要介绍Python中使用uv创建环境及... 目录一、uv工具简介核心特点：二、安装uv1. 通过pip安装2. 通过脚本安装验证安装：配置镜像源（可
阅读更多...
LiteFlow轻量级工作流引擎使用示例详解

LiteFlow轻量级工作流引擎使用示例详解

《LiteFlow轻量级工作流引擎使用示例详解》：本文主要介绍LiteFlow是一个灵活、简洁且轻量的工作流引擎,适合用于中小型项目和微服务架构中的流程编排,本文给大家介绍LiteFlow轻量级工... 目录1. LiteFlow 主要特点2. 工作流定义方式3. LiteFlow 流程示例4. LiteF
阅读更多...
使用Python开发一个现代化屏幕取色器

使用Python开发一个现代化屏幕取色器

《使用Python开发一个现代化屏幕取色器》在UI设计、网页开发等场景中,颜色拾取是高频需求,：本文主要介绍如何使用Python开发一个现代化屏幕取色器,有需要的小伙伴可以参考一下... 目录一、项目概述二、核心功能解析2.1 实时颜色追踪2.2 智能颜色显示三、效果展示四、实现步骤详解4.1 环境配置4.
阅读更多...
使用jenv工具管理多个JDK版本的方法步骤

使用jenv工具管理多个JDK版本的方法步骤

《使用jenv工具管理多个JDK版本的方法步骤》jenv是一个开源的Java环境管理工具,旨在帮助开发者在同一台机器上轻松管理和切换多个Java版本,：本文主要介绍使用jenv工具管理多个JD... 目录一、jenv到底是干啥的？二、jenv的核心功能（一）管理多个Java版本（二）支持插件扩展（三）环境隔
阅读更多...
SQL中JOIN操作的条件使用总结与实践

SQL中JOIN操作的条件使用总结与实践

《SQL中JOIN操作的条件使用总结与实践》在SQL查询中,JOIN操作是多表关联的核心工具,本文将从原理,场景和最佳实践三个方面总结JOIN条件的使用规则,希望可以帮助开发者精准控制查询逻辑... 目录一、ON与WHERE的本质区别二、场景化条件使用规则三、最佳实践建议1.优先使用ON条件2.WHERE用
阅读更多...
Springboot整合Redis主从实践

Springboot整合Redis主从实践

《Springboot整合Redis主从实践》：本文主要介绍Springboot整合Redis主从的实例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言原配置现配置测试LettuceConnectionFactory.setShareNativeConnect
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2