Android之UDP协议通讯

2024-08-31 09:48
文章标签 android 协议 udp 通讯

本文主要是介绍Android之UDP协议通讯，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

最近在做的项目中用到了UDP协议来通讯，整理了一下，可以与PC端网络助手之间进行测试。下面将主要功能代码写在下面供搭建参考：
UDPSocketClientManage

public class UDPSocketClientManage {// 服务器IPprivate static String SERVER_IP = "192.168.1.68";// 服务器端口private static int LOCAL_PORT_AUDIO = 10000;// 接收数据包private DatagramPacket Packet_Receive;// 端口private DatagramSocket msocketClient;NetworkState mLastNetworkState = NetworkState.NETWORK_STATE_NULL;SocketConnectListener mConnectListener = null;// 设置网络连接参数public void setNetworkParameter(String strIP, int nPort) {SERVER_IP = strIP;LOCAL_PORT_AUDIO = nPort;}// 注册接收连接状态和数据的回调函数public void RegSocketConnectListener(SocketConnectListener listener) {mConnectListener = listener;}/*** 启动连接服务器*/public void Connect() {// 正在开始连接mLastNetworkState = NetworkState.NETWORK_STATE_CONNECT_ING;try {// 端口msocketClient = new DatagramSocket(LOCAL_PORT_AUDIO);// 接收数据缓存byte[] Buffer_Receive = new byte[1024];// 接收包Packet_Receive = new DatagramPacket(Buffer_Receive, 1024);mLastNetworkState = NetworkState.NETWORK_STATE_CONNECT_SUCCEED;} catch (IOException e) {mLastNetworkState = NetworkState.NETWORK_STATE_CONNECT_FAILLD;Log.e("Show", e.toString());e.printStackTrace();} catch (Exception e) {mLastNetworkState = NetworkState.NETWORK_STATE_CONNECT_FAILLD;Log.e("Show", e.toString());e.printStackTrace();}// 向回调发数据if (null != mConnectListener) {mConnectListener.OnConnectStatusCallBack(mLastNetworkState);}if (msocketClient != null) {new Thread(reRunnable).start();}}Runnable reRunnable = new Runnable() {@SuppressLint("NewApi")@Overridepublic void run() {while (true) {try {// 接收数据if (Packet_Receive != null) {msocketClient.receive(Packet_Receive);// 判断数据是否合法InetSocketAddress address = (InetSocketAddress) Packet_Receive.getSocketAddress();// 判断是否是调度服务器的ipif (!address.getHostName().equals(SERVER_IP)) {continue;}// 判断是否是调度服务器的端口if (address.getPort() != LOCAL_PORT_AUDIO) {continue;}int length = Packet_Receive.getLength();if (length > 0)mConnectListener.OnReceiverCallBack(length, Packet_Receive.getData());}} catch (IOException e) {e.printStackTrace();Log.e("Show", e.toString());}}}};/*** 断开连接*/public void Close() {if (msocketClient != null) {msocketClient = null;mLastNetworkState = NetworkState.NETWORK_STATE_DISCONNECT_SUCCEED;mConnectListener.OnConnectStatusCallBack(mLastNetworkState);}}/*** @param data :需要发送的数据* @param len  :数据字节数据* @brief 发送数据*/public void send(byte[] data, int len) {Thread_Send thread_send = new Thread_Send(data, len);new Thread(thread_send).start();}/*** @brief 发送线程*/private class Thread_Send implements Runnable {// 发送数据缓存private byte[] Buffer_Send = new byte[1024];// 发送数据包private DatagramPacket Packet_Send;/*** @param data :需要发送的数据* @param len  :数据字节数据* @brief 构造函数*/public Thread_Send(byte[] data, int len) {// 发送包Packet_Send = new DatagramPacket(Buffer_Send, 1024);Packet_Send.setData(data);Packet_Send.setLength(len);}@Overridepublic void run() {try {Packet_Send.setPort(LOCAL_PORT_AUDIO);Packet_Send.setAddress(InetAddress.getByName(SERVER_IP));if (msocketClient != null) {msocketClient.send(Packet_Send);mLastNetworkState = NetworkState.NETWORK_STATE_TXD;mConnectListener.OnConnectStatusCallBack(mLastNetworkState);} else {mLastNetworkState = NetworkState.NETWORK_STATE_NULL;mConnectListener.OnConnectStatusCallBack(mLastNetworkState);}} catch (UnknownHostException e) {e.printStackTrace();mLastNetworkState = NetworkState.NETWORK_STATE_NULL;mConnectListener.OnConnectStatusCallBack(mLastNetworkState);} catch (IOException e) {e.printStackTrace();mLastNetworkState = NetworkState.NETWORK_STATE_NULL;mConnectListener.OnConnectStatusCallBack(mLastNetworkState);}}}// 获取最后的网络状态public NetworkState getLastNetworkState() {return mLastNetworkState;}@SuppressLint("LongLogTag")public static String getLocalIpAddress() {try {for (Enumeration<NetworkInterface> en = NetworkInterface.getNetworkInterfaces(); en.hasMoreElements(); ) {NetworkInterface intf = en.nextElement();for (Enumeration<InetAddress> enumIpAddr = intf.getInetAddresses(); enumIpAddr.hasMoreElements(); ) {InetAddress inetAddress = enumIpAddr.nextElement();if (!inetAddress.isLoopbackAddress()&& !inetAddress.isLinkLocalAddress()) {return inetAddress.getHostAddress().toString();}}

这里写代码片

} catch (SocketException ex) {Log.e("WifiPreference IpAddress", ex.toString());}return null;}}

