android udp编程实例,Android NDK网络通信篇（五）之UDP通信篇

Myth丶恋晨 2022-10-17 15:57 547阅读 0赞

Android NDK网络通信篇(五)

UDP通信篇

前言

本篇重点讲解UDP通信的相关函数以及UDP服务端和客户端程序设计流程，并提供UDP C/S通信的客户端和服务端示例代码。

UDP通信相关的头文件

\#include

UDP通信函数解析

创建UDP socket

intsocket(intdomain, inttype, intprotocal);

参数解析：

domain：指定将会产生通讯的socket域，并且选择用到的协议族。android平台目前支持以下协议族：

l  PF\_LOCAL：主机内部通讯协议族，该协议族使用物理上运行在同一台设备上的应用程序可以使用Socket APIs进行通信。

l  PF\_INET：IPv4协议族，该协议族使得运行的应用程序可以与网络上的其它应用程序进行通讯。

type：指通信的类型，支持以下两种类型：

SOCK\_STREAM：供TCP协议使用。

SOCK\_DGRAM：供UDP协议使用。

protocal：指定将会用到的协议。对于大部分协议族和协议类型来说，只能使用一个协议。为了选择默认的协议，该参数可以设为零。

如果socket创建成功，将会返回对应的socket描述符，否则返回-1。

示例代码：

