9月1日作业

news2024/11/25 9:59:46

思维导图

服务器代码

#include<myhead.h>

#define PORT 4567
#define IP "192.168.6.225"

struct msg //接收到的客户端信息结构体
{
	char type;
	char name[20];
	char txt[128];
};

//定义节点类型
typedef struct Node
{
    union
    {
        struct sockaddr_in cin;      //数据域
        int len;             //头结点数据域
    };

    struct Node *next;      //指针域
}Node, *LinkListPtr;

struct task
{
	LinkListPtr L;
	int sfd;
};

//创建链表
LinkListPtr list_create();

//判空操作
int list_empty(LinkListPtr L);

//申请结点封装数据函数
LinkListPtr node_buy(struct sockaddr_in cin);

//头插
int list_insert_head(LinkListPtr L, struct sockaddr_in cin);

//遍历链表,发送数据
int list_show(LinkListPtr L, int sfd, char *buf);

void *send_cli_msg(void *arg);

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 success\n");

	//允许端口能被快速复用
	int reuse = 1;
	if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0)
	{
		ERR_MSG("setsockopt");
		return -1;
	}
	printf("允许端口被快速复用成功\n");

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

	//bind函数绑定服务器地址信息
	if(bind(sfd, (struct sockaddr*)&sin, sizeof(sin)) < 0)
	{
		ERR_MSG("bind");
		return -1;
	}
	printf("bind success\n");

	struct sockaddr_in cin;  		 //定义客户端地址信息结构体
	socklen_t addrlen = sizeof(cin); 
	struct msg climsg;               //定义存放客户端信息结构体
	pthread_t tid;
	LinkListPtr L = list_create();
	struct task taskin;
	taskin.L = L;
	taskin.sfd = sfd;
	while(1)
	{
		//接受信息
		if(recvfrom(sfd, (struct msg*)&climsg, sizeof(climsg), 0, (struct sockaddr*)&cin, &addrlen) < 0)
		{
			ERR_MSG("recv");
			return -1;
		}

		if(climsg.type == 'L')
		{
			printf("----%s----已上线\n",climsg.name); //打印客户端上线
			char buf2[128];
			sprintf(buf2, "----%s----已上线", climsg.name);
			list_insert_head(L, cin);//加入链表
			list_show(L, sfd, buf2);
		}else if(climsg.type == 'C')
		{
			printf("%s: %s\n",climsg.name, climsg.txt);
			char buf2[128];
			strcpy(buf2, climsg.name);
			strcat(buf2, climsg.txt);
			list_show(L, sfd, buf2);
		}else if(climsg.type == 'Q')
		{
			printf("----%s----已下线\n",climsg.name); //打印客户端上线
			char buf2[128];
			sprintf(buf2, "----%s----已下线", climsg.name);
			list_show(L, sfd, buf2);
		}

		if(pthread_create(&tid, NULL, send_cli_msg, (void*)&taskin) != 0)
		{
			fprintf(stderr, "pthread_create failed__%d__\n", __LINE__);
		  return -1;
		  }

		//线程分离
		pthread_detach(tid);

	}

	if(close(sfd) < 0) //关闭文件描述符
	{
		ERR_MSG("close");
		return -1;
	}
	return 0;
}

void *send_cli_msg(void *arg)
{
	LinkListPtr L = ((struct task*)arg)->L;
	int sfd = ((struct task*)arg)->sfd;
	//群发消息
	char buf1[128] = "";
	bzero(buf1, sizeof(buf1));
	scanf("%s", buf1);
	list_show(L, sfd, buf1);
}

//创建链表
LinkListPtr list_create()
{
	//在堆区申请一个头结点类型
    LinkListPtr L = (LinkListPtr)malloc(sizeof(Node));
    if(NULL == L)
    {
        printf("创建失败\n");
        return NULL;
    }

    //创建成功,对节点进行初始化
    L->len = 0;       //初始链表长度为0
    L->next = NULL;     //链表上没有任何结点

    printf("创建链表成功\n");
    return L;
}

//判空操作
int list_empty(LinkListPtr L)
{
    //判断逻辑
    if(NULL == L)
    {
        printf("所给链表不合法\n");
        return -1;
    }

    //判断指针域的内容
    return L->next == NULL && L->len==0;
}


