c语言 多进程实现基于UDP的网络群聊聊天室

article/2025/10/23 5:32:20

功能

有新用户登录，其他在线的用户可以收到登录信息

有用户群聊，其他在线的用户可以收到群聊信息

有用户退出，其他在线的用户可以收到退出信息

服务器可以发送系统信息

流程图如下：

 

提示：

客户端登录之后，为了实现一边发送数据一边接收数据，可以使用多进程或者多线程

服务器既可以发送系统信息，又可以接收客户端信息并处理，可以使用多进程或者多线程

服务器需要给多个用户发送数据，所以需要保存每一个用户的信息，使用链表来保存数据传输的时候要定义结构体，结构体中包含操作码、用户名以及数据。

代码如下：

        服务器代码

//服务器代码
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <arpa/inet.h>#define ERRLOG(msg)                                        \do {                                                   \printf("%s %s %d:", __FILE__, __func__, __LINE__); \perror(msg);                                       \exit(-1);                                          \} while (0)typedef struct _MSG {char code; //操作码 ('L' 登录)，('C' 群聊)，('Q' 退出)char name[32];char txt[128];
} msg_t;
typedef struct _NODE {struct sockaddr_in clientaddr; //客户端网络信息结构体struct _NODE* next; //指针域
} node_t;int create_node(node_t **p);
int do_login(struct sockaddr_in clientaddr, node_t* phead, int sockfd, msg_t msg);
int do_chat(struct sockaddr_in clientaddr, node_t* phead, int sockfd, msg_t msg);
int do_quit(struct sockaddr_in clientaddr, node_t* phead, int sockfd, msg_t msg);
int main(int argc, char const* argv[])
{//入参合理性检查if (3 != argc) {printf("Usage : %s <IP> <PORT>\n", argv[0]);return -1;}// 1.创建套接字int sockfd = 0;if (-1 == (sockfd = socket(AF_INET, SOCK_DGRAM, 0))) {ERRLOG("socket error");}// 2.填充服务器网络信息结构体struct sockaddr_in serveraddr;memset(&serveraddr, 0, sizeof(serveraddr));serveraddr.sin_family = AF_INET;serveraddr.sin_port = htons(atoi(argv[2]));serveraddr.sin_addr.s_addr = inet_addr(argv[1]);socklen_t serveraddr_len = sizeof(serveraddr);//绑定if (-1 == bind(sockfd, (struct sockaddr*)&serveraddr, serveraddr_len)) {ERRLOG("bind error");}//用来保存客户端网络信息结构体struct sockaddr_in clientaddr;socklen_t clientaddr_len = sizeof(clientaddr);msg_t msg;pid_t pid = 0;if (-1 == (pid = fork())) {ERRLOG("fork error");} else if (0 == pid) {//子进程，用来接收数据并处理//创建用来保存客户端网络信息结构体的链表node_t *phead = NULL;create_node(&phead);phead->next =NULL;printf("聊天室已创建,等待用户加入群聊！！！\n");while(1) {memset(&msg, 0, sizeof(msg));memset(&clientaddr, 0, sizeof(clientaddr));if (-1 == recvfrom(sockfd, &msg, sizeof(msg), 0, (struct sockaddr*)&clientaddr, &clientaddr_len)) {ERRLOG("recvfrom error");}printf("[%s]: [%s]\n", msg.name, msg.txt);switch (msg.code) {case 'L':do_login(clientaddr, phead, sockfd,msg);break;case 'C':do_chat(clientaddr, phead, sockfd, msg);break;case 'Q':do_quit(clientaddr, phead, sockfd,  msg);break;}}} else if (0 < pid) {//父进程，用来发送系统消息//把父进程当作一个客户端，以群聊的方式发送消息给所有人（系统消息）msg.code = 'C';strcpy(msg.name, "系统");while (1){fgets(msg.txt, 128, stdin);msg.txt[strlen(msg.txt) - 1] = '\0';if (-1 == sendto(sockfd, &msg, sizeof(msg), 0, (struct sockaddr*)&serveraddr, serveraddr_len)) {ERRLOG("sendto error");}}}close(sockfd);return 0;
}
//创建链表节点的函数
int create_node(node_t** p)
{*p = (node_t*)malloc(sizeof(node_t));if (NULL == *p || NULL == p) {ERRLOG("malloc error");}
}
//登录的函数
int do_login(struct sockaddr_in clientaddr, node_t* phead, int sockfd, msg_t msg)
{//先遍历链表，将xxxx登录的消息 转发给所有人node_t* ptemp = phead;while (ptemp->next != NULL) {ptemp = ptemp->next;if (-1 == sendto(sockfd, &msg, sizeof(msg), 0, ((struct sockaddr*)&(ptemp->clientaddr)), sizeof(ptemp->clientaddr))) {ERRLOG("sendto error");}}//将新登录的用户头插到链表中node_t* pnew = NULL;create_node(&pnew);pnew->clientaddr = clientaddr;pnew->next = phead->next;phead->next = pnew;return 0;
}//群聊消息的函数
int do_chat(struct sockaddr_in clientaddr, node_t* phead, int sockfd, msg_t msg)
{//遍历链表，将群聊的数据发送给除自己外的所有人node_t* ptemp = phead;while (ptemp->next != NULL) {ptemp = ptemp->next;if (0 != memcmp(&clientaddr, &(ptemp->clientaddr), sizeof(clientaddr))) {if (-1 == sendto(sockfd, &msg, sizeof(msg), 0, ((struct sockaddr*)&(ptemp->clientaddr)), sizeof(ptemp->clientaddr))) {ERRLOG("sendto error");}}}
}int do_quit(struct sockaddr_in clientaddr, node_t* phead, int sockfd, msg_t msg)
{//将xxxx退出群聊的消息发送给除自己外所有的所有客户端，并且将自己在链表中删除node_t* ptemp = phead;while (ptemp->next != NULL) {if (0 != memcmp(&clientaddr, &(ptemp->clientaddr), sizeof(clientaddr))) {//判断是不是自己，不是自己就发送数据ptemp = ptemp->next;if (-1 == sendto(sockfd, &msg, sizeof(msg), 0, ((struct sockaddr*)&(ptemp->clientaddr)), sizeof(ptemp->clientaddr))) {ERRLOG("sendto error");}} else {//是自己，就将自己在链表中删除node_t* pdel = ptemp->next;ptemp->next = pdel->next;free(pdel);pdel == NULL;}}
}

        客户端代码

