Linux中 socket聊天室，给客户端发消息

Posted 2023-03-09

用socket做的一个 服务端和 客户端的聊天室，服务器创建一个子进程用来 给所有客户端发送消息，我的子进程是 另一个 .c文件中写的，但是在另一个 .c文件中 用 send 无法给客户端发送消息，怎么解决啊

//下面是一个实例
/**    
* socket.io chat    
*    
*/    
     
var web = require('QuickWeb');    
     
// undefined    
var _ = undefined;     
     
/**    
 * 创建一个房间    
 *    
 * @param string room 房间名称    
 * @param socket.io io socket.io实例    
 */    
var Room = module.exports = function (room, io)     
// 初始化socket.io实例，仅在第一次创建房间时需要设置io参数    
if (typeof io != 'undefined')    
Room.prototype.io = io;    
var io = this.io;    
   
// 房间成员列表    
var nicknames = this.nicknames = ;    
var onlinesum = this.onlinesum = 0;    
   
// 握手验证，如果是登录用户，则自动获取其昵称    
io.set('authorization', function (handshakeData, callback)     
// 通过客户端的cookie字符串来获取其session数据    
var sessionObject = handshakeData.sessionObject = web.session.getByCookie(handshakeData.headers.cookie);    
   
// 如果不是登录用户，则自动为其设置一个昵称    
var nickname = sessionObject.data.nickname;    
if (typeof nickname != 'string' || nickname == '')    
nickname = '#' + Math.floor(Math.random() * 1000) + '' + (new Date().getTime() % 86400000);    
sessionObject.data.nickname = nickname;    
   
callback(null, true);    
);    
   
/** 连接处理 */    
var connectionHandle = function (socket)     
onlinesum++;    
// 获取session    
var session = socket.handshake.sessionObject.data;    
var nickname = session.nickname;    
   
// 保持session，以免session过期    
var hold_session = socket.handshake.sessionObject.hold;    
   
/** 刷新在线列表 */    
refresh_online = function ()     
var n = [];    
for (var i in nicknames)    
n.push(i);    
socket.broadcast.emit('online list', n);    
socket.emit('online list', n);    
    
   
// 新成员加入时，通知其他成员    
nicknames[nickname] = socket;    
refresh_online();    
socket.broadcast.emit('system message', nickname + '回来了，大家赶紧去喷他~~');    
   
/** 公共消息 */    
socket.on('public message', function (msg, cb)     
hold_session();    
var timestamp = new Date().getTime();    
socket.broadcast.emit('public message', nickname, msg, timestamp);    
cb();    
);    
   
/** 私人消息 */    
socket.on('private message', function (to, msg, cb)     
hold_session();    
var timestamp = new Date().getTime();    
var err = '';    
for (var i in to)     
var target = nicknames[to[i]];    
if (target)     
cb();    
target.emit('private message', nickname, msg, timestamp);    
    
else     
err += '“' + to[i] + '”不在线\\n';    
    
    
if (err != '')    
cb(err);    
);    
   
/** 断开来连接 */    
socket.on('disconnect', function ()     
delete nicknames[nickname];    
onlinesum--;    
socket.broadcast.emit('system message', nickname + '悄悄地离开了。。。');    
refresh_online();    
);    
   
/** 命令 */    
socket.on('command', function (args, cb)     
if (args.length < 1)     
cb('无效的命令');    
return;    
    
switch (args[0])     
/* 查询或更改昵称 */    
case 'nick':    
var nick = args[1];    
if (typeof nick == 'undefined')    
cb(_, '你的昵称是：' + nickname);    
else    
if (nick == nickname)    
cb('你的昵称本来就是“' + nick + '”嘛，不需要改');    
else if (nicknameIsUsed(nick))    
cb('昵称“' + nick + '”已被占用');    
else     
nicknames[nick] = nicknames[nickname];    
delete nicknames[nickname];    
var oldnick = nickname;    
session.nickname = nickname = nick;    
cb(_, '昵称已更改为“' + nick + '”');    
// 通知其他人    
refresh_online();    
socket.broadcast.emit('system message', '“' + oldnick + '”的昵称已改为“' + nick + '”');    
    
break;    
   
/* 在线人数 */    
case 'online':    
cb(_, '当前共有' + onlinesum + '个人在线');    
break;    
   
/* 帮助 */    
default:    
cb(_, strHelp);    
    
);    
    
   
/* 注册聊天室 */    
if (typeof room == 'undefined')    
room = '';    
io.of('/' + room).on('connection', connectionHandle);    
   
   
/** 检查昵称是否被占用 */    
var nicknameIsUsed = function (nickname)     
for (var i in nicknames)    
if (i == nickname)    
return true;    
return false;    
    
    
   