//申请结点封装数据函数
LinkListPtr node_buy(struct sockaddr_in cin)
{
    //在堆区申请结点
    LinkListPtr p = (LinkListPtr)malloc(sizeof(Node));
    if(NULL == p)
    {
        printf("结点申请失败\n");
        return NULL;
    }

    //结点申请成功,将数据封装进去
    p->cin = cin;
    p->next = NULL;

    return p;
}

//头插
int list_insert_head(LinkListPtr L, struct sockaddr_in cin)
{
    //判断逻辑
    if(NULL == L)
    {
        printf("所给链表不合法\n");
        return 0;
    }

    //调用申请结点封装数据
    LinkListPtr p = node_buy(cin);
    if(NULL==p)
    {
        return 0;
    }

    //结点已经准备好,头插逻辑
    p->next = L->next;
    L->next = p;

    //表的变化
    L->len++;

    printf("插入成功\n");
    return 1;
}

//遍历链表,发送数据
int list_show(LinkListPtr L, int sfd, char *buf)
{
	//判断逻辑
	if(NULL==L || list_empty(L))
	{
		printf("遍历失败\n");
		return -1;
	}

	//遍历逻辑
	printf("群发开始");
	//1、定义遍历指针从第一个结点开始
	LinkListPtr q = L->next;
	while(q != NULL)     //2、只要当前结点存在
	{
		//发送
		if(sendto(sfd, buf, 128, 0, (struct sockaddr*)&(q->cin), sizeof(q->cin)) < 0)
		{
			ERR_MSG("send");
			return -1;
		}
		q = q->next;        //4、指针后移
	}
	printf("\n");
}

客户端代码

#define PORT 4567
#define IP "192.168.6.225"

struct msg //客户端信息结构体
{
	char type;
	char name[20];
	char txt[128];
};

struct serinfo //线程函数传参结构体
{
	int cfd;
	struct sockaddr_in sin;
	char name[20];
};

void *send_ser_msg(void *arg);

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

	//允许端口能被快速复用
	int reuse = 1;
	if(setsockopt(cfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0)
	{
		ERR_MSG("setsockopt");
		return -1;
	}
	printf("允许端口被快速复用成功\n");

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

	char buf[128] = ""; 			 //定义字符串容器
	struct sockaddr_in cin;  		 //定义客户端地址信息结构体
	socklen_t addrlen = sizeof(cin); 
	pthread_t tid;
	struct serinfo info;
	info.cfd = cfd;
	info.sin = sin;
	struct msg climsg;
	//登录操作
	char name[20];
	printf("请输入用户名\n");
	scanf("%s", name);
	climsg.type = 'L';
	strcpy(climsg.name, name);
	strcpy(climsg.txt, "");
	strcpy(info.name, name);
	//发送
	if(sendto(cfd, (struct msg*)&climsg, sizeof(climsg), 0, (struct sockaddr*)&sin, sizeof(sin)) < 0)
	{
		ERR_MSG("sendto");
		return -1;
	}
	while(1)
	{
		if(pthread_create(&tid, NULL, send_ser_msg, (void*)&info) != 0)
		{
			fprintf(stderr, "pthread_create failed__%d__\n", __LINE__);
			return -1;
		}

		bzero(buf, sizeof(buf));
		//接受信息
		if(recvfrom(cfd, buf, sizeof(buf), 0, (struct sockaddr*)&sin, &addrlen) < 0)
		{
			ERR_MSG("recv");
			return -1;
		}
		printf("server[%s:%d] rcvdata = %s\n", inet_ntoa(sin.sin_addr),\
				ntohs(sin.sin_port), buf);

		//线程分离
		pthread_detach(tid);

	}

	if(close(cfd) < 0) //关闭文件描述符
	{
		ERR_MSG("close");
		return -1;
	}
	return 0;
}