intNewUdpSocket(JNIEnv\*env,jobjectobj)\{

intsd=socket(PF\_INET,SOCK\_DGRAM,0);

returnsd;

绑定UDP socket

intbind(intsocketDescriptor, const structsockaddr\* address, intaddressLength);

参数解析：

socketDescriptor：指服务端socket

address：指socket要绑定的服务端地址结构体

addressLength：指定address结构体的大小

如果绑定成功，返回0，否则返回-1

示例代码：

sockaddr\_ingetSockaddr\_in(const char\*ip,intport)\{

sockaddr\_inaddress;

memset(&address,0, sizeof(sockaddr\_in));

address.sin\_family=AF\_INET;

address.sin\_port=htons(port);

inet\_aton(ip,&address.sin\_addr);

returnaddress;

intBindSocket(JNIEnv\*env,jobjectobj,intsd,const char\*ip,intport)\{

sockaddr\_inaddress=getSockaddr\_in(ip,port);

intresult=bind(sd,(sockaddr\*)&address, sizeof(address));

returnresult;

接收UDP信息

ssize\_trecvfrom(intsocketDescriptor, void\* buffer, size\_tbufferLength, intflags, const structsockaddr\* address, socklen\_t\* addressLength);

参数解析：

socketDescriptor：指要接收信息的socket，在客户端指服务端socket，在客户端指客户端socket

buffer：指接收数据的缓冲区

bufferLength：指接收数据的缓冲区的大小

flags：指要接收数据的附加参数

address：指sockaddr结构体，这个结构体将被填入接收方的信息

addressLength：address结构体的大小

如果函数调用成功返回接收到的数据的大小，否则返回-1

示例代码：

intserver\_socket= NewUdpSocket(env,gThiz);

sockaddr\_inaddress;

socklen\_taddr\_len= sizeof(address);

while(true)\{

charbuffer\[1024\];

intreceive\_size=recvfrom(server\_socket,buffer,1024,0,(constsockaddr\*)&address,&addr\_len);

if(receive\_size==0||env->ExceptionOccurred()!=NULL) break;

if(receive\_size>0)\{

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","receive datafrom client is%s",buffer);

intsend\_size=sendto(server\_socket,buffer,receive\_size,0,(constsockaddr\*)&address,addr\_len);

if(send\_size==0||env->ExceptionOccurred()!=NULL) break;

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","send data toclient is%s",buffer);

发送UDP信息

ssize\_tsendto(intsocketDescriptor, const void\* buffer, size\_tbufferLength, intflags, const structsockaddr\* address, socklen\_taddressLength);

参数解析：

socketDescriptor：指要发送信息的socket，在客户端指服务端socket，在客户端指客户端socket

buffer：指发送数据的缓冲区

bufferLength：指发送数据的缓冲区的大小

flags：指要发送数据的附加参数

address：指sockaddr结构体，这个结构体将被填入接收方的信息

addressLength：address结构体的大小

如果函数调用成功返回已发送的数据的大小，否则返回-1

示例代码：

intserver\_socket= NewUdpSocket(env,gThiz);

sockaddr\_inaddress;

socklen\_taddr\_len= sizeof(address);

while(true)\{

charbuffer\[1024\];

intreceive\_size=recvfrom(server\_socket,buffer,1024,0,(constsockaddr\*)&address,&addr\_len);

if(receive\_size==0||env->ExceptionOccurred()!=NULL) break;

if(receive\_size>0)\{

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","receive datafrom client is%s",buffer);

intsend\_size=sendto(server\_socket,buffer,receive\_size,0,(constsockaddr\*)&address,addr\_len);

if(send\_size==0||env->ExceptionOccurred()!=NULL) break;

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","send data toclient is%s",buffer);

获取客户端socket 信息

intgetpeername(intsocketDescriptor, structsockaddr\* address, socklen\_t\* addressLength);

参数解析：

socketDescriptor：指客户端socket

address：指sockaddr结构体，这个结构体将被填入客户端的信息

addressLength：address结构体的大小

如果函数调用成功返回0，否则返回-1

示例代码：

structSocketInfo\{

intport;

const char\*ip;

\};

SocketInfo\* GetClientSocketInfo(JNIEnv\*env,jobjectobj,intsd)\{

sockaddr\_inaddress;

socklen\_taddressLength= sizeof(address);

getpeername(sd,(sockaddr\*)&address,&addressLength);

SocketInfo\*socketInfo=newSocketInfo;

socketInfo->port=ntohs(address.sin\_port);

socketInfo->ip=inet\_ntoa(address.sin\_addr);

returnsocketInfo;

获取服务端socket信息

intgetsockname(intsocketDescriptor, structsockaddr\* address, socklen\_t\* addressLength);

参数解析：

socketDescriptor：指服务端socket

address：指sockaddr结构体，这个结构体将被填入服务端的信息

addressLength：address结构体的大小

如果函数调用成功返回0，否则返回-1

示例代码：

structSocketInfo\{

intport;

const char\*ip;

\};

SocketInfo\* GetServerSocketInfo(JNIEnv\*env,jobjectobj,intsd)\{

sockaddr\_inaddress;

socklen\_taddressLength= sizeof(address);

getsockname(sd,(sockaddr\*)&address,&addressLength);

SocketInfo\*socketInfo=newSocketInfo;

socketInfo->port=ntohs(address.sin\_port);

socketInfo->ip=inet\_ntoa(address.sin\_addr);

returnsocketInfo;

UDP服务端

UDP服务端程序流程图

![17ecb2662b48fbc179dcade36af2ef36.png][]

1.   创建UDP socket(socket())

2.   绑定UDP socket(bind())

3.   接收UDP消息(recvfrom())

4.   发送UDP消息(sendto())

UDP服务端程序示例

void\*udpServerThread(void\* args)\{

JNIEnv\*env;

gVM->AttachCurrentThread(&env,NULL);

intserver\_socket=NewUdpSocket(env,gThiz);

BindSocket(env,gThiz,server\_socket,gServerIP,gServerPort);

SocketInfo\*serverSocketInfo=GetServerSocketInfo(env,gThiz,server\_socket);

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","client ip=%s,client port=%d",serverSocketInfo->ip,serverSocketInfo->port);

sockaddr\_inaddress;

socklen\_taddr\_len= sizeof(address);

while(true)\{

charbuffer\[1024\];

intreceive\_size=recvfrom(server\_socket,buffer,1024,0,(constsockaddr\*)&address,&addr\_len);

if(receive\_size==0||env->ExceptionOccurred()!=NULL) break;

if(receive\_size>0)\{

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","receive datafrom client is%s",buffer);

intsend\_size=sendto(server\_socket,buffer,receive\_size,0,(constsockaddr\*)&address,addr\_len);

if(send\_size==0||env->ExceptionOccurred()!=NULL) break;

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","send data toclient is%s",buffer);

CloseSocket(env,gThiz,server\_socket);

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","%s","serversocket close");

gVM->DetachCurrentThread();

return(void\*)0;

extern"C"JNIEXPORTvoidJNICALLJava\_com\_kgdwbb\_jnistudy\_MainActivity\_startUDPServerSocket(JNIEnv\* env, jobjectthiz)\{

if(gThiz==NULL)\{

gThiz=env->NewGlobalRef(thiz);

pthread\_tpthread;

pthread\_create(&pthread,NULL,udpServerThread,NULL);

UDP客户端

UDP客户端程序流程图

![0d990d63f65ba9367eb3352cb5f6650d.png][]

1.   创建客户端socket(socket())

2.   发送消息到服务器(sendto())

3.   接收服务器返回的消息(recvfrom())

UDP客户端程序示例

void\* udpClientThread(void\* args)\{

JNIEnv\*env;

gVM->AttachCurrentThread(&env,NULL);

intclient\_socket=NewUdpSocket(env,gThiz);

sockaddr\_inaddress=getSockaddr\_in(gServerIP,gServerPort);

socklen\_taddr\_len= sizeof(address);

const char\*msg="helloboy";

intlen=strlen(msg);

intsend\_size=sendto(client\_socket,msg,len,0,(constsockaddr\*)&address,addr\_len);

if(send\_size==0||env->ExceptionOccurred()!=NULL)\{

CloseSocket(env,gThiz,client\_socket);

return(void\*)1;

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","send data toserver is%s",msg);

charbuffer2\[1024\];

intreceive\_size= recvfrom(client\_socket,buffer2,1024,0,(constsockaddr\*)&address,&addr\_len);

if(receive\_size==0||env->ExceptionOccurred()!=NULL)\{

CloseSocket(env,gThiz,client\_socket);

return(void\*)1;

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","receiveddata from server is%s",buffer2);

CloseSocket(env,gThiz,client\_socket);

\_\_android\_log\_print(ANDROID\_LOG\_VERBOSE,"hello","%s","clientsocket close");

gVM->DetachCurrentThread();

return(void\*)1;

extern"C"JNIEXPORTvoidJNICALLJava\_com\_kgdwbb\_jnistudy\_MainActivity\_startUDPClientSocket(JNIEnv\* env, jobjectthiz)\{

if(gThiz==NULL)\{

gThiz=env->NewGlobalRef(thiz);

pthread\_tpthread;

pthread\_create(&pthread,NULL,udpClientThread,NULL);

结束语

本篇重点讲解了UDP通信相关的函数，以及一个完整的UDP C/S架构的通信示例，相信大家学完本篇，一定能熟悉掌握UDP通信的相关知识。记得一定要多练习，才能更好的理解UDP通信的流程。

[17ecb2662b48fbc179dcade36af2ef36.png]: /images/20221014/6b172d1383884aa0adbcf7d00f64b1a7.png
[0d990d63f65ba9367eb3352cb5f6650d.png]: /images/20221014/a91eadf3491a4ee5a59ac35c088d608d.png

android udp编程实例,Android NDK网络通信篇（五）之UDP通信篇

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 Java网络编程理解不足：TCP/UDP通信实例

相关 Java网络编程 - UDP通信

相关 linux编程UDP通信

相关 android udp编程实例,Android NDK网络通信篇（五）之UDP通信篇

相关 Java网络编程：UDP通信

相关代码篇C#网络编程之UDP进程通信

相关 Android 网络通信之 UDP

相关 QT-UDP通信实例

相关网络通信协议、UDP与TCP协议、UDP通信、TCP通信

相关网络通信协议、UDP与TCP协议、UDP通信、TCP通信