接口SocketConnectListener

public abstract class SocketConnectListener {// 网络状态回调public abstract void OnConnectStatusCallBack(NetworkState networkState);// 接收数据回调public abstract void OnReceiverCallBack(int nLength, byte[] data);}

网络状态枚举类NetworkState

//网络状态枚举类
public enum NetworkState {NETWORK_STATE_NULL, // 无状态NETWORK_STATE_CONNECT_SUCCEED, // 网络连接成功NETWORK_STATE_DISCONNECT_SUCCEED, // 网络断开成功(自身断开)NETWORK_STATE_SERVER_DISCONNECT, // 网络被服务器断开NETWORK_STATE_CONNECT_FAILLD, // 连接服务器失败，IP/端口不正常NETWORK_STATE_CONNECT_ING, // 正在连接过程中...NETWORK_STATE_RXD, // 接收数据NETWORK_STATE_TXD; // 发送数据
}

主页面连接使用类MainActivity

public class MainActivity extends ActionBarActivity implements View.OnClickListener {public static UDPSocketClientManage socketClientManage = null;
//    private String mstrDataString = "";private byte[] mstrDataString;private TextView textViewRecrive;public static byte[] bytes1_up = {(byte) 0xfa,(byte)0x01,(byte)0x05,(byte)0x01};@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);findViewById(R.id.button1).setOnClickListener(this);findViewById(R.id.button2).setOnClickListener(this);findViewById(R.id.button3).setOnClickListener(this);TextView loTextView = (TextView) findViewById(R.id.textViewLoca);//手机端的连接路由之后IP地址，网络调试助手向目标主机发送的IP地址就是这里获取出来的String strLoString = UDPSocketClientManage.getLocalIpAddress();if (strLoString != null) {loTextView.setText(strLoString);}textViewRecrive = (TextView) findViewById(R.id.textViewRecrive);socketClientManage = new UDPSocketClientManage();socketClientManage.RegSocketConnectListener(new SocketConnectListener() {@Overridepublic void OnReceiverCallBack(int nLength, byte[] data) {
//                mstrDataString = new String(data);mstrDataString = data;mHandler.sendEmptyMessage(1);}@Overridepublic void OnConnectStatusCallBack(NetworkState networkState) {switch (networkState) {case NETWORK_STATE_CONNECT_SUCCEED:mHandler.sendEmptyMessage(0);break;default:break;}}});}Handler mHandler = new Handler() {@Overridepublic void handleMessage(Message msg) {super.handleMessage(msg);switch (msg.what) {case 0: // 接受到消息之后，对UI控件进行修改Toast.makeText(MainActivity.this, "连接成功", Toast.LENGTH_SHORT).show();break;case 1: // 接受到消息之后，对UI控件进行修改
//                    textViewRecrive.append(mstrDataString);
//                    textViewRecrive.setText(bytesToHexString(mstrDataString.getBytes()));
//                    Toast.makeText(MainActivity.this, mstrDataString, Toast.LENGTH_SHORT).show();//下面是以16进制方式来接收String str1 = Integer.toHexString(mstrDataString [0]& 0xFF);String str2 = Integer.toHexString(mstrDataString [1]& 0xFF);String str3 = Integer.toHexString(mstrDataString [2]& 0xFF);String str4 = Integer.toHexString(mstrDataString [3]& 0xFF);if (str1.length() == 1) {str1='0' + str1;}if (str2.length() == 1) {str2='0' + str2;}if (str3.length() == 1) {str3='0' + str3;}if (str4.length() == 1) {str4='0' + str4;}textViewRecrive.setText(str1+" "+str2+" "+str3+" "+str4);break;default:break;}}};@Overridepublic void onClick(View v) {switch (v.getId()) {case R.id.button1:new Thread(new Runnable() {@Overridepublic void run() {socketClientManage.Connect();}}).start();break;case R.id.button2:EditText ipEditText = (EditText) findViewById(R.id.editText1);EditText porText = (EditText) findViewById(R.id.editText2);String ipString = ipEditText.getText().toString().trim();String portString = porText.getText().toString().trim();socketClientManage.setNetworkParameter(ipString, portString != null ? Integer.parseInt(portString) : 0);Toast.makeText(MainActivity.this, "设置成功", Toast.LENGTH_SHORT).show();break;case R.id.button3:socketClientManage.send(bytes1_up, bytes1_up.length);break;default:break;}}
}

布局.xml文件

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"xmlns:tools="http://schemas.android.com/tools"android:id="@+id/container"android:layout_width="match_parent"android:layout_height="match_parent"android:orientation="vertical" ><LinearLayout
        android:layout_width="wrap_content"android:layout_height="wrap_content" ><TextView
            android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="本地IP地址：" /><TextView
            android:id="@+id/textViewLoca"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="TextView" /></LinearLayout><LinearLayout
        android:layout_width="match_parent"android:layout_height="wrap_content"android:orientation="vertical" ><EditText
            android:id="@+id/editText1"android:layout_width="match_parent"android:layout_height="40dp"><requestFocus /></EditText><TextView
            android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="PC端的IP地址（也就是发送数据服务器地址）：" /></LinearLayout><LinearLayout
        android:layout_width="match_parent"android:layout_height="wrap_content"android:orientation="vertical" ><TextView
            android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="PC端的IP端口（也就是发送数据服务器端口）：" /><EditText
            android:id="@+id/editText2"android:layout_width="match_parent"android:layout_height="40dp"android:inputType="number" ><requestFocus /></EditText></LinearLayout><LinearLayout
        android:layout_width="match_parent"android:layout_height="wrap_content"android:orientation="vertical" ><TextView
            android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="发送给PC端的数据" /><EditText
            android:id="@+id/editText3"android:layout_width="match_parent"android:layout_height="40dp" ><requestFocus /></EditText></LinearLayout><LinearLayout
        android:layout_width="match_parent"android:layout_height="wrap_content" ><Button
            android:id="@+id/button2"android:layout_width="wrap_content"android:layout_height="wrap_content"android:layout_marginRight="5dp"android:text="确定" /><Button
            android:id="@+id/button1"android:layout_width="wrap_content"android:layout_height="wrap_content"android:layout_marginRight="5dp"android:text="连接" /><Button
            android:id="@+id/button3"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="发送" /></LinearLayout><TextView
        android:id="@+id/textViewRecrive"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="接收到的数据：" /></LinearLayout>

最后别忘了在AndroidManifest.xml里添加权限

