send()、sendto()和recv()、recvfrom()的使用

send()、sendto()和recv()、recvfrom()的使用udp通讯中的sendto()需要在参数里指定接收方的地址/端口,recvfrom()则在参数中存放接收发送方的地址/端口,与之对应的send()和recv()则不需要如此,但是在调用send()之前,需要为套接字指定接收方的地址/端口(这样该函数才知道要把数据发往哪里),在调用recv()之前,可以为套接字指定发送方的地址/端口,这样该函数就只接收指定的发送方的数据,当然若不指定也可,该函数就可以

大家好,又见面了,我是你们的朋友全栈君。

本文收录于微信公众号「 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账号...

(0)


相关推荐

  • 数据库常见面试题(附答案)

    数据库常见面试题(附答案)1.事务四大特性原子性,要么执行,要么不执行隔离性,所有操作全部执行完以前,其它会话不能看到过程一致性,事务前后,数据总额一致持久性,一旦事务提交,对数据的改变就是永久的2.数据库隔离级别,每个级别会引发什么问题,mysql默认是哪个级别脏读:事务B读取事务A还没有提交的数据不可重复读:两次事务读的数据不一致幻读:事务A修改了数据,事务B也修改了数据,这时在事务A看

  • python中字符串类型转换为数字类型_python字符串转int

    python中字符串类型转换为数字类型_python字符串转intstr与inti=10s=str(i)#s=’10’s=’1’i=int(s)#i=1str与floatst=’.4’t=float(st)#t=0.4st=’0.4’t=float(st)#t=0.4t=0.4st=str(t)#st=’0.4’注意把字符串转换为数字类型时,…

  • 安全帽识别 安全帽佩戴识别 安全帽检测 安全帽分类 yolo安全帽识别

    安全帽识别 安全帽佩戴识别 安全帽检测 安全帽分类 yolo安全帽识别基于深度学习的安全帽佩戴检测安全帽识别安全帽检测安全帽分类yolo安全帽识别yolo安全帽tinyyolo安全帽识别安卓安全帽识别c++安全帽识别源码交流加wxdeeplearning_gogogo效果很棒,不服来战换不多说,奉上效果图…

  • 自动化测试平台(三):用户token验证及用户增删改查接口开发

    自动化测试平台(三):用户token验证及用户增删改查接口开发上一篇我们实现了用户登录的验证并返回token。那如何去校验请求的token是否有效呢?这篇内容为你讲解token的验证及用户管理(增删改查)的功能。

  • 启动ucosii之四OSTaskCreate()[通俗易懂]

    启动ucosii之四OSTaskCreate()[通俗易懂]函数原型来自OS_TASK.C/***********************************************************************************************************                                           CREATEATASK**************

  • easyui(一) 初始easyui「建议收藏」

    easyui(一) 初始easyui「建议收藏」分享使我快乐。哈哈~–WZY一、什么是easyui?学习一个东西,最重要的是知道它的定位(是干嘛的,基本的用法是什么,快速入门),其实easyui也非常简单,不要觉得很难。easyui就是一

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号