//客户端代码
#include <arpa/inet.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
#define ERRLOG(msg)                                        \do {                                                   \printf("%s %s %d:", __FILE__, __func__, __LINE__); \perror(msg);                                       \exit(-1);                                          \} while (0)typedef struct _MSG {char code; //操作码 ('L' 登录)，('C' 群聊)，('Q' 退出)char name[32];char txt[128];
} msg_t;
int main(int argc, const char* argv[])
{//入参合理性检查if (3 != argc) {printf("Usage : %s <IP> <PORT>\n", argv[0]);return -1;}// 1.创建套接字int sockfd = 0;if (-1 == (sockfd = socket(AF_INET, SOCK_DGRAM, 0))) {ERRLOG("socket error");}// 2.填充服务器网络信息结构体struct sockaddr_in serveraddr;memset(&serveraddr, 0, sizeof(serveraddr));serveraddr.sin_family = AF_INET;serveraddr.sin_port = htons(atoi(argv[2]));serveraddr.sin_addr.s_addr = inet_addr(argv[1]);socklen_t serveraddr_len = sizeof(serveraddr);msg_t msg;memset(&msg, 0, sizeof(msg));printf("请输入用户名: ");fgets(msg.name, 32, stdin);msg.name[strlen(msg.name) - 1] = '\0';//给服务器发送登录的数据包msg.code = 'L';strcpy(msg.txt, "加入群聊");if (-1 == sendto(sockfd, &msg, sizeof(msg), 0, (struct sockaddr*)&serveraddr, serveraddr_len)) {ERRLOG("sendto error");}pid_t pid = 0;if (-1 == (pid = fork())) {ERRLOG("fork error");} else if (0 == pid) {//子进程//接收由服务器发来的数据并打印while (1) {memset(&msg, 0, sizeof(msg));if (-1 == recvfrom(sockfd, &msg, sizeof(msg), 0, NULL, NULL)) {ERRLOG("recvfrom error");}printf("[%s]: [%s]\n", msg.name, msg.txt);}} else if (0 < pid) {//父进程while (1) {msg.code = 'C';fgets(msg.txt, 128, stdin);printf("我: ");msg.txt[strlen(msg.txt) - 1] = '\0';//判断是不是要退出if (!strncmp(msg.txt, "quit", 5)) {msg.code = 'Q';strcpy(msg.txt, "退出群聊");}if (-1 == sendto(sockfd, &msg, sizeof(msg), 0, (struct sockaddr*)&serveraddr, serveraddr_len)) {ERRLOG("sendto error");}if (!strcmp(msg.txt, "退出群聊")) {break;}}//先让子进程自杀kill(pid, SIGKILL);wait(NULL);close(sockfd);}return 0;
}


http://chatgpt.dhexx.cn/article/CC9PYB45.shtml

相关文章

Spring Boot使用WebSocket实现群聊

Spring Boot使用WebSocket实现群聊

