大家好,又见面了,我是你们的朋友全栈君。
本文收录于微信公众号「 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(),具体使用还要依据代码场景。
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/163414.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...