189 8069 5689
上次说到，使用消息队列可以做到简易的登录、退出功能。那么，该思考一下，聊天的用户列表和聊天记录应该存在哪儿呢？当然是服务器上，那么，就需要用到共享内存了。
10多年的秦淮网站建设经验，针对设计、前端、开发、售后、文案、推广等六对一服务，响应快，48小时及时工作处理。网络营销推广的优势是能够根据用户设备显示端的尺寸不同，自动调整秦淮建站的显示方式，使网站能够适用不同显示终端，在浏览器中调整网站的宽度，无论在任何一种浏览器上浏览网站，都能展现优雅布局与设计，从而大程度地提升浏览体验。创新互联建站从事“秦淮网站设计”,“秦淮网站推广”以来，每个客户项目都认真落实执行。
共享内存涉及到的函数，与消息队列相似，如下
#include < sys/ipc.h>
#include < sys/shm.h>
int shmget(key_t key, size_t size, int shmflg);作用：用来创建共享内存
void *shmat(int shmid, const void *shmaddr, int shmflg);作用：共享内存刚被创建的时候，任何进程还都不能访问它，为了建立对这个共享内存段的访问渠道，必须由我们来把它连接到某个进程的地址空间，shmat函数就是用来完成这项工作的。
int shmdt(const void *shmaddr);作用：把共享内存与当前进程脱离开
int shmctl(int shmid, int cmd, struct shmid_ds *buf);作用：共享内存的控制函数
返回值：成功-‘0’；失败-‘-1’
cmd将要采取的动作有以下三个值：
即
写一段测试代码练练：
shmwrite.c
#include < stdio.h>
#include < sys/msg.h>
#include < sys/ipc.h>
#include < sys/types.h>
int main()
{
int shmid;
char * addr;
//先检测该key的共享内存是否存在，如果存在，将原来的删除，重建
shmid = shmget(1000,0,0);
if(shmid != -1)
{
//已经存在，删除
shmctl(shmid,IPC_RMID,NULL);
}
shmid = shmget(1000,1024,IPC_CREAT);
if(shmid == -1)
{
perror("error");
}
// printf("shmid: %d\n",shmid);
//地址映射
addr = (char*)shmat(shmid,NULL,0);
strcpy(addr,"hello world!");
return 0;
}shmread.c
#include < stdio.h>
#include < sys/msg.h>
#include < sys/ipc.h>
#include < sys/types.h>
int main()
{
int shmid;
char * addr = NULL;
//先检测该key的共享内存是否存在，如果存在，将原来的删除，重建
shmid = shmget(1000,0,0);
if(shmid == -1)
{
perror("error");
}
printf("shmit: %d\n",shmid);
addr = (char*)shmat(shmid,NULL,0);
printf("%s\n",addr);
//解除映射
shmdt(&addr);
return 0;
}运行：
查看ipc状态：.jpg)
接下来，可以继续我们的小程序了。当有用户上线的时候，每个客户端都需要更新在线用户列表，也就是说服务器收到用户登录的消息之后，需要发消息（signal,kill）给每一个在线用户，客户端在重写消息的处理函数中，进行用户列表的打印工作。
那么，登录用户的状态信息就应该放在共享内存中，这样，服务器和客户端都可以访问。设计共享内存如下：.jpg)
假设最大连接用户数位100，可开辟一块空间，前100个单位存放每个用户的状态，后100个单位存放相应的用户信息。每当一位新用户登录时，服务器在共享内存里寻找一个空闲块（标志为0），比如找到userAddr+3的位置，将标志置为1，同时移动pUser指针，指向user3，将用户信息插入。同理，用户退出的是时候，需要将标志置为0。同时，发送信号，通知客户端读取共享内存的内容，这样客户端就能及时更新用户列表了。（由于发送信号的时候，需要遍历所有用户的id，所以可以用容器来存储用户信息）
基于上次，具体代码如下：
public.h:
#ifndef _PUBLICH
#define _PUBLICH
#include < stdio.h>
#include < string.h>
#include < sys/types.h>
#include < sys/ipc.h>
#include < sys/msg.h>
#include < sys/shm.h>
#include < signal.h>
#include < string>
#include < map>
#include < iostream>
using namespace std;
//用户信息结构体
typedef struct user_t
{
pid_t pid;
char uname[10]; //后面加上用户名不重名、密码验证
}USER_T;
//登录消息结构体
typedef struct login_msg_t
{
long type;
USER_T user;
}LMSG_T;
//消息队列：用户登录
#define LOGIN_TYPE 1
#define EXIT_TYPE 2
#define MSG_KEY 1000
#define MSG_SIZE sizeof(LMSG_T)-sizeof(long)
//共享内存：用户列表（空闲块：0-空闲，1-占用）
#define SHM_USER_KEY 1001
#define MAX_USER 100
#define SHM_USER_SIZE MAX_USER + MAX_USER * sizeof(USER_T)
#define SIGNAL_USERS 34
#endifserver.cpp:
#include "public.h"
int main()
{
int msg_id;
int shm_id;
LMSG_T loginMsg = {0};
char userAddr;
USER_T pUser; //用户真正写入的地址
map
map
int i;
/*1、创建消息队列：用户登录*/
msg_id = msgget(MSG_KEY,0);
if(msg_id == -1)
{
msg_id = msgget(MSG_KEY,IPC_CREAT);
if (msg_id == -1)
{
perror("server msgget");
return -1;
}
}
/*2、创建共享内存：用户列表*/
shm_id = shmget(SHM_USER_KEY,0,0);
if (shm_id != -1)
{//已经存在，删除
shmctl(shm_id,IPC_RMID,NULL);
}
shm_id = shmget(SHM_USER_KEY,SHM_USER_SIZE,IPC_CREAT);
userAddr = (char *)shmat(shm_id,NULL,0);//映射
pUser = (USER_T *)(userAddr + MAX_USER);
memset(userAddr,0,SHM_USER_SIZE);//初始化
//一直监听，是否有用户上线
while (1)
{
memset(&loginMsg,0,sizeof(LMSG_T));
msgrcv(msg_id,&loginMsg,MSG_SIZE,0,0); //任何消息都接收
switch(loginMsg.type)
{
case LOGIN_TYPE:
//登录
cout<<"client "<(loginMsg.user.pid,loginMsg.user.uname) );
}
else
{
cout<<"online users are full.\n"<pid == loginMsg.user.pid)
{
*(userAddr+i) = 0;
break;
}
}
for (it = userMap.begin();it != userMap.end();it++)
{
if ((*it).first == loginMsg.user.pid)
{
continue; //自己退出，不用再通知自己
}
kill((*it).first,SIGNAL_USERS);
}
break;
}
}
return 0; }
client.cpp：
#include "public.h"
char *userAddr;
USER_T *pUser;
void PrtUserList(int sig_no)
{
//读取共享内存里的用户列表数据
cout<<"==== online users ===="<uname<>uname;
//2.3 注册消息（放在最前面）
signal(SIGNAL_USERS,PrtUserList);
/*2、打开用户列表共享内存（要比写消息队列早）*/
shm_id = shmget(SHM_USER_KEY,0,0);
if (shm_id == -1)
{
perror("client shmget");
return -1;
}
userAddr = (char*)shmat(shm_id,NULL,0);
pUser = (USER_T*)(userAddr + MAX_USER);
/*1、打开消息队列*/
msg_id = msgget(MSG_KEY,0);
if(msg_id == -1)
{
perror("client msgget");
return -1;
}
//登录，写消息队列
loginMsg.type = LOGIN_TYPE; //设置登录的消息类型为1
loginMsg.user.pid = getpid();
memcpy(loginMsg.user.uname,uname,strlen(uname));
cout< 运行结果：
首先运行服务器，然后登陆Julia，再登陆Tomy，再退出Tomy。
至此，可以进行聊天的功能设计了，聊天内容同样存储在共享内存。由于私聊和群聊的功能，我们需要获取在线用户列表，所以同样，客户端也需要一个容器来暂时存储用户信息。（list也可以，直接存放用户结构体）
代码如下：
public.h
#ifndef _PUBLICH
#define _PUBLICH
#include < stdio.h>
#include < string.h>
#include < sys/types.h>
#include < sys/ipc.h>
#include < sys/msg.h>
#include < sys/shm.h>
#include < signal.h>
#include < string>
#include < map>
#include < iostream>
using namespace std;
//用户信息结构体
typedef struct user_t
{
pid_t pid;
char uname[10]; //后面加上用户名不重名、密码验证
}USER_T;
//登录消息队列结构体
typedef struct login_msg_t
{
long type;
USER_T user;
}LMSG_T;
//聊天消息结构体
typedef struct msg_t
{
USER_T user;
char acMsg[100];
}MSG_T;
//消息队列：用户登录
#define LOGIN_TYPE 1
#define EXIT_TYPE 2
#define MSG_KEY 1000
#define MSG_SIZE sizeof(LMSG_T)-sizeof(long)
//共享内存：用户列表（空闲块：0-空闲，1-占用）
#define SHM_USER_KEY 1001
#define MAX_USER 100
#define SHM_USER_SIZE MAX_USER + MAX_USER * sizeof(USER_T)
//共享内存：聊天内容
#define SHM_MSG_KEY 1002
#define SHM_MSG_SIZE sizeof(MSG_T)
//信号：更新用户列表，读消息
#define SIGNAL_USERS 34
#define SIGNAL_CHAT 35
#endifserver.cpp
服务器这边只需要再开一块共享内存就可以了
/*3、创建共享内存：聊天信息*/
int shm_msg_id = shmget(SHM_MSG_KEY,0,0);
if (shm_msg_id != -1)
{
shmctl(shm_msg_id,IPC_RMID,NULL);
}
shm_msg_id = shmget(SHM_MSG_KEY,SHM_MSG_SIZE,IPC_CREAT);
char *msgAddr = (char *)shmat(shm_msg_id,NULL,0);
memset(msgAddr,0,SHM_MSG_SIZE);client.cpp
#include "public.h"
char *userAddr;
USER_T *pUser;
char *msgAddr;
MSG_T *pMsg;
map userMap; //用户列表
map::iterator it;
void PrtUserList(int sig_no)
{
//读取共享内存里的用户列表数据
userMap.clear();
cout<<"==== online users ===="<uname<( (pUser+i)->pid, (pUser+i)->uname ));
}
}
}
void GetChatMsg(int sig_no)
{
//读取共享内存里的聊天内容
MSG_T msg = {0};
msg = *pMsg;
cout<<"receive msg from "<>uname;
//2.3 注册消息（放在最前面）
signal(SIGNAL_USERS,PrtUserList);
signal(SIGNAL_CHAT,GetChatMsg);
/*2、打开用户列表共享内存（要比写消息队列早）*/
shm_id = shmget(SHM_USER_KEY,0,0);
if (shm_id == -1)
{
perror("client userlist shmget");
return -1;
}
userAddr = (char*)shmat(shm_id,NULL,0);
pUser = (USER_T*)(userAddr + MAX_USER);
/*3、打开聊天信息共享内存*/
int shm_msg_id = shmget(SHM_MSG_KEY,0,0);
if (shm_msg_id == -1)
{
perror("client chatmsg shmget");
return -1;
}
msgAddr = (char *)shmat(shm_msg_id,NULL,0);
pMsg = (MSG_T *)msgAddr;
/*1、打开消息队列*/
msg_id = msgget(MSG_KEY,0);
if(msg_id == -1)
{
perror("client msgget");
return -1;
}
//登录，写消息队列
loginMsg.type = LOGIN_TYPE; //设置登录的消息类型为1
loginMsg.user.pid = getpid();
memcpy(loginMsg.user.uname,uname,strlen(uname));
cout<>toWho;
cout<<"say: ";
memset(acMsg,0,100);
cin>>acMsg;
// 3.1 把聊天内容写进共享内存
memcpy(msg.acMsg,acMsg,strlen(acMsg));
msg.user = loginMsg.user;
memcpy(msgAddr,&msg,SHM_MSG_SIZE);
if (strcmp(toWho,"all") == 0) //群聊
{
//通知所有人去读
for (it = userMap.begin();it != userMap.end();it++)
{
if ((*it).first != getpid())
{
kill((*it).first,SIGNAL_CHAT);
}
}
}
else //私聊
{
for (it = userMap.begin();it != userMap.end();it++)
{
if (strcmp((*it).second.c_str() , toWho) == 0)
{
kill((*it).first,SIGNAL_CHAT);
break;
}
}
}
}
memset(acOrder,0,sizeof(acOrder));
}
//解除映射
shmdt(&userAddr);
shmdt(&msgAddr);
return 0;
} 运行结果：
那么，共享内存里开辟一块空间用来存储一条聊天记录的话，考虑并发的问题，如果消息发送的太快，还来不及读取，那么消息就会被覆盖。如图：让读取消息的函数sleep一下，连续发送两条消息，结果第一条消息的内容会被覆盖。这是我们不想看到的。.jpg)
所以，又需要用到信号量的知识了，下次复习（先写着聊天试试）~