1.通过https://start.aliyun.com创建一个spring boot项目 https://start.aliyun.com 所需依赖&#xff1a; 2.编写代码 目录&#xff1a; WebMvcConfig&#xff0c;监控用户页面&#xff1a; package com.example.mywbsk.config;import org.springframework.context.annotat…
阅读更多...
网络编程 : 基于UDP的网络群聊聊天室

网络编程 : 基于UDP的网络群聊聊天室

一、UDP网络编程: 1.1 流程 服务器流程: 创建用户数据报套接字 填充服务器的网络信息结构体 绑定套接字与服务器网络信息结构体 收发数据 关闭套接字 客户端流程&#xff1a; 创建用户数据报套接字 填充服务器的网络信息结构体 收发数据 关闭套接字 二、基于UDP的网络群聊聊天…
阅读更多...
Java网络编程：TCP实现群聊功能代码

Java网络编程：TCP实现群聊功能代码

Java网络编程&#xff1a;TCP实现群聊功能代码 实现的功能&#xff1a;群聊 具体操作流程的大致思路&#xff1a; 某个客户端发送消息&#xff0c;服务器将该消息转发给其余客户端&#xff08;除了自己&#xff09;。 代码一共分两个端&#xff08;服务器和客户端&#xff0…
阅读更多...
【Java教程】UDP实现群聊聊天室

【Java教程】UDP实现群聊聊天室

大家好&#xff0c;今天为大家带来了一个非常有意思的小程序——UDP实现的群聊聊天室。这个程序使用的UDP协议&#xff0c;并使用DatagramSocket的子类MulticastSocket实现组播&#xff0c;可以部署在一个局域网内的多台电脑上&#xff0c;并可以实现文字群聊。 本文将会按照以…
阅读更多...
群聊私聊天建群社交即时通讯H5系统开发

群聊私聊天建群社交即时通讯H5系统开发

群聊私聊天建群社交即时通讯H5系统开发 前端功能&#xff1a; 聊天、通讯录、动态、发现、我、多国语言、私聊、群聊、创建群聊&#xff08;设置免费、收费&#xff09;、发布动态、发信息&#xff08;图片、文字、红包、不支持语言&#xff09;、我的余额&#xff08;后台添加…
阅读更多...
socket.io实现简易版群聊

socket.io实现简易版群聊

最近学了点 websocket 的技术知识&#xff0c;了解到 node.js 有相关技术——socket.io可以实现&#xff0c;就想着实现一个简单版本的群聊。 先看看效果图 在浏览器中打开2个窗口&#xff0c;访问 http://localhost:3000/socket 目录结构 node 服务器代码实现 需要安装 exp…
阅读更多...
Go实现简易聊天室（群聊）

Go实现简易聊天室（群聊）

参考&#xff1a;Go 群聊 ( goroutine ) 语雀 基于websocket的聊天室&#xff0c;可进一步参考&#xff1a; (1) go实现聊天室(WebSocket方式) (2) Golang代码搜集-基于websocketvue.js的简易聊天室 闲着无聊ing~ 一直想着能用go整一些好玩的小工具&#xff0c;想着想着突然想…
阅读更多...
vue+websocket+nodejs创建聊天室- 创建群聊、加入群聊

vue+websocket+nodejs创建聊天室- 创建群聊、加入群聊

前言 前几篇我们讲了如何创建聊天室,一对一/一对多聊天&#xff0c;以及加已读未读消息状态。 这篇主要讲如何创建群聊和加入群聊。 还是跟之前一样&#xff0c;本文只写新加入的逻辑&#xff0c;之前逻辑请查看之前文章。 PS&#xff1a;效果稍微有点粗糙哈哈&#xff0c;不要…
阅读更多...
html群聊插件,团队群聊.html

html群聊插件,团队群聊.html

&#xfeff;团队群聊 $axure.utils.getTransparentGifPath function() { return resources/images/transparent.gif; }; $axure.utils.getOtherPath function() { return resources/Other.html; }; $axure.utils.getReloadPath function() { return resources/reload.html;…
阅读更多...
ajax聊天室创建群聊,js+node.js+socket.io实现聊天功能（私聊，创建群聊）

ajax聊天室创建群聊,js+node.js+socket.io实现聊天功能（私聊，创建群聊）

效果图： 这里启动了四个客户端进行测试 1. 登录，以及获取在线用户列表 2. 私聊功能 3. 群聊功能 偶然发现了WebSocket, 发现这个可以实时通信，在线聊天，所以就做了一个聊天工具的demo，记录一下 Socket.io WebSocket是js原生自带的，而Socket.io相当于是对WebSocket进行封装…
阅读更多...
php怎么做群聊,workerman实现群聊

