大家好，又见面了，我是你们的朋友全栈君。
本文收录于微信公众号「 LinuxOK 」，ID为：Linux_ok，关注公众号第一时间获取更多技术学习文章。
udp通讯中的sendto()需要在参数里指定接收方的地址/端口，recvfrom()则在参数中存放接收发送方的地址/端口，与之对应的send()和recv()则不需要如此，但是在调用send()之前，需要为套接字指定接收方的地址/端口(这样该函数才知道要把数据发往哪里)，在调用recv()之前，可以为套接字指定发送方的地址/端口，这样该函数就只接收指定的发送方的数据，当然若不指定也可，该函数就可以接收任意的地址的数据。(这些内容前面文章udp通讯中的connect()和bind()函数
有详细讲过)
这4个函数的使用比较简单，但在一个实例中，遇到一个小问题。
实现功能: udp服务器创建一个套接字接收客户端的连接，连接成功后，服务器再创建一个套接字与客户端进行数据交互，要求尽量使用connect()和recv()、send()函数。
udp服务器代码:
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#define BUFSZ 1024
#define PORT 6567
int main(void)
{
int srv_sd, cli_sd;
int new_sd;
int ret;
struct sockaddr_in svr_addr, cli_addr;
socklen_t addrlen = sizeof(struct sockaddr_in);
char buf[BUFSZ] = {};
//创建套接字
if ((srv_sd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
{
perror("socket");
exit(EXIT_FAILURE);
}
//为服务器套接字绑定端口
svr_addr.sin_family = AF_INET;
svr_addr.sin_port = htons(PORT);
svr_addr.sin_addr.s_addr = 0;
if ((ret = bind(srv_sd, (struct sockaddr* )&svr_addr, addrlen)) < 0)
{
perror("bind");
exit(EXIT_FAILURE);
}
//接收客户端的连接
ret = recvfrom(srv_sd, buf, BUFSZ, 0, (struct sockaddr* )&cli_addr, &addrlen);
if (ret < 0)
{
perror("recvfrom");
exit(EXIT_FAILURE);
}
printf("server output msg:\n");
printf("client IPAddr = %s, Port = %d, buf = %s\n", inet_ntoa(cli_addr.sin_addr), ntohs(cli_addr.sin_port), buf);
close(srv_sd);
//创建与客户端数据交互的套接字
cli_sd = socket(AF_INET, SOCK_DGRAM, 0);
if (cli_sd < 0)
{
perror("socket");
exit(EXIT_FAILURE);
}
//为新套接字绑定地址信息
svr_addr.sin_family = AF_INET;
svr_addr.sin_port = htons(6666);
svr_addr.sin_addr.s_addr = 0;
if ((ret = bind(cli_sd, (struct sockaddr* )&svr_addr, addrlen)) < 0)
{
perror("bind");
exit(EXIT_FAILURE);
}
//为新套接字指定目的地址，接下来的数据交互将可以采用recv()和send()
if ((ret = connect(cli_sd, (struct sockaddr* )&cli_addr, addrlen)) < 0)
{
perror("connect");
exit(EXIT_FAILURE);
}
//服务器先发数据再收数据
while (1)
{
memset(buf, 0, BUFSZ);
printf("ple input: ");
fgets(buf, BUFSZ, stdin);
//sendto(sd, buf, BUFSZ, 0, (struct sockaddr* )&svr_addr, addrlen);
send(cli_sd, buf, BUFSZ, 0);
ret = recv(cli_sd, buf, BUFSZ, 0);
printf("server output msg:\n");
printf("client IPAddr = %s, Port = %d, buf = %s\n", inet_ntoa(cli_addr.sin_addr), ntohs(cli_addr.sin_port), buf);
}
close(cli_sd);
return 0;
}
udp客户端代码:
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#define BUFSZ 1024
#define PORT 6567
int main(int argc, char *argv[])
{
int sd;
struct sockaddr_in svr_addr, cli_addr;
int ret;
socklen_t addrlen = sizeof(struct sockaddr_in);
char buf[BUFSZ] = {};
//创建套接字
if ((sd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
{
perror("socket");
exit(EXIT_FAILURE);
}
//为套接字绑定本地地址信息
cli_addr.sin_family = AF_INET;
cli_addr.sin_port = htons(9693);
cli_addr.sin_addr.s_addr = 0;
if ((ret = bind(sd, (struct sockaddr* )&cli_addr, addrlen)) < 0)
{
perror("bind");
exit(EXIT_FAILURE);
}
//为套接字指定目的地址信息，接下来的与服务器的数据交互就可以使用
svr_addr.sin_family = AF_INET;
svr_addr.sin_port = htons(PORT);
svr_addr.sin_addr.s_addr = inet_addr("192.168.1.166");
if ((ret = connect(sd, (struct sockaddr* )&svr_addr, addrlen)) < 0)
{
perror("connect");
exit(EXIT_FAILURE);
}
//数据交互
while (1)
{
memset(buf, 0, BUFSZ);
printf("ple input: ");
fgets(buf, BUFSZ, stdin);
//sendto(sd, buf, BUFSZ, 0, (struct sockaddr* )&svr_addr, addrlen);
send(sd, buf, BUFSZ, 0);
memset(buf, 0, BUFSZ);
//ret = recvfrom(sd, buf, BUFSZ, 0, (struct sockaddr* )&svr_addr, &addrlen);
ret = recv(sd, buf, BUFSZ, 0);
printf("client output msg:\n");
printf("server IPAddr = %s, Port = %d, buf = %s\n", inet_ntoa(cli_addr.sin_addr), ntohs(cli_addr.sin_port), buf);
}
close(sd);
return 0;
}
运行结果:
观察程序流程，可以得出:
客户端发起连接给服务器，服务器接收到后创建新的套接字并调用connect()函数为该套接字指定目标地址信息，这个目标地址信息虽然确实是客户端的，但是客户端的目标地址却是服务器，那么服务器新的套接字的目标地址不是客户端而是服务器，所以服务器发出的数据还是自己收到。
程序的问题出现在客户端，客户端创建了套接字后，就立即为其制定目标(服务器)的地址信息，而这个目标地址信息并非作为接下来数据交互的地址，所以应该把为客户端指定目标地址操作放在服务器创建新的sd之后返回数据到客户端之后，但是注意，客服端创建完套接字后不能马上为其connect()以指定目的地址信息，那么就发数据给服务器时就要使用sendto()、接收数据则是用recvfrom()，流程图改为：
客户端代码实现为：
int main(int argc, char *argv[])
{
int sd;
struct sockaddr_in svr_addr, cli_addr;
int ret;
socklen_t addrlen = sizeof(struct sockaddr_in);
char buf[BUFSZ] = {};
//创建套接字
if ((sd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
{
perror("socket");
exit(EXIT_FAILURE);
}
cli_addr.sin_family = AF_INET;
cli_addr.sin_port = htons(9693);
cli_addr.sin_addr.s_addr = 0;
if ((ret = bind(sd, (struct sockaddr* )&cli_addr, addrlen)) < 0)
{
perror("bind");
exit(EXIT_FAILURE);
}
//为sendto()函数的使用指定目标地址
svr_addr.sin_family = AF_INET;
svr_addr.sin_port = htons(PORT);
svr_addr.sin_addr.s_addr = inet_addr("192.168.1.166");
//发送数据
memset(buf, 0, BUFSZ);
printf("ple input: ");
fgets(buf, BUFSZ, stdin);
sendto(sd, buf, BUFSZ, 0, (struct sockaddr* )&svr_addr, addrlen);
//接收数据，此时svr_addr的地址信息是服务端新建的专为数据交互使用的sd
memset(buf, 0, BUFSZ);
ret = recvfrom(sd, buf, BUFSZ, 0, (struct sockaddr* )&svr_addr, &addrlen);
printf("client output msg:\n");
printf("server IPAddr = %s, Port = %d, buf = %s\n", inet_ntoa(cli_addr.sin_addr), ntohs(cli_addr.sin_port), buf);
//为套接字绑定目标地址，目标地址是服务端专为数据交互使用的sd
if ((ret = connect(sd, (struct sockaddr* )&svr_addr, addrlen)) < 0)
{
perror("connect");
exit(EXIT_FAILURE);
}
//数据交互
while (1)
{
memset(buf, 0, BUFSZ);
printf("ple input: ");
fgets(buf, BUFSZ, stdin);
//sendto(sd, buf, BUFSZ, 0, (struct sockaddr* )&svr_addr, addrlen);
send(sd, buf, BUFSZ, 0);
memset(buf, 0, BUFSZ);
//ret = recvfrom(sd, buf, BUFSZ, 0, (struct sockaddr* )&svr_addr, &addrlen);
ret = recv(sd, buf, BUFSZ, 0);
printf("client output msg:\n");
printf("server IPAddr = %s, Port = %d, buf = %s\n", inet_ntoa(cli_addr.sin_addr), ntohs(cli_addr.sin_port), buf);
}
close(sd);
return 0;
}
运行结果:
结论: connect()和send()、recv()三个函数的搭配使用并不能说一定能代替sendto()、recvfrom()，具体使用还要依据代码场景。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/163414.html原文链接：https://javaforall.net
