结论:
udp可以调用connect函数。
udp可以多次调用connect函数。
udp调用connect作用:
发送端:我们不需要再次指定也不能指定端口和ip地址
接收端:不必使用类似recvfrom的函数来获得数据报的发送者,一个已连接的udp套接字只与一个ip地址交换数据
已连接的udp如果错误会返回给发送端
udp多次调用connect作用:
指定一个新的ip和端口
断开套接字
适用于udp一对一的经常不断发送数据的情况,可以提高效率。
比如:
未connect的udp发送数据为,建立连接->发送数据->断开连接->建立连接->发送数据->断开连接。每次发送报文可能要做路由查询
connect的udp发送数据为,建立连接->发送数据->发送数据->发送数据->断开连接。
测试代码:
客户端:
#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <errno.h>
int main(int argc, char *argv[])
{
if(argc < 2){
printf("argument error\n");
exit(1);
}
char *ip = argv[1];
struct sockaddr_in server;
struct sockaddr_in client;
server.sin_family = AF_INET;
server.sin_port = htons(atoi(argv[2]));
inet_pton(AF_INET, ip, &server.sin_addr);
client.sin_family = AF_INET;
client.sin_port = htons(8000);
//注意本机测试可以为127.0.0.1,它是不经过网卡的,非本机测试必须指定为网卡对外的ip地址,ifconfig即可查看。
inet_pton(AF_INET, "192.168.23.3", &client.sin_addr);
int fd = socket(AF_INET, SOCK_DGRAM, 0);
if(fd < 0){
printf("create socket error\n");
exit(1);
}
int bret = bind(fd, (struct sockaddr*)&client, sizeof(client));
if(bret == -1){
printf("bind error\n");
exit(1);
}
int cret = connect(fd, (struct sockaddr*)&server, sizeof(server));
if(cret == -1){
printf("connect error\n");
printf("%d\n", cret);
//如果错误可以查看错误号,并比对表查看错误
strerror(errno);
printf("%d\n", errno);
exit(1);
}else{
printf("connect success!\n");
}
char buf[1000] = "hello world";
int n = sendto(fd, buf, 1000, 0, (struct sockaddr*)&server, sizeof(server));
//int n = write(fd, buf, 1000);
//int n = sendto(fd, buf, 1000, 0, NULL, 0);
//int n = send(fd, buf, 1000, 0);
if(n <= 0){
printf("send error\n");
}
return EXIT_SUCCESS;
}
服务端:
#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
int main(int argc, char *argv[])
{
if(argc < 2){
printf("argument error\n");
}
int port = atoi(argv[2]);
char *ip = argv[1];
struct sockaddr_in server;
bzero(&server, sizeof(server));
server.sin_family = AF_INET;
server.sin_port = htons(port);
inet_pton(AF_INET, ip, &server.sin_addr);
int udpfd = socket(AF_INET, SOCK_DGRAM, 0);
if(udpfd < 0){
printf("socket udp socketfd error\n");
exit(-1);
}
int ret = bind(udpfd, (struct sockaddr*)&server, sizeof(server));
if(ret == -1){
printf("bind error\n");
exit(-1);
}
struct sockaddr_in client;
socklen_t len = sizeof(client);
char buffer[2048];
while(1){
bzero(buffer, 2048);
//int n = recvfrom(udpfd, buffer, 2048, 0, (struct sockaddr*)&client, &len);
int n = read(udpfd, buffer, 2048);
printf("%s\n", buffer);
}
return EXIT_SUCCESS;
}