Linux中 socket聊天室，给客户端发消息
用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\
';
/**
* 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\
';
温馨提示：内容为网友见解，仅供参考
第1个回答 推荐于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;
}追问
你没贴代码，不知道问题在哪?
请试试下面 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)
这是什么意思啊
第2个回答 2016-01-15
这题目是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;
}
你没贴代码，不知道问题在哪?
请试试下面 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;
}
相似回答