var strHelp = '输入$help获取帮助\\n\\    
========= 系统命令 ========\\n\\    
**$nick** [昵称] 查看或更改昵称\\n\\    
**$online** 当前在线人数\\n\\    
**$clear** 清空消息\\n\\    
========= 使用技巧 ========\\n\\    
**给某人发送消息** @对方昵称 消息内容（可同时@多个人）\\n\\    
**发送图片** !图片url\\n\\    
**发送链接** [网址]\\n\\    
';

参考技术A 这题目是Linux Socket 很普遍的练习
你没贴代码，不知道问题在哪?
请试试下面 Server.c and Client.c

服务器：server.c
#include <sys/types.h>
#include <sys/socket.h> // 包含套接字函数库
#include <stdio.h>
#include <netinet/in.h> // 包含AF_INET相关结构
#include <arpa/inet.h> // 包含AF_INET相关操作的函数
#include <unistd.h>
#include<string.h>
#include<stdlib.h>
#include<fcntl.h>
#include<sys/shm.h>

#define PORT 8888;

#define MYKEY 12345
#define SIZE 10240

int main()

int shmid;
char *shmaddr; //定义子进程共用的共享内存
shmid = shmget(MYKEY, SIZE, IPC_CREAT | 0600);
shmaddr= (char *) shmat(shmid, 0, 0);

if(shmid==-1)

printf("shmid error\n");

memset(shmaddr,0,SIZE);

int i=0;
char buf[100];
memset(buf,0,100);

int server_sockfd,client_sockfd;
int server_len,client_len;

struct sockaddr_in server_sockaddr,client_sockaddr;

server_sockfd = socket(AF_INET,SOCK_STREAM, 0); // 定义套接字类型

server_sockaddr.sin_family=AF_INET;
server_sockaddr.sin_port=PORT;
server_sockaddr.sin_addr.s_addr=INADDR_ANY;

server_len=sizeof(server_sockaddr);

//允许重复使用本地地址和套接字绑定
int j=1;
setsockopt(server_sockfd,SOL_SOCKET,SO_REUSEADDR,&j,sizeof(j));

//绑定端口
if(bind(server_sockfd,(struct sockaddr *)&server_sockaddr,server_len)==-1)

perror("bind:");
exit(1);


if(listen(server_sockfd,5)==-1)

perror("listen:");
exit(1);

printf("Listening...\n");

client_len=sizeof(client_sockaddr);

pid_t ppid,pid;

while(1)

if((client_sockfd=accept(server_sockfd,(struct sockaddr *)&client_sockaddr,&client_len))==-1)

perror("accept error:");
exit(1);


printf("%s登录服务器\n",inet_ntoa(client_sockaddr.sin_addr));

ppid=fork();

if(ppid==-1)

printf("fork 1 failed:");


if(ppid==0) //子进程用于接收客户端信息并发送

pid=fork();
if(pid==-1)

printf("fork 2 failed:");
exit(1);


int recvbytes;

if(pid==0) //子子进程用于接收消息

while(1)


if((recvbytes=recv(client_sockfd,buf,100,0))==-1)

perror("read client_sockfd failed:");


// printf("recvbytes=%d\n",recvbytes);
usleep(10000);
printf("client send buf=%s\n",buf);

for(i=0;i<1000;i++)

if(*(shmaddr+100*i)==0)

strcpy(shmaddr+100*i,buf);
break;







if(pid>0) //子进程用于发送消息

while(1)

if(*(shmaddr+i*100)!=0)

// strcpy(&buf,shmaddr+100*i);

// buf++;
write(client_sockfd,shmaddr,SIZE);
// send(client_sockfd,buf,strlen(buf),0);

// printf("the server is send buf=%c",buf);
// printf("send client :%s\n",(shmaddr+i*100)) ;
i++;








if(ppid>0) //总父进程返回等待接收消息

close(client_sockfd);






客户端：client.c
#include <sys/types.h>
#include <sys/socket.h> // 包含套接字函数库
#include <stdio.h>
#include <netinet/in.h> // 包含AF_INET相关结构
#include <arpa/inet.h> // 包含AF_INET相关操作的函数
#include <unistd.h>
#include<string.h>
#include<time.h>

#define PORT 8888
#define IP_ADDR "192.168.110.185"

#define SIZE 10240

int main()