    <uses-permission android:name="android.permission.ACCESS_WIFI_STATE" /><uses-permission android:name="android.permission.CHANGE_WIFI_STATE" /><uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" /><uses-permission android:name="android.permission.INTERNET" />

以上这些就是全部代码，有不足指出还请大家指出
下面为大家附上源码

这篇关于Android之UDP协议通讯的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


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

相关文章

Android学习总结之Java和kotlin区别超详细分析

Android学习总结之Java和kotlin区别超详细分析

《Android学习总结之Java和kotlin区别超详细分析》Java和Kotlin都是用于Android开发的编程语言,它们各自具有独特的特点和优势,：本文主要介绍Android学习总结之Ja... 目录一、空安全机制真题 1：Kotlin 如何解决 Java 的 NullPointerExceptio
阅读更多...
C#使用MQTTnet实现服务端与客户端的通讯的示例

C#使用MQTTnet实现服务端与客户端的通讯的示例

《C#使用MQTTnet实现服务端与客户端的通讯的示例》本文主要介绍了C#使用MQTTnet实现服务端与客户端的通讯的示例,包括协议特性、连接管理、QoS机制和安全策略,具有一定的参考价值,感兴趣的可... 目录一、MQTT 协议简介二、MQTT 协议核心特性三、MQTTNET 库的核心功能四、服务端（BR
阅读更多...
Android NDK版本迭代与FFmpeg交叉编译完全指南

Android NDK版本迭代与FFmpeg交叉编译完全指南

《AndroidNDK版本迭代与FFmpeg交叉编译完全指南》在Android开发中,使用NDK进行原生代码开发是一项常见需求,特别是当我们需要集成FFmpeg这样的多媒体处理库时,本文将深入分析A... 目录一、android NDK版本迭代分界线二、FFmpeg交叉编译关键注意事项三、完整编译脚本示例四
阅读更多...
Android与iOS设备MAC地址生成原理及Java实现详解

Android与iOS设备MAC地址生成原理及Java实现详解

《Android与iOS设备MAC地址生成原理及Java实现详解》在无线网络通信中,MAC（MediaAccessControl）地址是设备的唯一网络标识符,本文主要介绍了Android与iOS设备M... 目录引言1. MAC地址基础1.1 MAC地址的组成1.2 MAC地址的分类2. android与I
阅读更多...
Android 实现一个隐私弹窗功能

Android 实现一个隐私弹窗功能

《Android实现一个隐私弹窗功能》：本文主要介绍Android实现一个隐私弹窗功能,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧... 效果图如下：1. 设置同意、退出、点击用户协议、点击隐私协议的函数参数2. 《用户协议》、《隐私政策》设置成可点击的，且颜色要区分出来res/l
阅读更多...
Android实现一键录屏功能(附源码)

Android实现一键录屏功能(附源码)

《Android实现一键录屏功能(附源码)》在Android5.0及以上版本,系统提供了MediaProjectionAPI,允许应用在用户授权下录制屏幕内容并输出到视频文件,所以本文将基于此实现一个... 目录一、项目介绍二、相关技术与原理三、系统权限与用户授权四、项目架构与流程五、环境配置与依赖六、完整
阅读更多...
Android 12解决push framework.jar无法开机的方法小结

Android 12解决push framework.jar无法开机的方法小结

《Android12解决pushframework.jar无法开机的方法小结》：本文主要介绍在Android12中解决pushframework.jar无法开机的方法,包括编译指令、框架层和s... 目录1. android 编译指令1.1 framework层的编译指令1.2 替换framework.ja
阅读更多...
Android开发环境配置避坑指南

Android开发环境配置避坑指南

《Android开发环境配置避坑指南》本文主要介绍了Android开发环境配置过程中遇到的问题及解决方案,包括VPN注意事项、工具版本统一、Gerrit邮箱配置、Git拉取和提交代码、MergevsR... 目录网络环境：VPN 注意事项工具版本统一：android Studio & JDKGerrit的邮
阅读更多...
Android实现定时任务的几种方式汇总(附源码)

Android实现定时任务的几种方式汇总(附源码)

《Android实现定时任务的几种方式汇总(附源码)》在Android应用中,定时任务（ScheduledTask）的需求几乎无处不在：从定时刷新数据、定时备份、定时推送通知,到夜间静默下载、循环执行... 目录一、项目介绍1. 背景与意义二、相关基础知识与系统约束三、方案一：Handler.postDel
阅读更多...
Android使用ImageView.ScaleType实现图片的缩放与裁剪功能

Android使用ImageView.ScaleType实现图片的缩放与裁剪功能

《Android使用ImageView.ScaleType实现图片的缩放与裁剪功能》ImageView是最常用的控件之一,它用于展示各种类型的图片,为了能够根据需求调整图片的显示效果,Android提... 目录什么是 ImageView.ScaleType？FIT_XYFIT_STARTFIT_CENTE
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2