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)
blank

相关推荐

  • py爬取图片_Python爬取图片

    py爬取图片_Python爬取图片疲惫的生活里总要有些温柔梦想吧目标URL:http://www.win4000.com/meinvtag4_1.html爬取美桌网某个标签下的美女壁纸,点进详情页可以发现,里面是一组套图一…

  • js将json字符串转换成json对象_json对象转字符串

    js将json字符串转换成json对象_json对象转字符串json简介及json字符串转换成json对象JSON有两种表示结构:对象和数组对象结构以”{”大括号开始,以”}”大括号结束。中间部分由0或多个以”,”分隔的”key(关键字)/value(值)”对构成,关键字和值之间以”:”分隔,语法结构如代码 { key1:value1, key2:value2, … } 其中关键字是字符串,而值可以是字符串,数值,true,false,null,对象或数组数组结构以”[”开始,以”]”结束。中间由0或多个以”,”分隔

  • 【CSS3常用功能的写法】

    随着浏览器的升级,CSS3已经可以投入实际应用了。但是,不同的浏览…

  • Windows Server 2016 检查更新时,错误代码8024401C 的解决方案「建议收藏」

    Windows Server 2016 检查更新时,错误代码8024401C 的解决方案「建议收藏」这个问题的核心是连接不到更新服务器,有多种解决方案(如给SoftwareDistribution改名、疑难解答等),还有一部分情况是因为IPV6导致,关闭IPV6即可解决。如果其他办法都不好用可以试试这个~WindowsServer关闭ipv6的办法:开始->运行->输入Regedit进入注册表编辑器定位到:[HKEY_…

  • django配置文件详解_django配置redis

    django配置文件详解_django配置redis前言Django的配置文件settings.py用于配置整个网站的环境和功能,核心配置必须有项目路径、密钥配置、域名访问权限、App列表、中间件、资源文件、模板配置、数据库的连接方式基本配置信息

  • 计算机插了网线缺连不了网络,网线连不上网怎么回事_为什么网线插电脑上不了网-win7之家…

    计算机插了网线缺连不了网络,网线连不上网怎么回事_为什么网线插电脑上不了网-win7之家…当我们在使用有线网络的时候,都需要在电脑中插入网线才可以,但是有不少用户却遇到网线连不上网的情况,为什么网线插电脑上不了网呢?导致这样问题的原因有很多,为了帮助到大家,现在给大家讲解一下网线连不上网的几种解决方法,一起来看看吧。具体步骤如下:1、电脑插上网线却连不上网首先可能是网线接触不良导致的,可以将网线的两端拔下来重新连接再试试看能不能连上网,或者查看一下网线有无破损,将网线放在其他电脑上连接…

发表回复

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

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