struct tm *timeptr;
time_t timeval;
char tm[50];
//(void)time(&timeval);

//printf("the date is %s\n",ctime(&timeval));
// printf("The time is %s\n",tm);

int sockfd; // 用于保存客户套接字标识符
int len; // 用于客户消息长度
struct sockaddr_in address; // 定义客户套接字地址

int result;

sockfd = socket(AF_INET,SOCK_STREAM, 0); // 定义套接字类型
address.sin_family = AF_INET; // 定义套接字地址中的域

address.sin_addr.s_addr = inet_addr(IP_ADDR); // 定义套接字地址

address.sin_port = htons(PORT); // 定义套接字端口
char buf[100]; // 定义要传送的消息
memset(buf,0,100);
char str[90]; //存贮输入的语句

char shmaddr[SIZE]; //接受服务器发送的全部聊天数据
int i=0;

char myname[100];
char say[10]="说：";
printf("欢迎来到聊天室，请输入你的姓名:\n");
scanf("%s",myname);

len = sizeof(address);
result = connect(sockfd, (struct sockaddr *) &address, len); // 请求连接

if (result == -1)

perror("Connect failed");
return 1;

printf("%s成功登录服务器:\n",myname);

pid_t pid;

pid=fork();
if(pid==-1)

printf("fork failed");


int sendbytes=0;

if(pid==0) //子进程用于发送数据

while(1)

printf("请输入语句:\n");

scanf("%s",str);

(void)time(&timeval);
strcpy(tm,ctime(&timeval));

strcpy(buf,myname); //姓名传入buf中
strcat(buf,tm); //时间传入buf中
strcat(buf,say);
strcat(buf,str); //语句传入bufz中

//read(0,buf,strlen(buf));

// send(sockfd,buf,strlen(buf),0);
// getchar();

if((sendbytes=write(sockfd, buf, 100))==-1)

perror("send to server failed:");
// 向服务器传送消息

// printf("sendbytes=%d\n",sendbytes);
// printf("buf=%s\n",buf);
// printf("input buf=%s\n",buf);
usleep(1000);

memset(buf,0,100);
memset(tm,0,50);



if(pid>0) //父进程用于接受消息并读取

while(1)

read(sockfd,shmaddr,SIZE);
// printf("server send shmaddr=%s\n",shmaddr);

if(*(shmaddr+i*100)!=0)

printf("%s\n",(shmaddr+i*100)) ;
i++;



usleep(1000);



close(sockfd);
return 0;

追问

if(*(shmaddr+100*i)==0)

这是什么意思啊

本回答被提问者采纳 参考技术B 这题目是Linux Socket 很普遍的练习
你没贴代码，不知道问题在哪?
请试试下面 Server.c and Client.c

服务器：server.c
#include <sys/types.h>
#include <sys/socket.h> // 包含套接字函数库
#include <stdio.h>
#include <netinet/in.h> // 包含AF_INET相关结构
#include <arpa/inet.h> // 包含AF_INET相关操作的函数
#include <unistd.h>
#include<string.h>
#include<stdlib.h>
#include<fcntl.h>
#include<sys/shm.h>

#define PORT 8888;

#define MYKEY 12345
#define SIZE 10240

int main()

int shmid;
char *shmaddr; //定义子进程共用的共享内存
shmid = shmget(MYKEY, SIZE, IPC_CREAT | 0600);
shmaddr= (char *) shmat(shmid, 0, 0);

if(shmid==-1)

printf("shmid error\n");

memset(shmaddr,0,SIZE);

int i=0;
char buf[100];
memset(buf,0,100);

int server_sockfd,client_sockfd;
int server_len,client_len;

struct sockaddr_in server_sockaddr,client_sockaddr;

server_sockfd = socket(AF_INET,SOCK_STREAM, 0); // 定义套接字类型

server_sockaddr.sin_family=AF_INET;
server_sockaddr.sin_port=PORT;
server_sockaddr.sin_addr.s_addr=INADDR_ANY;

server_len=sizeof(server_sockaddr);

//允许重复使用本地地址和套接字绑定
int j=1;
setsockopt(server_sockfd,SOL_SOCKET,SO_REUSEADDR,&j,sizeof(j));

//绑定端口
if(bind(server_sockfd,(struct sockaddr *)&server_sockaddr,server_len)==-1)

perror("bind:");
exit(1);


if(listen(server_sockfd,5)==-1)

perror("listen:");
exit(1);

printf("Listening...\n");

client_len=sizeof(client_sockaddr);

pid_t ppid,pid;

while(1)

