BBS客户端服务器的编写

2024-05-10 23:44
文章标签 服务器 编写 客户端 bbs

本文主要是介绍BBS客户端服务器的编写，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

根据网络编程中的内容，我们本篇文章将讲解一个bbs通信的项目，首先让我们了解一下什么是bbs.

一、bbs介绍

BBS，即Bulletin Board System的缩写，中文译为“电子公告板系统”或“网络论坛”。它是一个在网络上进行信息交流和讨论的平台。早期的BBS主要用于公布股市价格等信息，只能在苹果计算机上运行。随着个人计算机的普及，BBS逐渐转移到个人计算机上，功能也得到了扩展，用户可以在BBS上发布文章、收发电子邮件、交流聊天、发布广告等。BBS的发展历程可以追溯到20世纪70年代，最早的BBS系统出现在美国芝加哥。在中国，第一个BBS站出现在1991年。如今，BBS仍然是一种常见的网络交流方式，被广泛应用于教学、推广、地方交流和一般性讨论等领域。

二、bbs客户端

2.1、客户端流程图

简单来看

  1. 使用socket创建通讯句柄
  2. 使用connect连接到主机
  3. 使用select进行键盘和网络的多路选择
    • 如果有键盘数据，则读入键盘数据并发送到网络
    • 如果有网络数据，则接收网络数据并上屏显示
  4. 判断是否接收到退出符，如果是，则使用close断开网络连接并结束程序

 2.2实现代码

首先进行初始化，使用套接字与服务器进行连接

#include <sys/types.h>			
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <fcntl.h>int init_socket(char *ip)
{//1. 创建一个套接字int sockfd = socket(AF_INET, SOCK_STREAM, 0);//2 定义一个 sockaddr_in 结构体,并初始化struct  sockaddr_in  serveraddr;serveraddr.sin_family = AF_INET;serveraddr.sin_port = htons(2000); //  h:host  n:network s : shortinet_aton(ip, &serveraddr.sin_addr);//3. connect 服务器connect(sockfd, (struct sockaddr*)&serveraddr, sizeof(serveraddr));return  sockfd;
}

init_socket函数的作用是初始化一个套接字，并使用该套接字连接到指定的服务器。

函数接受一个参数ip，表示服务器的IP地址。函数内部首先使用socket系统调用创建了一个套接字，并指定了地址族（AF_INET表示IPv4）和套接字类型（SOCK_STREAM表示面向连接的TCP协议）。然后，函数定义了一个sockaddr_in结构体变量serveraddr，用于存储服务器的地址信息。

接下来，函数对serveraddr结构体进行了初始化。其中，sin_family字段被设置为AF_INET，表示使用IPv4地址族。sin_port字段被设置为htons(2000)，表示服务器的端口号是2000。htons函数用于将主机字节序的16位整数转换为网络字节序。sin_addr字段被设置为使用inet_aton函数将传入的IP地址字符串转换为网络字节序的二进制形式。

最后，函数使用connect系统调用尝试连接到服务器。如果连接成功，则返回套接字描述符sockfd；如果连接失败，则返回错误代码。

 

 主函数

