3/13作业

企业开发 2023-04-08 02:32:06 阅读次数: 0

TCP服务器、客户端搭建

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <string.h>
#include <unistd.h>

#define ERR_MSG(msg) do{\
	fprintf(stderr,"line:%d",__LINE__);\
	perror(msg);\
}while(0)

#define PORT 1588 //1024~49151
#define IP "192.168.31.244"

int main(int argc, const char *argv[])
{
	//创建流式套接字
	int sfd = socket(AF_INET,SOCK_STREAM,0);
	if(sfd<0)
	{
		ERR_MSG("socket");
		return -1;
	}
	printf("socket create success sfd=%d\n",sfd);

	//设置允许端口快速被重用
	int resue=1;
	if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&resue,sizeof(resue))<0)
	{
		ERR_MSG("setsockopt");
		return -1;
	}

	//填充服务器的地址信息结构体
	struct sockaddr_in sin;
	sin.sin_family      = AF_INET; //必须填AF_INET
	sin.sin_port        = htons(PORT);//端口号的网络字节序，1024~49151
	sin.sin_addr.s_addr = inet_addr(IP);    //IP地址，ifconfig查看
	
	//绑定
	if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))<0)
	{
		ERR_MSG("bind");
		return -1;
	}
	printf("bind success __%d__\n",__LINE__);

	//将套接字设置为被动监听状态
	if(listen(sfd,128)<0)
	{
		ERR_MSG("listen");
		return -1;
	}
	printf("listen success __%d__\n",__LINE__);

	//阻塞函数，阻塞等待客户端连接成功
	//当客户端连接成功后，会从已完成连接的队列头中获取一个客户端信息，
	//并生成一个新的文件描述符；新的文件描述符才是客户端通信的文件描述符
	struct sockaddr_in cin;  //存储连接成功的客户端地址信息
	socklen_t addrlen=sizeof(cin);
	int newfd=-1;
	newfd=accept(sfd,(struct sockaddr*)&cin,&addrlen);
	if(newfd<0)
	{
		ERR_MSG("accept");
		return -1;
	}
	printf("[%s:%d] newfd=%d 客户端连接成功\n",\
			inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),newfd);
	
	ssize_t res=-1;
	char buf[128]="";
	while(1)
	{
		bzero(buf, sizeof(buf));
		//循环接受客户端的信息
		res = recv(newfd, buf, sizeof(buf), 0);
		if(res < 0)
		{
			ERR_MSG("recv");
			return -1;
		}
		else if(0 == res)
		{
			fprintf(stderr,"[%s:%d] newfd=%d 客户端下线\n",\
					inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),newfd);
			break;
		}
		printf("[%s:%d]:%s\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port),buf);
		//发送
		strcat(buf, "*-*");
		if(send(newfd, buf, sizeof(buf), 0) < 0)
		{
			ERR_MSG("send");
			return -1;
		}
		printf("发送成功\n");
	}
	close(newfd);
	close(sfd);
	return 0;
}
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <string.h>
#include <unistd.h>

#define ERR_MSG(msg) do{\
	fprintf(stderr,"line:%d",__LINE__);\
	perror(msg);\
}while(0)

#define PORT 1588 //1024~49151
#define IP "192.168.31.244"

int main(int argc, const char *argv[])
{
	//创建流式套接字
	int cfd = socket(AF_INET,SOCK_STREAM,0);
	if(cfd<0)
	{
		ERR_MSG("socket");
		return -1;
	}
	printf("socket create success cfd=%d\n",cfd);

	//绑定----非必须绑定


	//填充服务器的地址信息结构体---给connect使用，指定连接哪个服务器
	struct sockaddr_in sin;
	sin.sin_family      = AF_INET; //必须填AF_INET
	sin.sin_port        = htons(PORT);//端口号的网络字节序，1024~49151
	sin.sin_addr.s_addr = inet_addr(IP);    //IP地址，ifconfig查看
	
	//连接服务器
	if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin))<0)
	{
		ERR_MSG("connect");
		return -1;
	}
	printf("connect success __%d__\n",__LINE__);

	ssize_t res=-1;
	char buf[128]="";
	while(1)
	{
		bzero(buf, sizeof(buf));
		//发送
		fgets(buf, sizeof(buf), stdin);
		buf[strlen(buf)-1] = 0;
		if(send(cfd, buf, sizeof(buf), 0) < 0)
		{
			ERR_MSG("send");
			return -1;
		}
		printf("发送成功\n");
		//循环接收信息
		bzero(buf,sizeof(buf));
		res = recv(cfd, buf, sizeof(buf), 0);
		if(res < 0)
		{
			ERR_MSG("recv");
			return -1;
		}
		else if(0 == res)
		{
			fprintf(stderr,"服务器下线\n");
			break;
		}
		printf("%s\n", buf);
	}

	close(cfd);
	return 0;
}

 UDP服务器、客户端搭建

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <string.h>
#include <unistd.h>

#define ERR_MSG(msg) do{\
	fprintf(stderr,"line:%d",__LINE__);\
	perror(msg);\
}while(0)

#define PORT 1600 //1024~49151
#define IP "192.168.31.244"

