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实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸： 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  （注意不能是bmp格式） 替换默认锁屏壁纸： 将图片资源放入vendo
阅读更多...
Android平台播放RTSP流的几种方案探究（VLC VS ExoPlayer VS SmartPlayer）

Android平台播放RTSP流的几种方案探究（VLC VS ExoPlayer VS SmartPlayer）

技术背景 好多开发者需要遴选Android平台RTSP直播播放器的时候，不知道如何选的好，本文针对常用的方案，做个大概的说明： 1. 使用VLC for Android VLC Media Player（VLC多媒体播放器），最初命名为VideoLAN客户端，是VideoLAN品牌产品，是VideoLAN计划的多媒体播放器。它支持众多音频与视频解码器及文件格式，并支持DVD影音光盘，VCD影
阅读更多...
android-opencv-jni

android-opencv-jni

//------------------start opencv--------------------@Override public void onResume(){ super.onResume(); //通过OpenCV引擎服务加载并初始化OpenCV类库，所谓OpenCV引擎服务即是 //OpenCV_2.4.3.2_Manager_2.4_*.apk程序包，存
阅读更多...
【Linux】应用层http协议

【Linux】应用层http协议

一、HTTP协议 1.1 简要介绍一下HTTP        我们在网络的应用层中可以自己定义协议，但是，已经有大佬定义了一些现成的，非常好用的应用层协议，供我们直接使用，HTTP（超文本传输协议）就是其中之一。        在互联网世界中，HTTP（超文本传输协议）是一个至关重要的协议，他定义了客户端（如浏览器）与服务器之间如何进行通信，以交换或者传输超文本（比如HTML文档）。
阅读更多...
从状态管理到性能优化：全面解析 Android Compose

从状态管理到性能优化：全面解析 Android Compose

文章目录 引言一、Android Compose基本概念1.1 什么是Android Compose?1.2 Compose的优势1.3 如何在项目中使用Compose 二、Compose中的状态管理2.1 状态管理的重要性2.2 Compose中的状态和数据流2.3 使用State和MutableState处理状态2.4 通过ViewModel进行状态管理 三、Compose中的列表和滚动
阅读更多...
Android 10.0 mtk平板camera2横屏预览旋转90度横屏拍照图片旋转90度功能实现

Android 10.0 mtk平板camera2横屏预览旋转90度横屏拍照图片旋转90度功能实现

1.前言 在10.0的系统rom定制化开发中，在进行一些平板等默认横屏的设备开发的过程中，需要在进入camera2的 时候，默认预览图像也是需要横屏显示的，在上一篇已经实现了横屏预览功能，然后发现横屏预览后，拍照保存的图片 依然是竖屏的，所以说同样需要将图片也保存为横屏图标了，所以就需要看下mtk的camera2的相关横屏保存图片功能， 如何实现实现横屏保存图片功能 如图所示: 2.mtk
阅读更多...
android应用中res目录说明

android应用中res目录说明

Android应用的res目录是一个特殊的项目，该项目里存放了Android应用所用的全部资源，包括图片、字符串、颜色、尺寸、样式等，类似于web开发中的public目录，js、css、image、style。。。。 Android按照约定，将不同的资源放在不同的文件夹中，这样可以方便的让AAPT(即Android Asset Packaging Tool , 在SDK的build-tools目
阅读更多...
Android fill_parent、match_parent、wrap_content三者的作用及区别

Android fill_parent、match_parent、wrap_content三者的作用及区别

这三个属性都是用来适应视图的水平或者垂直大小，以视图的内容或尺寸为基础的布局，比精确的指定视图的范围更加方便。 1、fill_parent 设置一个视图的布局为fill_parent将强制性的使视图扩展至它父元素的大小 2、match_parent 和fill_parent一样，从字面上的意思match_parent更贴切一些，于是从2.2开始，两个属性都可以使用，但2.3版本以后的建议使
阅读更多...
Android Environment 获取的路径问题

Android Environment 获取的路径问题

1. 以获取 /System 路径为例 /*** Return root of the "system" partition holding the core Android OS.* Always present and mounted read-only.*/public static @NonNull File getRootDirectory() {return DIR_ANDR
阅读更多...
Java Websocket实例【服务端与客户端实现全双工通讯】

Java Websocket实例【服务端与客户端实现全双工通讯】

Java Websocket实例【服务端与客户端实现全双工通讯】 现很多网站为了实现即时通讯，所用的技术都是轮询(polling)。轮询是在特定的的时间间隔（如每1秒），由浏览器对服务器发 出HTTP request，然后由服务器返回最新的数据给客服端的浏览器。这种传统的HTTP request 的模式带来很明显的缺点 – 浏 览器需要不断的向服务器发出请求，然而HTTP
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2