一、实例代码
对于基础好的朋友可以直接拿代码看
客户端代码:
#include <stdio.h>
#include <sys/socket.h>//socket()
#include <netinet/in.h>//struct sockaddr_in
#include <string.h>//memset()
#include <arpa/inet.h>//inet_addr()
#include <unistd.h>//close()
#define SERVER_IP "127.0.0.1"
#define SERVER_PORT 12345
int main()
{
int sockfd = socket(AF_INET, SOCK_DGRAM, 0);
if(sockfd == -1)
{
perror("create socket failed\n");
return -1;
}
/*定义服务端地址信息用于发送函数*/
struct sockaddr_in server_addr;
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = inet_addr(SERVER_IP);
server_addr.sin_port = htons(SERVER_PORT);
/*要发送的数据缓冲区*/
char buf[1500];
while(1)
{
memset(buf, 0, sizeof(buf));
scanf("%s", buf);
int sendlen = sendto(sockfd, buf, sizeof(buf), 0, (const struct sockaddr *)&server_addr, sizeof(server_addr));
if(sendlen == -1)
{
perror("send failed\n");
break;
}
}
close(sockfd);
return 0;
}
服务端代码:
#include <stdio.h>
#include <sys/socket.h>//socket()
#include <netinet/in.h>//struct sockaddr_in
#include <string.h>//memset()
#include <arpa/inet.h>//inet_addr()
#include <unistd.h>//close()
#define SERVER_PORT 12345
int main()
{
int sockfd = socket(AF_INET, SOCK_DGRAM, 0);
if(sockfd == -1)
{
perror("create socket failed\n");
return -1;
}
/*绑定本端地址*/
struct sockaddr_in server_addr;
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;//INADDR_ANY == inet_addr("0.0.0.0"),监听本地所有网卡地址
server_addr.sin_port = htons(SERVER_PORT);
int ret = bind(sockfd, (const struct sockaddr *)&server_addr, sizeof(server_addr));
if(ret == -1)
{
perror("bind failed\n");
close(sockfd);
return -1;
}
struct sockaddr_in client_addr;//recvfrom函数会自动填充客户端的地址信息
socklen_t c_addr_len = sizeof(client_addr);
//接收数据的缓冲区
char buf[1024];
while(1)
{
memset(buf, 0, sizeof(buf));
int recvlen = recvfrom(sockfd, buf, sizeof(buf), 0, (struct sockaddr *)&client_addr, &c_addr_len);
if(recvlen == -1)
{
perror("recv falied\n");
break;
}
else if(recvlen == 0)
{
perror("connection reset by peer\n");
break;
}
else
{
printf("recv:%s\n", buf);
}
}
close(sockfd);
return 0;
}
二、函数接口解析
1. sendto函数
ssize_t sendto(socket s, const void * msg, int len, unsigned int flags,
const struct sockaddr * to, int tolen);
功能:
通过已创建的socket向第五个参数中的地址发送数据
参数:
s:一个udp的socket描述符,可以通过socket()函数创建
msg:存储发送数据的缓冲区
len:缓冲区长度
flags:类型为int,控制位,指定是否接受带外数据和是否预览报文,默认为0
to:目的地址的网络地址信息结构体指针
tolen:类型为&int,地址的字节长度的指针
返回值:
成功返回发送的字节数,失败返回 -1,使用perror或者打印全局变量errno可以打印出失败原因
EBADF 错误原因是第一个参数未指定合法的描述符
ENOTSOCK 错误原因是第一个参数未指定一个套接字描述符
EFAULT 错误原因是参数msg不正确
EMSGSIZE 错误原因是报文对套接字而言太大了
EWOULDBLOCK 错误原因是套接字没有数据,但是已经北指定为非阻塞I/O
ENOBUFS 错误原因是系统没有足够的资源完成操作
2.recvfrom函数
ssize_t recvfrom(int sockfd, void *buf, size_t len, unsigned int flags,
struct sockaddr *from, socklen_t *fromlen);
功能:
从套接字获取报文,并将对端网络地址填充到第五个参数中
参数:
sockfd:由socket()函数创建的套接字描述符
buf:存放报文的缓冲区地址
len:缓冲区长度
flags:控制位,指明是否接受带外数据和是否预览报文,默认为0
from:存放发送方地址结构体的地址
fromlen:发送方地址的大小
返回值:
成功返回接收到的报文大小,失败返回-1,使用perror或者打印全局变量errno可以打印出失败原因
EBADF 错误原因是第一个参数没有指定合法的描述符
ENOTSOCK 错误原因是第一个参数没有指定一个套接字描述符
EWOULDBLOCK 错误原因是套接字没有数据,但是已经被设定为非阻塞I/O
EINTR 错误原因是在读操作进行时,被信号所中断
EFAULT 错误原因是参数buffer不正确