void *send_ser_msg(void *arg)
{
	int cfd = ((struct serinfo*)arg)->cfd;
	struct sockaddr_in sin = ((struct serinfo*)arg)->sin;
	char name[20];
	strcpy(name, ((struct serinfo*)arg)->name);
	char buf1[128] = "";
	struct msg climsg;
	while(1)
	{
		scanf("%s", buf1);
		if(strcmp((buf1), "quit") == 0)
		{
			climsg.type = 'Q';
			strcpy(climsg.name, name);
			strcpy(climsg.txt, "quit");
			if(sendto(cfd, (struct msg*)&climsg, sizeof(climsg), 0, (struct sockaddr*)&sin, sizeof(sin)) < 0)
			{
				ERR_MSG("sendto");
				return NULL;
			}
			exit(0);
		}
		else
		{
			climsg.type = 'C';
			strcpy(climsg.name, name);
			strcpy(climsg.txt, buf1);
			//发送
			if(sendto(cfd, (struct msg*)&climsg, sizeof(climsg), 0, (struct sockaddr*)&sin, sizeof(sin)) < 0)
			{
				ERR_MSG("sendto");
				return NULL;
			}
		}
	}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1004082.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

springboot+springSecurity+jwt实现登录认证后令牌授权

springbootspringSecurityjwt实现登录认证后令牌授权&#xff08;已绑定整个项目的源码&#xff09; 目录 springbootspringSecurityjwt实现登录认证后令牌授权&#xff08;已绑定整个项目的源码&#xff09;一、自定义数据源登录认证1、实现spring security中UserDetails类2、…

22.1 JavaScript 基础

1. JavaScript 1.1 简介 JavaScript(简称js): 是一种广泛应用于网页开发的脚本语言. 它被用于增强网页的交互性和动态性, 可以让开发者对网页进行操作和控制. JavaScript可用于处理用户输入, 改变网页的内容, 动态加载数据, 创建动画效果等. 它在现代的Web开发中扮演着至关重…

【GIS】栅格转面报错:ERROR 000864输入栅格: 输入不在定义的属性域内。 ERROR 000863: 无效的 GP 数据类型

问题: 栅格转面(矢量)时,ArcGIS窗口显示:ERROR 000864输入栅格: 输入不在定义的属性域内。 ERROR 000863: 无效的 GP 数据类型. 原因: 栅格转面时输入的栅格数据集的字段必须是整型. 解决办法: 使用Spatial Analyst中的转为整型工具,将栅格数据转为整型后再进行栅格转面的操作…

pycharm增加新的编译器

安装了python2和3的电脑上&#xff0c;使用pycharm时候&#xff0c;最好将2和3都加入其编译器。 方法&#xff1a; 1、File-settings... 2、如图选择&#xff0c;然后点击加号&#xff0c;添加python2或者3的exe

通常用哪些软件做数据可视化大屏?

一般就两种&#xff0c;一种是可视化大屏编辑软件&#xff0c;另一种则是BI系统&#xff08;BI数据可视化工具&#xff09;。考虑到数据来源多、数据量大以及数据分析效率、直观易懂性等实实在在的客观问题&#xff0c;建议采用BI系统来制作数据可视化大屏。 BI系统做可视化大…

首个国家级元宇宙计划发布,和数集团迎来赛道发展新机遇

近日&#xff0c;工业和信息化部、教育部、文化和旅游部、国务院国资委、国家广播电视总局办公厅五部门联合印发《元宇宙产业创新发展三年行动计划&#xff08;2023-2025年&#xff09;》&#xff08;以下简称《计划》&#xff09;&#xff0c;其中在发展目标中提到要培育3-5家…

手把手教你搭建WordPress博客网站并发布至公网

文章目录 概述前置准备1 安装数据库管理工具1.1 安装图形图数据库管理工具&#xff0c;SQL_Front 2 创建一个新数据库2.1 创建数据库2.2 为数据库创建一个用户 3 安装PHP7.44. 创建一个新站点4.1 创建站点根目录4.2 访问WordPress官网&#xff0c;下载最新版本的压缩包4.3 创建…

Linux之yum/git的使用

目录 一、yum 1、关于yum 2、yum的操作 ①、yum list ②、yum install ③、yum remove 二、git 1、Linux中连接gitee 2、git的操作 ①git add [文件] ②git commit -m "提交日志" ③git push 3、可能出现的问题 ①配置用户名、邮箱 ②出现提交冲突 ③…

2023在家做什么副业兼职能赚钱?分享几种线上兼职副业!

现代社会&#xff0c;很多人都渴望能够在家中轻松自由地赚取一份收入。无论是为了照顾孩子、追求个人兴趣还是摆脱繁忙的通勤&#xff0c;都有越来越多的人开始探索如何在家赚钱。幸运的是&#xff0c;随着技术的进步和互联网的普及&#xff0c;我们现在有更多的机会去实现这个…

halcon对图片进行处理基础

实例图片 C:\Users\Public\Documents\MVTec\HALCON-19.11-Progress\examples\images*读取图片 read_image (Image1, D:/c/image/1.png) *读取大小 get_image_size(Image1,Width, Height) *创建窗口 dev_close_window() dev_open_window(0, 0, Width, Height, black, WindowHan…

D. Cyclic Operations Codeforces Round 897 (Div. 2)

Problem - D - Codeforces 题目大意&#xff1a;有一个长度为n的数组a&#xff0c;每次操作可以选取一个长度为k的所有数互不相同的数组b&#xff0c;令a[bi]b[i%k1]&#xff0c;问能否将一个全为零的数组通过任意次操作得到a 1<k<n<1e5 思路&#xff1a;通过上述操…

如何用Jmeter编写脚本压测

随着商业业务不断扩张&#xff0c;调用adsearch服务频率越来越高&#xff0c;所以这次想做个压测&#xff0c;了解目前多少并发量可以到达adsearch服务的界值。 这次选用的jmeter压测工具&#xff0c;压测思路如图&#xff1a; 同时&#xff0c;我也准备了一份软件测试面试视频…

Windows C++ VS2022 OpenVINO 物体检测 Demo

准备工作&#xff1a; 1、下载opencv 地址&#xff1a;Releases - OpenCV 我下载的是opencv-4.5.5&#xff0c;存放的路径为&#xff1a; 2、下载OpenVino 地址&#xff1a;https://storage.openvinotoolkit.org/repositories/openvino/packages/2023.0.1/ 我存放的路径为…

蓝牙运动耳机哪款好用、最好用的运动耳机推荐

运动耳机现如今可谓是备受热捧的运动潮流单品&#xff0c;消费者对于耳机的需求实际上非常多元化。一款出色的运动耳机不仅要满足基本的运动需求&#xff0c;还需要具备丰富的使用功能&#xff0c;这直接决定了耳机的附加价值。接下来&#xff0c;我将向大家推荐5款佩戴舒适、牢…

HarmonyOS应用开发—资源分类与访问

应用开发过程中&#xff0c;经常需要用到颜色、字体、间距、图片等资源&#xff0c;在不同的设备或配置中&#xff0c;这些资源的值可能不同。 应用资源&#xff1a;借助资源文件能力&#xff0c;开发者在应用中自定义资源&#xff0c;自行管理这些资源在不同的设备或配置中的表…

idea装载jerbel以及文件上传下载

一、JRebel 1.1 Jrebel介绍 JRebel是一个Java开发工具&#xff0c;它是一款用于实时代码重载的插件。它的主要功能是在不重新启动应用程序的情况下&#xff0c;将修改后的Java代码实时应用到正在运行的应用程序中&#xff0c;从而加快开发周期&#xff0c;提高开发效率。 实…

算法通关村第十九关:青铜-动态规划是怎么回事

青铜挑战-动态规划是怎么回事 动态规划&#xff08;简称DP&#xff0c;Dynamic Programming&#xff09;&#xff1a;最热门、最重要的算法之一。面试中大量出现&#xff0c;整体偏难。 1. 热身&#xff1a;重复计算和记忆化搜索&#xff08;如何说一万次"我爱你"&…

Windows驱动开发(一)

1. 引言 很难为术语 “驱动程序”提供一个精确的定义。 就最基本的意义而言&#xff0c;驱动程序是一个软件组件&#xff0c;可让操作系统和设备彼此通信。 例如&#xff0c;假设应用程序需要从设备中读取某些数据。 应用程序会调用由操作系统实现的函数&#xff0c;操作系统…

WPF——Control与Template理解

文章目录 一、前言二、控件三、模板3.1 DataTemplate3.2 ControlTemplate3.3 ContentPresenter 四、结语 一、前言 最近又翻看了下刘铁猛的《深入浅出WPF》&#xff0c;发现对模板章节中的部分内容有了更深的体会&#xff0c;所以写篇文扯扯。 文章标题是Control与Template&a…

画流程图用什么软件好?安利这几款

画流程图用什么软件好&#xff1f;画流程图是一项非常重要的技能&#xff0c;它可以帮助我们更好地规划和管理工作流程&#xff0c;提高工作效率。在现代的企业中&#xff0c;流程图已经成为了不可或缺的一部分&#xff0c;它可以用来描述各种业务流程、流程控制、组织结构等等…