socket编程花了我三四天的事件终于将这个程序给实现了
所谓的多人聊天室，其实不过是客户端创建一个数据接收线程和数据发送线程，而在服务器端创建一个套接字数组，开启一个接受连接请求线程，不断接受来自客户端的连接请求，然后将建立的连接所形成的新套接字描述符存进套接字数组，并针对所存储的套接字描述符建立多个数据接收线程，对于所接收到的数据，开启一个数据转发进程，对套接字数组中的每个客户端将收到的数据进行转发。服务器就是起到这个一个数据转发的功能。
附上代码
客户端：
#include <stdio.h>
#include <winsock2.h>
#include <pthread.h>
#pragma comment(lib,"ws2_32.lib")
char buffer[4096] = {0};
int iRecvLen = 0;
int iSnedLen = 0;
char name[20];
void THRE_RECV(SOCKET ClientSocket)
{
char buffer[50]={0};
while(1)
{
memset(buffer, 0, sizeof(buffer));///接收消息
iRecvLen = recv(ClientSocket, buffer, sizeof(buffer), 0);
if (SOCKET_ERROR == iRecvLen)
{
printf("send failed with error code: %d\n", WSAGetLastError());
closesocket(ClientSocket);
WSACleanup();
return -1;
}
///printf("recv %d bytes from %s: ", iRecvLen, nameOther);//为了美观最好不要打印这个了
//strcat(buffer, "\0");
buffer[iRecvLen] = 0;
printf("\n%s\n", buffer);
}
}
int main()
{
WSADATA wsaData = { 0 };///存放套接字信息,WSADATA结构被用来保存AfxSocketInit函数返回的WindowsSockets初始化信息。
SOCKET ClientSocket = INVALID_SOCKET;///客户端套接字
///printf("%d\n",INVALID_SOCKET);
SOCKADDR_IN ServerAddr = { 0 };///服务端地址
USHORT uPort = 18000;///服务端端口
///初始化套接字
if(WSAStartup(MAKEWORD(2,2), &wsaData))///该函数的第一个参数指明程序请求使用的Socket版本，其中高位字节指明副版本、低位字节指明主版本
///第二个参数返回请求的socket版本信息
{
printf("WSAStartup failed with error code: %d\n", WSAGetLastError());
return -1;
}
///判断套接字版本
if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
{
printf("wVersion was not 2.2\n");
return -1;
}
///创建套接字
ClientSocket = socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);///AF_INET代表一个地址族,SOCK_STREAM表示为TCP协议的流服务,IPPROTO_TCP的值为6
///printf("%d\n",IPPROTO_TCP);
if (ClientSocket == INVALID_SOCKET)
{
printf("socket初始化失败并返回错误代码: %d\n", WSAGetLastError());
return -1;
}
///输入服务器IP
printf("Please input the server's IP:");
char IP[32] = { 0 };
gets(IP);
///输入聊天的用户名
printf("Please input the Client's username:");
char name[32] = {0};
memset(name,0,sizeof(name));
gets(name);
///设置服务器地址，填充服务器地址的结构
ServerAddr.sin_family = AF_INET;
ServerAddr.sin_port = htons(uPort);///服务器端口
ServerAddr.sin_addr.S_un.S_addr = inet_addr(IP);///服务器地址
printf("Connecting...........\n");
///连接服务器
if(SOCKET_ERROR == connect(ClientSocket, (SOCKADDR*)&ServerAddr, sizeof(ServerAddr)))
{
printf("Connect failed with error code: %d \n", WSAGetLastError());
closesocket(ClientSocket);
WSACleanup();
return -1;
}
printf("Successfuuly got a connection from IP:%s Port:%d\n\n\n\n",inet_ntoa(ServerAddr.sin_addr),htons(ServerAddr.sin_port));
_beginthreadex(NULL,0,&THRE_RECV,ClientSocket,NULL,0);
iSnedLen = send(ClientSocket,name,strlen(name),0);
if(SOCKET_ERROR == iSnedLen)
{
printf("send failed with error code: %d\n", WSAGetLastError());
closesocket(ClientSocket);
WSACleanup();
return -1;
}
while(1)
{
memset(buffer, 0, sizeof(buffer));
///发送消息
gets(buffer);
if(strcmp(buffer,"bye") == 0) break;
printf("%s: ", name);
iSnedLen = send(ClientSocket, buffer, strlen(buffer), 0);
if (SOCKET_ERROR == iSnedLen)
{
printf("send failed with error code: %d\n", WSAGetLastError());
closesocket(ClientSocket);
WSACleanup();
return -1;
}
}
closesocket(ClientSocket);
WSACleanup();
system("pause");
return 0;
}
服务器端：
#include <WinSock2.h>
#include <process.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#pragma comment(lib,"ws2_32.lib")
#define SEND_OVER 1 ///已经转发消息
#define SEND_YET 0 ///还没转发消息
typedef struct _Client
{
SOCKET sClient; ///客户端套接字
char buf[128]; ///数据缓冲区
char userName[16]; ///客户端用户名
char IP[20]; ///客户端IP
UINT_PTR flag; ///标记客户端，用来区分不同的客户端
int first;
}Client;
Client g_Client[10] = { 0 };
int SENDFFFF = 0;
int Rflag = 0;
SOCKADDR_IN ServerAddr = { 0 };///服务端地址
SOCKADDR_IN ClientAddr = { 0 };///客户端地址
int iClientAddrLen = sizeof(ClientAddr);
SOCKET g_ServerSocket = INVALID_SOCKET; ///服务端套接字
SOCKADDR_IN g_ClientAddr = { 0 }; ///客户端地址
int g_iClientAddrLen = sizeof(g_ClientAddr);
USHORT uPort = 18000; ///服务器监听端口
unsigned __stdcall ThreadSend(void* param)
{
while(1)
{
if(SENDFFFF==0) continue;
else
{
SOCKET client = INVALID_SOCKET; ///创建一个临时套接字来存放要转发的客户端套接字
char temp[128];
memset(temp,0,sizeof(temp)); ///创建一个临时的数据缓冲区，用来存放接收到的数据
memcpy(temp, g_Client[Rflag].buf, sizeof(temp));
printf("temp = %s\n",temp);
int k = 1;
while(k<=5)
{
if(k!=Rflag)
{
sprintf(g_Client[k].buf, "%s: %s", g_Client[Rflag].userName, temp);///添加一个用户名头
}
k++;
}
k=1;
while(k<=5)
{
if(strlen(temp) != 0&&g_Client[k].sClient!=INVALID_SOCKET&&k!=Rflag)
{
int ret = send(g_Client[k].sClient, g_Client[k].buf, strlen(g_Client[k].buf), 0);
printf("g_Client[k].buf == .............%s\n",g_Client[k].buf);
if(ret==SOCKET_ERROR) return 1;
}
k++;
}
Rflag = 0;
SENDFFFF = 0;
}
}
return 0;
}
unsigned __stdcall THREAD_RECV(SOCKET ClientSocket)
{
int flag = 0;
int u = 1;
while(u<=5)
{
if(g_Client[u].sClient==ClientSocket&&g_Client!=INVALID_SOCKET)
{
flag = u;
}
u++;
}
printf("flag = %d\n",flag);
char temp[80] = {0};
while(1)
{
memset(temp, 0, sizeof(temp));
int ret = recv(ClientSocket, temp, sizeof(temp), 0); ///接收数据
printf("%s\n",temp);
if (ret == SOCKET_ERROR)
{
printf("ClientSocket=%d error=%d",ClientSocket,errno);
//getchar();
continue;
}
//iStatus = SEND_YET; ///设置转发状态为未转发
//flag = client == g_Client[0].sClient ? 1 : 0; ///这个要设置，否则会出现自己给自己发消息的BUG
int k = 1;
while(k<=5)
{
if(k!=flag&&g_Client[flag].first==1)
memcpy(g_Client[k].buf, temp, strlen(g_Client[k].buf));
printf("%s\n",g_Client[k].buf);
k++;
}
if(g_Client[flag].first==0)///如果这是第一次传过来的数，说明这是一个用户名，不需要进行转发，将其复制到该相应的用户名当中
{
memcpy(g_Client[flag].userName,temp,sizeof(temp));
g_Client[flag].first = 1;
}
else
{
Rflag = flag;
SENDFFFF = 1; ///开启一个转发线程,flag标记着要转发给哪个客户端
}
}
}
unsigned __stdcall THREAD_ACCEPT(SOCKET ClientSocket)
{
int num = 0;
while(1)
{
num = 0;
int k = 1;
while(k<=5)
{
if(g_Client[k].sClient!=INVALID_SOCKET)
{
num++;
k++;
continue;
}
else
{
g_Client[k].sClient = accept(ClientSocket, (SOCKADDR*)&g_ClientAddr, &g_iClientAddrLen);
if(g_Client[k].sClient == INVALID_SOCKET)
{
printf("accept failed with error code: %d\n", WSAGetLastError());
closesocket(ClientSocket);
WSACleanup();
return -1;
}
//int len = recv(g_Client[k].sClient, g_Client[k].userName, 15, 0); ///接收用户名
//g_Client[k].userName[len]=0;
//printf("\nlen = %d\n",len);
printf("Successfuuly got a connection from IP:%s ,Port: %d,UerName: %s\n",inet_ntoa(g_ClientAddr.sin_addr), htons(g_ClientAddr.sin_port), g_Client[k].userName);
//printf("%s\n",g_Client[k].sClient);
printf("k = %d\n",k);
memcpy(g_Client[k].IP, inet_ntoa(g_ClientAddr.sin_addr), sizeof(g_Client[k].IP)); ///记录客户端IP
g_Client[k].flag = g_Client[k].sClient; ///不同的socke有不同UINT_PTR类型的数字来标识
num++;
k++;
break;
}
}
//printf("num = %d\n",num);
if(num>=3)
{
int l =1;
while(l<=5)
{
if(g_Client[l].sClient!=INVALID_SOCKET)
{
_beginthreadex(NULL,0,&THREAD_RECV,g_Client[l].sClient,0,0);
}
l++;
}
}
}
}
int main()
{
///存放套接字信息的结构
WSADATA wsaData = { 0 };
SOCKET ServerSocket = INVALID_SOCKET;///服务端套接字
SOCKET ClientSocket = INVALID_SOCKET;///客户端套接字
int pp = 1;
while(pp<=6)
{
memset(g_Client[pp].buf,0,sizeof(g_Client[pp].buf));
g_Client[pp].first = 0;
memset(g_Client[pp].IP,0,sizeof(g_Client[pp].IP));
g_Client[pp].sClient = INVALID_SOCKET;
memset(g_Client[pp].userName,0,sizeof(g_Client[pp].userName));
pp++;
}
if (WSAStartup(MAKEWORD(2, 2), &wsaData))
{
printf("WSAStartup failed with error code: %d\n", WSAGetLastError());
return -1;
}
///判断版本
if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)
{
printf("wVersion was not 2.2\n");
return -1;
}
///创建套接字
ServerSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (ServerSocket == INVALID_SOCKET)
{
printf("socket failed with error code: %d\n", WSAGetLastError());
return -1;
}
///设置服务器地址
ServerAddr.sin_family = AF_INET;///连接方式
ServerAddr.sin_port = htons(uPort);///服务器监听端口
ServerAddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);///任何客户端都能连接这个服务器
///初始化套接字
///绑定服务器
if (SOCKET_ERROR == bind(ServerSocket, (SOCKADDR*)&ServerAddr, sizeof(ServerAddr)))
{
printf("bind failed with error code: %d\n", WSAGetLastError());
closesocket(ServerSocket);
return -1;
}
///监听有无客户端连接
if (SOCKET_ERROR == listen(ServerSocket, 1))
{
printf("listen failed with error code: %d\n", WSAGetLastError());
closesocket(ServerSocket);
WSACleanup();
return -1;
}
_beginthreadex(NULL, 0, ThreadSend, NULL,0,NULL);
_beginthreadex(NULL,0,&THREAD_ACCEPT,ServerSocket,NULL,0);
int k = 0;
while(k<100)///让主线程休眠，不让它关闭TCP连接.
{
Sleep(10000000);
k++;
}
///关闭套接字
int j = 1;
while(j<6)
{
if (g_Client[j].sClient != INVALID_SOCKET)
closesocket(g_Client[j].sClient);
j++;
}
closesocket(g_ServerSocket);
WSACleanup();
return 0;
/*
ClientSocket = accept(ServerSocket, (SOCKADDR*)&ClientAddr, &iClientAddrLen);///accept为阻塞函数
if (ClientSocket == INVALID_SOCKET)
{
printf("accept failed with error code: %d\n", WSAGetLastError());
closesocket(ServerSocket);
WSACleanup();
return -1;
}
printf("Successfuuly got a connection from IP:%s Port:%d\n\n\n\n",inet_ntoa(ClientAddr.sin_addr),htons(ClientAddr.sin_port));
*/
}
对于代码的思路和注释都写在代码里面了，希望这个文档对于刚学习网络编程的人有所帮助。
不过这个程序有一个问题就是在客户端断开连接的时候会出现错误，还有待解决！！可以对每个客户端的连接建立一个线程进行单独的循环查询，当检测到其断开时对其进行关闭套接字，关闭相应的线程。
相关推荐
操作系统与Linux程序设计团队作业，基于Socket编程的多人聊天室 <C语言实现>+源代码+文档说明 - 小白不懂运行，下载完可以私聊问，可远程教学 该资源内项目源码是个人的课程设计，代码都测试ok，都是运行成功后才...
本次实验利用TCP/IP, 语言环境为 C/C++ 利用套接字Socket编程，以及线程处理， 实现Server/CLient 之间多人的聊天系统的基本功能。
java实现socket编程网络通信多人聊天室，可以实现简单的多人聊天功能。适合初学的大二，大三学生，学习。
【Java socket编程】多人聊天室 源代码
Python实现的多人聊天室源码，基于socket tcp通信，使用tkinter做客户端界面；一个多人同时在线的聊天系统；
C语言基于socket多人聊天(包含注册登录)，有注册和登录模块，验证通过才可以发信息。可实现多人同时在线发信息，或者一对一发信息
java socket编程 多人聊天室。一个服务端，多个客户端可进行聊天
该代码可以实验服务器一对一处理客户机的信息，逆序送回，也可以一对多处理客户机信息，即迭代以及并发处理，最后还可以模拟UDP的多人聊天室，有异常捕捉以及消息互通
用java语言 Socket Thread 实现的 聊天室 例子。分为Server、Client端，先运行Server，再运行Client
4、使用网络编程，掌握基于TCP协议的Socket编程，了解Socket编程的协议约定，掌握简单应用协议的开发。 5、使用C/S架构，对网络编程有一定的了解 二．项目概述 运用java程序编写聊天室，实现简单的聊天功能。它是...
基于TCP的网络编程，使用Socket和ServerSocket实现多人聊天的聊天室程序，Java网络编程章节训练的小程序
Java代码写的基于TCP和Socket编程的局域网多线程多人聊天室（Java网络编程）实训小例子。
介绍了Socket的工作机制和基于CAsyncSocket 类的Sockets编程的基本方法。通过一个应用实例，编写服务端和客户端代码，实现多人之间信息传递。
本代码实现模拟扣扣聊天室。 开发环境 : Linux，vim，gcc，gdb等 项目简述 : 使用socket网络编程及多线程程序设计开发多人聊天室，实现多客户端登录，室内群聊及一对一私聊。
Java 网络编程 多人聊天室 Socket通信 多线程 课程设计，基于UDP通信，用户数据包，用户在主界面进行人员管理，可添加聊天人员，保证干货----明亮出品
mfc多人聊天室教程,叫你怎样用socket编程写聊天室
在linux下的基于TCP/IP，采用socket通信的聊天室，实现进入聊天室，进行多人群聊，指定人进行私聊，群主管理员功能，颗进行禁言，提出群聊等操作。个人账号可修改昵称或者修改密码，还可进行找回密码等功能 基于...
1. 用Java图形用户界面编写聊天室服务器端和客户端， 支持多个客户端连接到一个服务器。每个客户端能够输入账号。 2. 可以实现群聊（聊天记录显示在所有客户端界面）。 3. 完成好友列表在各个客户端上显示。 4. 可以...
JAVA多人聊天室 整个项目全部打包了 包含各个版本~
服务端知识进行连接 之后调用服务端的线程 服务端并没有大的改动，在原有的基础上加上线程池， 客户端界面只有简单的传一个...调用客户端的方法，方法中有线程，线程中进行socket的链接，这样才能实现多个文件的传输。