if((client_sockfd=accept(server_sockfd,(struct sockaddr *)&client_sockaddr,&client_len))==-1)

perror("accept error:");
exit(1);


printf("%s登录服务器\n",inet_ntoa(client_sockaddr.sin_addr));

ppid=fork();

if(ppid==-1)

printf("fork 1 failed:");


if(ppid==0) //子进程用于接收客户端信息并发送

pid=fork();
if(pid==-1)

printf("fork 2 failed:");
exit(1);


int recvbytes;

if(pid==0) //子子进程用于接收消息

while(1)


if((recvbytes=recv(client_sockfd,buf,100,0))==-1)

perror("read client_sockfd failed:");


// printf("recvbytes=%d\n",recvbytes);
usleep(10000);
printf("client send buf=%s\n",buf);

for(i=0;i<1000;i++)

if(*(shmaddr+100*i)==0)

strcpy(shmaddr+100*i,buf);
break;







if(pid>0) //子进程用于发送消息

while(1)

if(*(shmaddr+i*100)!=0)

// strcpy(&buf,shmaddr+100*i);

// buf++;
write(client_sockfd,shmaddr,SIZE);
// send(client_sockfd,buf,strlen(buf),0);

// printf("the server is send buf=%c",buf);
// printf("send client :%s\n",(shmaddr+i*100)) ;
i++;








if(ppid>0) //总父进程返回等待接收消息

close(client_sockfd);






客户端：client.c
#include <sys/types.h>
#include <sys/socket.h> // 包含套接字函数库
#include <stdio.h>
#include <netinet/in.h> // 包含AF_INET相关结构
#include <arpa/inet.h> // 包含AF_INET相关操作的函数
#include <unistd.h>
#include<string.h>
#include<time.h>

#define PORT 8888
#define IP_ADDR "192.168.110.185"

#define SIZE 10240

int main()


struct tm *timeptr;
time_t timeval;
char tm[50];
//(void)time(&timeval);

//printf("the date is %s\n",ctime(&timeval));
// printf("The time is %s\n",tm);

int sockfd; // 用于保存客户套接字标识符
int len; // 用于客户消息长度
struct sockaddr_in address; // 定义客户套接字地址

int result;

sockfd = socket(AF_INET,SOCK_STREAM, 0); // 定义套接字类型
address.sin_family = AF_INET; // 定义套接字地址中的域

address.sin_addr.s_addr = inet_addr(IP_ADDR); // 定义套接字地址

address.sin_port = htons(PORT); // 定义套接字端口
char buf[100]; // 定义要传送的消息
memset(buf,0,100);
char str[90]; //存贮输入的语句

char shmaddr[SIZE]; //接受服务器发送的全部聊天数据
int i=0;

char myname[100];
char say[10]="说：";
printf("欢迎来到聊天室，请输入你的姓名:\n");
scanf("%s",myname);

len = sizeof(address);
result = connect(sockfd, (struct sockaddr *) &address, len); // 请求连接

if (result == -1)

perror("Connect failed");
return 1;

printf("%s成功登录服务器:\n",myname);

pid_t pid;

pid=fork();
if(pid==-1)

printf("fork failed");


int sendbytes=0;

if(pid==0) //子进程用于发送数据

while(1)

printf("请输入语句:\n");

scanf("%s",str);

(void)time(&timeval);
strcpy(tm,ctime(&timeval));

strcpy(buf,myname); //姓名传入buf中
strcat(buf,tm); //时间传入buf中
strcat(buf,say);
strcat(buf,str); //语句传入bufz中

//read(0,buf,strlen(buf));

// send(sockfd,buf,strlen(buf),0);
// getchar();

if((sendbytes=write(sockfd, buf, 100))==-1)

perror("send to server failed:");
// 向服务器传送消息

// printf("sendbytes=%d\n",sendbytes);
// printf("buf=%s\n",buf);
// printf("input buf=%s\n",buf);
usleep(1000);

memset(buf,0,100);
memset(tm,0,50);



if(pid>0) //父进程用于接受消息并读取

while(1)

read(sockfd,shmaddr,SIZE);
// printf("server send shmaddr=%s\n",shmaddr);

if(*(shmaddr+i*100)!=0)

printf("%s\n",(shmaddr+i*100)) ;
i++;



usleep(1000);



close(sockfd);
return 0;

Socket入门笔记 用TcpClient实现一个简易聊天室

效果

 

实现思路

使用TcpListener建一个服务器,接收所有客户端发送的消息,然后由服务器再发送到其他客户端

