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

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

 我来答

3个回答

#热议# 什么是淋病？哪些行为会感染淋病？

Coder小Q
2016-02-14 · TA获得超过657个赞

知道小有建树答主

回答量：353

采纳率：100%

帮助的人：143万

我也去答题访问个人页

关注

展开全部

//下面是一个实例
/**    
* 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\    
';

已赞过 已踩过<

评论收起

Storm代理
2023-06-05 广告

StormProxies是全球大数据IP资源服务商，其住宅代理网络由真实的家庭住宅IP组成，可为企业或个人提供满足各种场景的代理产品。点击免费测试（注册即送1G流量）StormProxies有哪些优势？1、IP+端口提取形式，不限带宽，IP... 点击进入详情页

本回答由Storm代理提供

匿名用户
推荐于2017-09-25

展开全部

这题目是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)

这是什么意思啊

本回答被提问者采纳

已赞过 已踩过<

评论收起

百度网友fcbe779
2016-01-15 · 超过27用户采纳过TA的回答

知道答主

回答量：162

采纳率：0%

帮助的人：45万

我也去答题访问个人页

关注

展开全部

已赞过 已踩过<

评论收起

更多回答（1）

推荐律师服务：若未解决您的问题，请您详细描述您的问题，通过百度律临进行免费专业咨询

您可能关注的内容

旗舰性能云电脑-海马云电脑，纵享每帧丝滑，特效拉满!

pc.haimacloud.com

笔记本品牌质量排行-购物就上淘宝，好货挑选更便捷!

simba.taobao.com广告

淘宝甄选，办公专用电脑品牌，高效办公好助手

专业选择，高效配置，助您轻松应对日常工作任务。品牌保证，淘宝品质护航，为您的职业生涯添加助力。

simba.taobao.com广告

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

您可能关注的内容

其他类似问题

为你推荐：