int main(int argc, const char *argv[])
{
	//创建流式套接字
	int sfd = socket(AF_INET,SOCK_DGRAM,0);
	if(sfd<0)
	{
		ERR_MSG("socket");
		return -1;
	}
	printf("socket create success sfd=%d\n",sfd);

	//允许端口快速被复用

	//填充服务器自身的地址信息结构体 AF_INET : man 7 IP
	struct sockaddr_in sin;
	sin.sin_family      = AF_INET;
	sin.sin_port        = htons(PORT);
	sin.sin_addr.s_addr = inet_addr(IP);

	//绑定--->必须绑定
	if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin))<0)
	{
		ERR_MSG("bind");
		return -1;
	}
	printf("bind success __%d__\n",__LINE__);

	char buf[128] = "";
	ssize_t res=0;
	struct sockaddr_in cin;
	socklen_t addrlen = sizeof(cin);

	while(1)
	{
		bzero(buf,sizeof(buf));
		res=recvfrom(sfd, buf, sizeof(buf), 0, (struct sockaddr*)&cin, &addrlen);
		//循环读取数据
		if(res<0)
		{
			ERR_MSG("recvfrom");
			return -1;
		}
		printf("[%s:%d]:%s\n", inet_ntoa(cin.sin_addr), ntohs(cin.sin_port),buf);
		//发送数据
		strcat(buf, "*-*");
		if(sendto(sfd, buf, sizeof(buf), 0, (struct sockaddr*)&cin, sizeof(cin))<0)
		{
			ERR_MSG("sendto");
			return -1;
		}
		printf("发送数据成功\n");
	}
	close(sfd);
	return 0;
}
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <string.h>
#include <unistd.h>

#define ERR_MSG(msg) do{\
    fprintf(stderr, "line:%d ", __LINE__);\
    perror(msg);\
}while(0)
                                                                                                                                                  
#define SER_PORT 6666               //1024~49151
#define SER_IP  "192.168.31.244"    //IP地址，本机IP ifconfig

#define CLI_PORT 8888
#define CLI_IP  "192.168.31.244"

int main(int argc, const char *argv[])
{
    //创建报式套接字
    int sfd = socket(AF_INET, SOCK_DGRAM, 0);
    if(sfd < 0)
    {
        ERR_MSG("socket");
        return -1;
    }
    printf("socket create success  sfd=%d __%d__\n", sfd, __LINE__);

    //绑定--->非必须绑定
    //如果不绑定，操作系统会自动绑定本机IP，从49152~65535范围内随机一个未被使用的端口号

    
    //填充客户端自身的地址信息结构体, AF_INET : man 7 ip
    struct sockaddr_in cin;
    cin.sin_family      = AF_INET;
    cin.sin_port        = htons(CLI_PORT);  //客户端自身的端口号，需要从1024~49151中选择没有被使用过的
    cin.sin_addr.s_addr = inet_addr(CLI_IP);    //客户端的本机IP

    if(bind(sfd, (struct sockaddr*)&cin, sizeof(cin)) < 0)
    {
        ERR_MSG("bind");
        return -1;
    }
    printf("bind success __%d__\n", __LINE__);
    ///

    //填充服务器的地址信息结构体
    //供给下面的sendto使用，
    struct sockaddr_in sin;
    sin.sin_family      = AF_INET;  //必须填AF_INET;
    sin.sin_port        = htons(SER_PORT);  //服务器绑定的端口，网络字节序
    sin.sin_addr.s_addr = inet_addr(SER_IP);    //服务器绑定的IP，本机IP ifconfig

    char buf[128] = "";
    ssize_t res = 0;

    struct sockaddr_in rcvAddr;     //存储获取到的数据包是从谁那里来的
    socklen_t addrlen = sizeof(rcvAddr);

    while(1)
    {
        bzero(buf, sizeof(buf));
        //发送
        fgets(buf, sizeof(buf), stdin);
        buf[strlen(buf)-1] = 0;

        //发送给服务器，所以上面的代码，需要填充好服务器的地址信息结构
        //想要发送给谁，就填谁的地址信息结构体
        if(sendto(sfd, buf, sizeof(buf), 0, (struct sockaddr*)&sin, sizeof(sin)) < 0)
        {
            ERR_MSG("sendto");
            return -1;
        }
        printf("发送成功\n");

        //接收数据
        //res = recvfrom(sfd, buf, sizeof(buf), 0, NULL, NULL);
        //res = recv(sfd, buf, sizeof(buf), 0);
        res = recvfrom(sfd, buf, sizeof(buf), 0, (struct sockaddr*)&rcvAddr, &addrlen);
        if(res < 0)
        {
            ERR_MSG("recvfrom");
            return -1;
        }
        printf("[%s : %d] : %s\n", \
                inet_ntoa(rcvAddr.sin_addr), ntohs(rcvAddr.sin_port), buf);


    }

    //关闭所有文件描述符
    close(sfd);
    return 0;
}

猜你喜欢

转载自blog.csdn.net/k_weihgl/article/details/129507867
今日推荐
周排行
Leetcode简单题61~80
解决zookeeper磁盘IO高的问题
多线程相关方法详解
Maven-setting.xml文件详解
Maven 项目的 classpath 理解
渊亭科技大数据笔试题
配置JVM内存分配
计算机网络个人学习笔记 （三）网络层 ：第三部分 连载
js中两个等号(==)和三个等号(===)的区别
用C程序自动打开电脑上的程序
每日归档
更多
2024-09-18(0)
2024-09-17(0)
2024-09-16(0)
2024-09-15(0)
2024-09-14(0)
2024-09-13(0)
2024-09-12(0)
2024-09-11(0)
2024-09-10(0)
2024-09-09(0)

代码天地 © 2018 codetd.com

境外服务器   最新电视剧2022