客户端使用TcpClient,发消息给服务器,接收服务器的消息,不和其他客户端直接交互

服务器端

接收客户端

开启一个线程,死循环去接收客户端.接收到之后放到一个集合里,保存起来,以便转发消息用.每个客户端都再开启一个线程,用于接收这个客户端发送的消息.

接收客户端的方法AcceptTcpClient()是阻塞方法,在程序退出释放资源时会引发异常,可以先使用Pending()方法先判断是否有挂起的链接请求,有请求的话再去接收.这样可以避免退出时引发的异常.

这里取每隔1秒接收一次.

/// <summary>
/// 接收客户端
/// </summary>
private void AcceptClient()
{
    try
    {
        while (_isAccept)
        {
            if (_listener.Pending())
            {
                TcpClient client = _listener.AcceptTcpClient();
                IPEndPoint endpoint = client.Client.RemoteEndPoint as IPEndPoint;
                _clients.Add(endpoint.ToString(), client);

                //添加到前端客户端列表
                lbx_Clients.Dispatcher.Invoke(() =>
                {
                    lbx_Clients.Items.Add(endpoint.ToString());
                });

                //接收消息线程
                Thread reciveMessageThread = new Thread(ReciveMessage);
                reciveMessageThread.Start(client);
            }
            else
            {
                Thread.Sleep(1000);
            }
        }
    }
    catch (Exception ex)
    {
        MessageBox.Show(ex.Message);
    }
}

接收消息并转发

也是死循环接收,使用Read()方法接收.如果远程主机已关闭连接,Read()将立即返回零字节.此时跳出循环,释放资源,结束此线程.

/// <summary>
/// 接收消息
/// </summary>
/// <param name="obj">TcpClient</param>
private void ReciveMessage(object obj)
{
    TcpClient client = obj as TcpClient;
    IPEndPoint endpoint = null;
    NetworkStream stream = null;

    try
    {
        endpoint = client.Client.RemoteEndPoint as IPEndPoint;
        stream = client.GetStream();

        while (true)
        {
            byte[] data = new byte[1024];
            //如果远程主机已关闭连接,Read将立即返回零字节
            int length = stream.Read(data, 0, data.Length);
            if (length > 0)
            {
                #region if
                string msg = Encoding.UTF8.GetString(data, 0, length);

                //添加到前端消息列表
                lbx_Messages.Dispatcher.Invoke(() =>
                {
                    lbx_Messages.Items.Add(string.Format("{0}:{1}", endpoint.ToString(), msg));
                });

                //发送到其他客户端
                foreach (KeyValuePair<string, TcpClient> kvp in _clients)
                {
                    if (kvp.Value != client)
                    {
                        string writeMsg = string.Format("{0}:{1}", endpoint.ToString(), msg);
                        byte[] writeData = Encoding.UTF8.GetBytes(writeMsg);
                        NetworkStream writeStream = kvp.Value.GetStream();
                        writeStream.Write(writeData, 0, writeData.Length);
                    }
                }
                #endregion
            }
            else
            {
                //客户端断开连接 跳出循环
                break;
            }
        }
    }
    catch (Exception ex)
    {
        //Read是阻塞方法 客户端退出是会引发异常 释放资源 结束此线程
    }
    finally
    {
        //从前端客户端列表移除
        lbx_Clients.Dispatcher.Invoke(() =>
        {
            lbx_Clients.Items.Remove(endpoint.ToString());
        });
        //释放资源
        stream.Dispose();
        _clients.Remove(endpoint.ToString());
        client.Dispose();
    }
}

客户端

接收消息

开启线程,死循环接收服务器发送的消息.如果Read()返回0,说明服务器已关闭.

/// <summary>
/// 接收消息
/// </summary>
private void ReciveMessage()
{
    try
    {
        NetworkStream stream = _client.GetStream();
        while (true)
        {
            byte[] data = new byte[1024];
            int length = stream.Read(data, 0, data.Length);
            if (length > 0)
            {
                string msg = Encoding.UTF8.GetString(data, 0, length);

                //添加到前端消息列表
                lbx_Messages.Dispatcher.Invoke(() =>
                {
                    lbx_Messages.Items.Add(msg);
                });
            }
            else
            {
                MessageBox.Show("服务器已关闭");
                stream.Dispose();
                break;
            }
        }
    }
    catch (Exception ex)
    {
        //Read是阻塞方法 程序退出释放资源是会引发异常 不做处理 线程结束
    }
}

源码下载:

服务器端:SocketServerDemo.zip

客户端:SocketClientDemo.zip