int main(int argc, char *argv[])
{char buf[1024]={0};int result,fd;fd_set rdset;int sockfd = init_socket(argv[1]);while(1){FD_ZERO(&rdset);FD_SET(sockfd, &rdset);FD_SET(0, &rdset);if(select(sockfd+1, &rdset, NULL, NULL, NULL)<0){perror("select:");return -1;}if(FD_ISSET(sockfd,&rdset))//网络有数据可读{memset(buf,0,sizeof(buf));result = recv(sockfd, buf, sizeof(buf)-1, 0);if(result < 0){perror("recv:");return -1;}else if(result == 0){printf("服务器断开连接\n");break;}else{buf[result] = 0; //放 \0 作为buf的结束标志printf("%s\n",buf);}}if(FD_ISSET(0, &rdset)) //键盘有数据可读{memset(buf,0,sizeof(buf));if(fgets(buf, sizeof(buf), stdin)){write(sockfd,buf,strlen(buf));}}}
}

这段代码是C语言编写的一个网络通信程序的主函数。它实现了一个简单的客户端，可以与服务器进行数据的发送和接收。

函数的开头定义了一些变量：

  • char buf[1024]：用于存储接收到的数据或要发送的数据的缓冲区。
  • int result：用于存储接收或发送操作的结果。
  • fd_set rdset：用于存储要监视的文件描述符的集合。

然后，程序调用init_socket函数来初始化套接字，并将服务器的IP地址作为参数传递给它。init_socket函数返回一个套接字描述符sockfd，用于与服务器进行通信。

接下来是一个无限循环，用于不断监视套接字和标准输入是否有数据可读。循环的开始，程序使用FD_ZERO函数清空文件描述符集合rdset，然后使用FD_SET函数将套接字描述符sockfd和标准输入的文件描述符0添加到集合中。

然后，程序调用select函数来监视文件描述符集合。如果select函数返回值小于0，表示发生了错误，程序会调用perror函数打印错误信息并返回-1。

如果select函数返回值大于0，表示有文件描述符可读。程序首先检查套接字描述符是否可读，即FD_ISSET(sockfd, &rdset)是否为真。如果是真，表示网络上有数据可读，程序会使用recv函数接收数据，并将接收到的数据存储在缓冲区buf中。如果接收操作成功，程序会将接收到的数据打印到屏幕上。如果接收到的数据长度为0，表示服务器断开了连接，程序会打印提示信息并退出循环。

如果套接字描述符不可读，程序会检查标准输入是否可读，即FD_ISSET(0, &rdset)是否为真。如果是真，表示键盘上有数据可读，程序会使用fgets函数读取一行数据，并将读取到的数据存储在缓冲区buf中。然后，程序会使用write函数将数据发送给服务器。

总的来说，这个主函数实现了一个简单的网络通信客户端，可以与服务器进行数据的发送和接收。它使用select函数来监视套接字和标准输入，并根据不同的情况进行相应的操作。

三、bbs服务器

3.1 服务器流程

  1. 使用socket创建监听句柄
  2. 使用bind绑定端口
  3. 使用listen监听端口
  4. 使用accept等待客户接入，并使用pthread_create创建线程与客户交互
  5. 在线程中，使用write发送选择菜单，并使用read等待客户选择
    • 如果选择有效，则调用addClient添加新客户到链表中
    • 使用read等待客户发布消息，并将消息保存到相应类型的文件中
    • 调用multicastMsg将消息转发到相同类型的其他客户
  6. 判断是否接收到退出标识，如果是，则调用removeClient删除该客户并关闭通讯句柄，然后线程退出

3.2 实现代码

首先进行一定义

//定义类型枚举量
typedef enum ClientType
{NEWS_TYPE,ENTERTAINMENT_TYPE,SUPPLY_TYPE
}ClientType;//定义客户节点量
typedef struct ClientNode
{int sockfd;enum ClientType type;char logname[20]; //登录名struct ClientNode * next;
}ClientNode;ClientNode *head=NULL;
pthread_rwlock_t lockList = PTHREAD_RWLOCK_INITIALIZER;
pthread_rwlock_t lockFile = PTHREAD_RWLOCK_INITIALIZER;char *name_msg = "请输入登录名:\n";
char *menu="\n"
" -------------------------\n"	
"      登录类型选择              \n"
"      1)  新闻              \n"
"      2)  娱乐              \n"
"      3)  交易              \n"
" -------------------------\n"	
"请选择登录的类目:";
  • ClientType：这是一个枚举类型，表示了客户端的类型，包括新闻（NEWS_TYPE）、娱乐（ENTERTAINMENT_TYPE）和供应（SUPPLY_TYPE）三种类型。
  • ClientNode：这是一个结构体类型，表示了链表中的一个节点，包含了客户端的套接字描述符（sockfd）、类型（type）、登录名（logname）以及指向下一个节点的指针（next）。
  • head：这是一个指向ClientNode类型的指针，表示了链表的头节点。初始值为NULL，表示链表为空。
  • lockList和lockFile：这两个是读写锁（pthread_rwlock_t）类型的变量，用于对链表和文件进行并发访问的控制。初始化为PTHREAD_RWLOCK_INITIALIZER，表示锁已经被初始化。

 初始化套接字，等待客户端请求

int init_socket(char *ip)
{//1. 创建一个套接字int sockfd = socket(AF_INET, SOCK_STREAM, 0);//2 定义一个 sockaddr_in 结构体,并初始化struct  sockaddr_in  serveraddr;serveraddr.sin_family = AF_INET;serveraddr.sin_port = htons(2000); //  h:host  n:network s : shortserveraddr.sin_addr.s_addr = htonl(INADDR_ANY);// INADDR_ANY  有内核帮你找一个合适的网卡IP地址socklen_t addrlen = sizeof(serveraddr);int on=1;setsockopt(sockfd, SOL_SOCKET, SO_REUSEPORT, &on, sizeof(on));int r =  bind(sockfd,(struct sockaddr *)&serveraddr,addrlen);if(r < 0){perror("bind:");return -1;}r = listen(sockfd, 5);if(r < 0){perror("listen:");return -1;}return  sockfd;
}

使用socket系统调用创建一个套接字，指定地址族为AF_INET（表示IPv4），类型为SOCK_STREAM（表示面向连接的TCP协议）。

定义一个sockaddr_in结构体变量serveraddr，用于存储服务器的地址信息。

初始化serveraddr结构体的各个字段：

sin_family字段被设置为AF_INET，表示使用IPv4地址族。

sin_port字段被设置为htons(2000)，表示服务器的端口号为2000。htons函数用于将主机字节序的16位整数转换为网络字节序。

sin_addr.s_addr字段被设置为htonl(INADDR_ANY)，表示服务器可以接受来自任何IP地址的连接请求。htonl函数用于将主机字节序的32位整数转换为网络字节序。

使用setsockopt系统调用设置套接字选项，允许多个进程或线程同时绑定到同一个端口号上。

使用bind系统调用将套接字绑定到指定的IP地址和端口号上。如果绑定失败，则打印错误信息并返回-1。

使用listen系统调用开始监听套接字，等待客户端的连接请求。如果监听失败，则打印错误信息并返回-1。

如果一切正常，则返回套接字描述符sockfd。

 使用头插法，插入客户，形成一个链表

void insertNode(ClientNode * p)
{p->next = head;head = p;
}

 客户端断开连接后，删除此节点

void DeleteNode(ClientNode *client)
{ClientNode *p = head;ClientNode *q = head;while(p){if(p->sockfd == client->sockfd){if(p == q){//你要删除的是 第一个节点headhead = p->next;}q->next = p->next;free(p);break;}q = p; //保存上一节点p = p->next; }
}

  1. 定义两个指针变量p和q，其中p用于遍历链表，q用于保存p的前一个节点。
  2. 使用while循环遍历链表，直到找到要删除的节点或到达链表的末尾。
  3. 在循环内部，使用if语句判断当前节点是否为要删除的节点。如果当前节点的sockfd字段与要删除节点的sockfd字段相等，则表示找到了要删除的节点。
  4. 如果要删除的节点是链表的第一个节点，即p == q，则直接将头节点指向下一个节点，即head = p->next;。
  5. 如果要删除的节点不是链表的第一个节点，则将q的next指针指向p的下一个节点，即q->next = p->next;，从而将p从链表中删除。
  6. 使用free函数释放被删除节点所占用的内存空间。
  7. 使用break语句退出循环。

 发送历史记录

void sendHistory(char *filename,int newfd)
{char buf[1024]={};int n;FILE *fp = fopen(filename, "r");if(fp==NULL){perror("fopen:");return ;}while(fgets(buf, sizeof(buf),fp)){write(newfd, buf, strlen(buf));}fclose(fp);
}
  1. 定义一个字符数组buf作为缓冲区，用于存储从文件中读取的数据。
  2. 使用fopen函数以只读模式打开指定文件。如果文件打开失败，则打印错误信息并返回。
  3. 使用fgets函数从文件中读取一行数据，并将其存储在缓冲区buf中。如果读取成功，则使用write函数将数据发送给套接字连接。
  4. 重复步骤3，直到文件中的所有数据都读取完毕。
  5. 使用fclose函数关闭文件。

保存文件

void save2File(char *filename, char *buf)
{FILE *fp;fp = fopen(filename, "a+"); // 以追加和读写模式打开文件if (fp != NULL) {fputs(buf, fp); // 将数据写入文件末尾fclose(fp); // 关闭文件} else {perror("Error opening file"); // 如果文件打开失败，打印错误信息}
}

函数的实现步骤如下：

  1. 使用fopen函数以追加和读写模式（"a+"）打开指定的文件。如果文件不存在，则会创建一个新文件。如果文件已经存在，则会在文件末尾追加数据。
  2. 如果文件打开成功（fp不为NULL），则使用fputs函数将数据缓冲区buf中的内容写入到文件中。
  3. 无论文件打开是否成功，都需要使用fclose函数关闭文件。
  4. 如果文件打开失败（fp为NULL），则使用perror函数打印错误信息。

将一条消息从一个客户端节点广播到所有类型相同的其他客户端节点

void multicastNode(ClientNode * client,char * buf)
{ClientNode *p = head;while(p){//类型和本人相同，又不是本人的节点if((p->type == client->type) && (p->sockfd != client->sockfd) ){write(p->sockfd, client->logname,strlen(client->logname));write(p->sockfd," 说: ", 6);write(p->sockfd, buf, strlen(buf));}p= p->next;}
}
  1. 定义一个指针变量p，用于遍历链表。
  2. 使用while循环遍历链表，直到到达链表的末尾。
  3. 在循环内部，使用if语句判断当前节点是否满足广播条件，即类型与指定节点相同且不是指定节点本身。
  4. 如果满足条件，则使用write系统调用将指定节点的登录名、消息内容发送给当前节点。
  5. 继续遍历链表，直到到达链表的末尾。

需要注意的是，在调用multicastNode函数之前，需要确保链表中已经存在至少两个节点，并且指定节点的类型不为空。

 主函数

int main(int argc, char *argv[])
{char buf[1024]={0};int result,fd, newfd;fd_set rdset;pthread_t tid;struct sockaddr_in re;socklen_t addrlen = sizeof(re);int sockfd = init_socket(argv[1]);while(1){newfd = accept(sockfd, (struct sockaddr *)&re,&addrlen);printf("newfd=%d\n", newfd);printf("IP:%s\n", inet_ntoa(re.sin_addr));pthread_create(&tid, NULL, talk2client, &newfd);}}
  1. 定义一些变量：
    • char buf[1024]：用于存储接收到的数据或要发送的数据的缓冲区。
    • int result：用于存储接收或发送操作的结果。
    • int fd：文件描述符，未使用。
    • int newfd：用于存储新连接的套接字描述符。
    • fd_set rdset：用于存储要监视的文件描述符的集合。
    • pthread_t tid：用于存储新线程的ID。
    • struct sockaddr_in re：用于存储客户端的地址信息。
    • socklen_t addrlen：用于存储客户端地址信息的长度。
  2. 调用init_socket函数初始化服务器套接字，并将服务器的IP地址作为参数传递给它。init_socket函数返回一个套接字描述符sockfd，用于监听客户端的连接请求。
  3. 进入一个无限循环，不断接受客户端的连接请求并创建线程来处理。
    • 调用accept函数接受一个客户端的连接请求，并将新连接的套接字描述符存储在newfd中。同时，将客户端的地址信息存储在re中。
    • 打印出新连接的套接字描述符和客户端的IP地址。
    • 调用pthread_create函数创建一个新线程，并将talk2client函数的地址和newfd的地址作为参数传递给它。talk2client函数是用于处理客户端请求的函数，它将在新的线程中执行。
  4. 由于是无限循环，服务器将一直运行下去，不断接受新的客户端连接并创建线程来处理。

 线程实现

void *talk2client(void *arg)
{int result;int newfd = *(int *)arg;char * filename;char buf[200]={};//设置线程为 分离属性：自己回收 线程资源pthread_detach(pthread_self());ClientNode * p = (ClientNode *)malloc(sizeof(ClientNode));memset(p, 0, sizeof(ClientNode));memset(buf,0, sizeof(buf));// 1.填入：sockfd p->sockfd = newfd;p->next = NULL;//2.读登录名write(newfd, name_msg, strlen(name_msg));result = recv(newfd, buf, sizeof(buf)-1, 0);buf[result-1] = 0; //去掉行尾的 '\n'printf("buf:%s\n", buf);strcpy(p->logname,buf);//3. 登录的类型write(newfd, menu, strlen(menu));result = recv(newfd, buf, sizeof(buf)-1, 0);if(result<=0){printf("客户端断开连接\n");close(newfd);pthread_exit(NULL);}buf[result-1] = 0; //去掉行尾的 '\n'printf("buf:%s\n", buf);if(buf[0]=='1'){p->type = NEWS_TYPE;filename = "bbs_news.txt";}else if(buf[0]=='2'){p->type = ENTERTAINMENT_TYPE;filename = "bbs_trans.txt";}else if(buf[0]=='3'){p->type = SUPPLY_TYPE;filename = "bbs_fun.txt";}//插入客户结点到head链表pthread_rwlock_wrlock(&lockList);insertNode(p);pthread_rwlock_unlock(&lockList);//发送历史记录pthread_rwlock_rdlock(&lockFile);sendHistory(filename,newfd);pthread_rwlock_unlock(&lockFile);//进入主循环while(1){result = recv(newfd, buf, sizeof(buf)-1, 0);if(result < 0){perror("recv:");continue;}else if(result == 0){printf("客户端断开连接\n");pthread_rwlock_wrlock(&lockList);DeleteNode(p);pthread_rwlock_unlock(&lockList);break;}else {if(strncmp(buf, "exit\n", 5)==0){printf("客户端要主动离开\n");pthread_rwlock_wrlock(&lockList);DeleteNode(p);pthread_rwlock_unlock(&lockList);break;}//保存记录！buf[result -1]= 0; // 去掉 最后 \n 符号pthread_rwlock_wrlock(&lockFile);save2File(filename, buf);pthread_rwlock_unlock(&lockFile);// 多播信息pthread_rwlock_rdlock(&lockList);multicastNode(p, buf);pthread_rwlock_unlock(&lockList);}}
}

talk2client函数是一个处理与客户端通信的函数，它通过套接字与客户端进行数据的发送和接收。该函数被main函数中的pthread_create调用，在独立的线程中运行，以处理每个连接到服务器的客户端。

函数首先获取传递进来的参数，即新的套接字描述符newfd。然后，它创建一个ClientNode结构体的对象p，用于存储客户端的信息，如套接字描述符和登录名。接下来，函数与客户端进行交互，首先发送一个提示信息，要求客户端输入登录名，然后接收客户端的登录名并存储在p中。

接着，函数向客户端发送一个菜单，让客户端选择登录的类型，然后接收客户端的选择，根据选择设置p中的类型字段，并确定要保存消息的文件名。然后，函数将p插入到链表中，并发送历史记录给客户端。

最后，函数进入一个循环，不断接收客户端发送的消息。如果接收到的消息是"exit"，则表示客户端主动断开连接，函数从链表中删除该客户端的信息并退出循环。否则，函数将消息保存到相应的文件中，并使用multicastNode函数将消息广播给其他类型相同的客户端。

需要注意的是，在函数中使用了读写锁来保护对共享资源（链表和文件）的访问，以避免并发访问导致的数据不一致问题。

如果有想自己试试的小伙伴们，为了方便代码我再单独放在下面

客户端代码全部

#include <sys/types.h>			
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <fcntl.h>int init_socket(char *ip)
{//1. 创建一个套接字int sockfd = socket(AF_INET, SOCK_STREAM, 0);//2 定义一个 sockaddr_in 结构体,并初始化struct  sockaddr_in  serveraddr;serveraddr.sin_family = AF_INET;serveraddr.sin_port = htons(2000); //  h:host  n:network s : shortinet_aton(ip, &serveraddr.sin_addr);//3. connect 服务器connect(sockfd, (struct sockaddr*)&serveraddr, sizeof(serveraddr));return  sockfd;
}int main(int argc, char *argv[])
{char buf[1024]={0};int result,fd;fd_set rdset;int sockfd = init_socket(argv[1]);while(1){FD_ZERO(&rdset);FD_SET(sockfd, &rdset);FD_SET(0, &rdset);if(select(sockfd+1, &rdset, NULL, NULL, NULL)<0){perror("select:");return -1;}if(FD_ISSET(sockfd,&rdset))//网络有数据可读{memset(buf,0,sizeof(buf));result = recv(sockfd, buf, sizeof(buf)-1, 0);if(result < 0){perror("recv:");return -1;}else if(result == 0){printf("服务器断开连接\n");break;}else{buf[result] = 0; //放 \0 作为buf的结束标志printf("%s\n",buf);}}if(FD_ISSET(0, &rdset)) //键盘有数据可读{memset(buf,0,sizeof(buf));if(fgets(buf, sizeof(buf), stdin)){write(sockfd,buf,strlen(buf));}}}
}

服务器代码全部

#include <sys/types.h>			
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <fcntl.h>//定义类型枚举量
typedef enum ClientType
{NEWS_TYPE,ENTERTAINMENT_TYPE,SUPPLY_TYPE
}ClientType;//定义客户节点量
typedef struct ClientNode
{int sockfd;enum ClientType type;char logname[20]; //登录名struct ClientNode * next;
}ClientNode;ClientNode *head=NULL;
pthread_rwlock_t lockList = PTHREAD_RWLOCK_INITIALIZER;
pthread_rwlock_t lockFile = PTHREAD_RWLOCK_INITIALIZER;char *name_msg = "请输入登录名:\n";
char *menu="\n"
" -------------------------\n"	
"      登录类型选择              \n"
"      1)  新闻              \n"
"      2)  娱乐              \n"
"      3)  交易              \n"
" -------------------------\n"	
"请选择登录的类目:";int init_socket(char *ip)
{//1. 创建一个套接字int sockfd = socket(AF_INET, SOCK_STREAM, 0);//2 定义一个 sockaddr_in 结构体,并初始化struct  sockaddr_in  serveraddr;serveraddr.sin_family = AF_INET;serveraddr.sin_port = htons(2000); //  h:host  n:network s : shortserveraddr.sin_addr.s_addr = htonl(INADDR_ANY);// INADDR_ANY  有内核帮你找一个合适的网卡IP地址socklen_t addrlen = sizeof(serveraddr);int on=1;setsockopt(sockfd, SOL_SOCKET, SO_REUSEPORT, &on, sizeof(on));int r =  bind(sockfd,(struct sockaddr *)&serveraddr,addrlen);if(r < 0){perror("bind:");return -1;}r = listen(sockfd, 5);if(r < 0){perror("listen:");return -1;}return  sockfd;
}//插入结点p到 Head链表中
void insertNode(ClientNode * p)
{p->next = head;head = p;
}
void DeleteNode(ClientNode *client)
{ClientNode *p = head;ClientNode *q = head;while(p){if(p->sockfd == client->sockfd){if(p == q){//你要删除的是 第一个节点headhead = p->next;}q->next = p->next;free(p);break;}q = p; //保存上一节点p = p->next; }
}void save2File(char *filename, char *buf)
{FILE *fp = fopen(filename,"a"); //appendfputs(buf, fp);fclose(fp);}
void sendHistory(char *filename,int newfd)
{char buf[1024]={};int n;FILE *fp = fopen(filename, "r");if(fp==NULL){perror("fopen:");return ;}while(fgets(buf, sizeof(buf),fp)){write(newfd, buf, strlen(buf));}fclose(fp);
}void multicastNode(ClientNode * client,char * buf)
{ClientNode *p = head;while(p){//类型和本人相同，又不是本人的节点if((p->type == client->type) && (p->sockfd != client->sockfd) ){write(p->sockfd, client->logname,strlen(client->logname));write(p->sockfd," 说: ", 6);write(p->sockfd, buf, strlen(buf));}p= p->next;}
}void *talk2client(void *arg)
{int result;int newfd = *(int *)arg;char * filename;char buf[200]={};//设置线程为 分离属性：自己回收 线程资源pthread_detach(pthread_self());ClientNode * p = (ClientNode *)malloc(sizeof(ClientNode));memset(p, 0, sizeof(ClientNode));memset(buf,0, sizeof(buf));// 1.填入：sockfd p->sockfd = newfd;p->next = NULL;//2.读登录名write(newfd, name_msg, strlen(name_msg));result = recv(newfd, buf, sizeof(buf)-1, 0);buf[result-1] = 0; //去掉行尾的 '\n'printf("buf:%s\n", buf);strcpy(p->logname,buf);//3. 登录的类型write(newfd, menu, strlen(menu));result = recv(newfd, buf, sizeof(buf)-1, 0);if(result<=0){printf("客户端断开连接\n");close(newfd);pthread_exit(NULL);}buf[result-1] = 0; //去掉行尾的 '\n'printf("buf:%s\n", buf);if(buf[0]=='1'){p->type = NEWS_TYPE;filename = "bbs_news.txt";}else if(buf[0]=='2'){p->type = ENTERTAINMENT_TYPE;filename = "bbs_trans.txt";}else if(buf[0]=='3'){p->type = SUPPLY_TYPE;filename = "bbs_fun.txt";}//插入客户结点到head链表pthread_rwlock_wrlock(&lockList);insertNode(p);pthread_rwlock_unlock(&lockList);//发送历史记录pthread_rwlock_rdlock(&lockFile);sendHistory(filename,newfd);pthread_rwlock_unlock(&lockFile);//进入主循环while(1){result = recv(newfd, buf, sizeof(buf)-1, 0);if(result < 0){perror("recv:");continue;}else if(result == 0){printf("客户端断开连接\n");pthread_rwlock_wrlock(&lockList);DeleteNode(p);pthread_rwlock_unlock(&lockList);break;}else {if(strncmp(buf, "exit\n", 5)==0){printf("客户端要主动离开\n");pthread_rwlock_wrlock(&lockList);DeleteNode(p);pthread_rwlock_unlock(&lockList);break;}//保存记录！buf[result -1]= 0; // 去掉 最后 \n 符号pthread_rwlock_wrlock(&lockFile);save2File(filename, buf);pthread_rwlock_unlock(&lockFile);// 多播信息pthread_rwlock_rdlock(&lockList);multicastNode(p, buf);pthread_rwlock_unlock(&lockList);}}
}int main(int argc, char *argv[])
{char buf[1024]={0};int result,fd, newfd;fd_set rdset;pthread_t tid;struct sockaddr_in re;socklen_t addrlen = sizeof(re);int sockfd = init_socket(argv[1]);while(1){newfd = accept(sockfd, (struct sockaddr *)&re,&addrlen);printf("newfd=%d\n", newfd);printf("IP:%s\n", inet_ntoa(re.sin_addr));pthread_create(&tid, NULL, talk2client, &newfd);}}

记得先运行服务器再运行客户端哦

这篇关于BBS客户端服务器的编写的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/977904。

相关文章

服务器集群同步时间手记

服务器集群同步时间手记

1.时间服务器配置（必须root用户） （1）检查ntp是否安装 [root@node1 桌面]# rpm -qa|grep ntpntp-4.2.6p5-10.el6.centos.x86_64fontpackages-filesystem-1.41-1.1.el6.noarchntpdate-4.2.6p5-10.el6.centos.x86_64 （2）修改ntp配置文件 [r
阅读更多...
Linux服务器Java启动脚本

Linux服务器Java启动脚本

Linux服务器Java启动脚本 1、初版2、优化版本3、常用脚本仓库 本文章介绍了如何在Linux服务器上执行Java并启动jar包， 通常我们会使用nohup直接启动，但是还是需要手动停止然后再次启动， 那如何更优雅的在服务器上启动jar包呢，让我们一起探讨一下吧。 1、初版 第一个版本是常用的做法，直接使用nohup后台启动jar包， 并将日志输出到当前文件夹n
阅读更多...
如何编写Linux PCIe设备驱动器 之二

如何编写Linux PCIe设备驱动器 之二

如何编写Linux PCIe设备驱动器 之二 功能(capability)集功能(capability)APIs通过pci_bus_read_config完成功能存取功能APIs参数pos常量值PCI功能结构 PCI功能IDMSI功能电源功率管理功能 功能(capability)集 功能(capability)APIs int pcie_capability_read_wo
阅读更多...
Java Websocket实例【服务端与客户端实现全双工通讯】

Java Websocket实例【服务端与客户端实现全双工通讯】

Java Websocket实例【服务端与客户端实现全双工通讯】 现很多网站为了实现即时通讯，所用的技术都是轮询(polling)。轮询是在特定的的时间间隔（如每1秒），由浏览器对服务器发 出HTTP request，然后由服务器返回最新的数据给客服端的浏览器。这种传统的HTTP request 的模式带来很明显的缺点 – 浏 览器需要不断的向服务器发出请求，然而HTTP
阅读更多...
速盾：直播 cdn 服务器带宽？

速盾：直播 cdn 服务器带宽？

在当今数字化时代，直播已经成为了一种非常流行的娱乐和商业活动形式。为了确保直播的流畅性和高质量，直播平台通常会使用 CDN（Content Delivery Network，内容分发网络）服务器来分发直播流。而 CDN 服务器的带宽则是影响直播质量的一个重要因素。下面我们就来探讨一下速盾视角下的直播 CDN 服务器带宽问题。 一、直播对带宽的需求 高清视频流 直播通常需要传输高清视频
阅读更多...
一种改进的red5集群方案的应用、基于Red5服务器集群负载均衡调度算法研究

一种改进的red5集群方案的应用、基于Red5服务器集群负载均衡调度算法研究

转自： 一种改进的red5集群方案的应用： http://wenku.baidu.com/link?url=jYQ1wNwHVBqJ-5XCYq0PRligp6Y5q6BYXyISUsF56My8DP8dc9CZ4pZvpPz1abxJn8fojMrL0IyfmMHStpvkotqC1RWlRMGnzVL1X4IPOa_  基于Red5服务器集群负载均衡调度算法研究 http://ww
阅读更多...
RTMP流媒体服务器 crtmpserver

RTMP流媒体服务器 crtmpserver

http://www.oschina.net/p/crtmpserver crtmpserver又称rtmpd是Evostream Media Server（www.evostream.com）的社区版本采用GPLV3授权 其主要作用为一个高性能的RTMP流媒体服务器，可以实现直播与点播功能多终端支持功能，在特定情况下是FMS的良好替代品。 支持RTMP的一堆协议（RT
阅读更多...
云原生之高性能web服务器学习（持续更新中）

云原生之高性能web服务器学习（持续更新中）

高性能web服务器 1 Web服务器的基础介绍1.1 Web服务介绍1.1.1 Apache介绍1.1.2 Nginx-高性能的 Web 服务端 2 Nginx架构与安装2.1 Nginx概述2.1.1 Nginx 功能介绍2.1.2 基础特性2.1.3 Web 服务相关的功能 2.2 Nginx 架构和进程2.2.1 架构2.2.2 Ngnix进程结构 2.3 Nginx 模块介绍2.4
阅读更多...
Wondows dos下怎么编写bat批处理文件

Wondows dos下怎么编写bat批处理文件

最近搞php，在运行时，以Nginx+php-cgi.exe方式运行Wordpress项目 打开dos，先cd到php-cgi.exe文件当前目录下执行启动命令：php-cgi.exe -b 127.0.0.1:9001再打开一个dos，再cd到nginx.exe文件当前目录下执行启动命令：start nginx 大概过程要经过这些步骤，觉得很麻烦，就学下怎么编写一个bat文件，以双击运行代替
阅读更多...
阿里云服务器ces

阿里云服务器ces

允许公网通过 HTTP、HTTPS 等服务访问实例 https://help.aliyun.com/document_detail/25475.html?spm=5176.2020520101.0.0.3ca96b0b3KGTPq#allowHttp
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2