php怎么做群聊,workerman实现群聊

服务端&#xff1a; require_once "../vendor/autoload.php"; use Workerman\Worker; $worker new Worker(‘websocket://0.0.0.0:2345‘); $worker->count 1; $worker->onWorkerStart function($data){ echo "连接开始\n"; }; $worker->onCon…
阅读更多...
致微信：我们什么时候重新定义群聊？

致微信：我们什么时候重新定义群聊？

你永远都不知道&#xff0c;自己到底有多少微信群。 你也很难想象&#xff0c;一个20多人的小团队&#xff0c;相互之间会建几百个群&#xff0c;然后当你需要群发一个文件/通知时&#xff0c;还是找不到合适的群&#xff0c;怎么办&#xff1f;重新拉一个群呗。 如果你加的群稍…
阅读更多...
怎么玩转LINE 群聊

怎么玩转LINE 群聊

关键词&#xff1a;LINE群聊 &#xff1b;SaleSmartly&#xff08;ss客服&#xff09; 一个 LINE 群聊是企业让客户了解其产品或服务的有效方式。如果使用得当&#xff0c; LINE 小组是企业同时快速培养与多个客户关系的绝佳场所。想了解更多吗&#xff1f;继续阅读&#xff0…
阅读更多...
微信怎么找群聊？找回微信群聊只需要这样…

微信怎么找群聊？找回微信群聊只需要这样…

如今社会中的日常生活已经离不开微信&#xff0c;微信是社交界的一股清流&#xff0c;聊天、视频、语音等等功能&#xff0c;而且支付功能的用途范围在国内也甚是广泛。微信怎么找群聊&#xff1f;是的&#xff0c;当多个好友之间相互认识&#xff0c;或者都有一个共同点的时候…
阅读更多...
免费tk域名+freewebhostingarea空间

免费tk域名+freewebhostingarea空间

1.申请免费域名 进入http://www.dot.tk&#xff08;推荐注册tk域名&#xff09;&#xff0c;申请一个新的域名&#xff0c;每次申请12个月以下是免费的&#xff0c;到期前14天可以免费续期 在此页面执行下一步之前&#xff0c;需要进行设置DNS服务器 2.获取DNS服务器 申请进…
阅读更多...
免费国外PHP+MYSQL空间申请

免费国外PHP+MYSQL空间申请

这是一个在匈牙利的免费空间,但是在网页上方挂广告条(可以用CSS屏蔽掉). 支持的以下内容管理系统: - Joomla - Wordpress - e107 - Drupal - Simple Machine Forum (SMF) - PHP-Nuke - phpBB - Elxis - MyBB - CMS Made Simple 具体申请步骤: 1.进入www.freeweb.hu 2. 3. 4. 5.…
阅读更多...
GIS地理空间数据免费获取

GIS地理空间数据免费获取

GIS地理空间数据免费获取 国内&#xff1a; 一、测绘地理信息局会提供权威的数据。 需要进入全国地理信息资源目录服务系统网站&#xff08;http://www.webmap.cn/main.do?methodindex&#xff09;&#xff0c;该网站提供&#xff1a;30米全球地表覆盖数据&#xff0c;Globe…
阅读更多...
15 个国外免费卫星图像数据源介绍

15 个国外免费卫星图像数据源介绍

有人说&#xff1a;一个人从1岁活到80岁很平凡&#xff0c;但如果从80岁倒着活&#xff0c;那么一半以上的人都可能不凡。 生活没有捷径&#xff0c;我们踩过的坑都成为了生活的经验&#xff0c;这些经验越早知道&#xff0c;你要走的弯路就会越少。 数据源 (Data Source) 顾名…
阅读更多...
新手建站十大免费空间推荐-稳定,可用的免费空间及其使用体验

新手建站十大免费空间推荐-稳定,可用的免费空间及其使用体验

新手建站十大免费空间推荐-稳定,可用的免费空间及其使用体验 新手建站十大 免费空间推荐-稳定,可用的 免费空间及其使用体验 一、OpenShift OpenShift 1、OpenShift空间是Red Hat的平台即服务的云计算平台(PaaS)&#xff0c;自成立以来就为大家提供 免费空间服务&#xff0c;深…
阅读更多...
国外免费云存储 空间

国外免费云存储 空间

苹果 微软 云存储 谷歌 亚马逊 Dropbox 摘要&#xff1a;为了能够让免费的云存储空间更大&#xff0c;我们就需要拥有更多的账户。现在有12种公共云存储的选择&#xff0c;最大可以得到112GB的免费存储空间&#xff0c;就让我们带着你慢慢分析他们的利弊。 如今市场上几乎所有提…
阅读更多...
推荐文章

Copyright @ 2022~2023