myicq-1.0a1服务器代码的一点分析(二)—在线人员管理与内存分配
顾剑辉(Solarsoft)
http://solarsoft.126.com
在线人员的管理
在upd服务器中,在线人员的管理是必不可少的.其实这种方法也可以用到游戏服务器中.接下去我们来看一下,myicq是怎样管理的.
Myicq采用的是哈希表来管理,哈希表的查找效率是非常高的,到目前是我见的最高效的查找方法,请看myicq中哈希表的实现:
#define HASH_SIZE (1 << 16)
#define HASH_MASK (HASH_SIZE - 1)
struct HASH {
ListHead ipport; //IP和端口
ListHead uin; //唯一的ID号
};
static HASH bucket[HASH_SIZE];//设置"桶"
inline int hashfn(uint32 uin)//哈希函数
{
uin ^= (uin >> 16);
uin ^= (uin >> 8);
return (uin & HASH_MASK);
}
inline int hashfn(uint32 ip, uint16 port)
{
int h = (ip ^ port);
h ^= (h >> 16);
h ^= (h >> 8);
return (h & HASH_MASK);
}
并用类SessionHash进行管理看其定义:
class SessionHash {
public:
static UdpSession *get(uint32 uin);
static UdpSession *get(uint32 ip, uint16 port);
static void put(UdpSession *p, uint32 ip, uint16 port);
static void put(UdpSession *p, uint32 uin);
static void random(IcqOutPacket &out, int n);
};
UdpSession *SessionHash::get(uint32 uin)
{
ListHead *pos;
ListHead *head = &bucket[hashfn(uin)].uin;
LIST_FOR_EACH(pos, head) {
UdpSession *p = LIST_ENTRY(pos, UdpSession, uinItem);
if (p->uin == uin)
return p;
}
return NULL;
}
UdpSession *SessionHash::get(uint32 ip, uint16 port)
{
ListHead *pos;
ListHead *head = &bucket[hashfn(ip, port)].ipport;
LIST_FOR_EACH(pos, head) {
UdpSession *p = LIST_ENTRY(pos, UdpSession, ipportItem);
if (p->ip == ip && p->port == port)
return p;
}
return NULL;
}
void SessionHash::put(UdpSession *p, uint32 ip, uint16 port)
{
int i = hashfn(ip, port);
bucket[i].ipport.addHead(&p->ipportItem);
}
void SessionHash::put(UdpSession *p, uint32 uin)
{
int i = hashfn(uin);
bucket[i].uin.addHead(&p->uinItem);
}
void SessionHash::random(IcqOutPacket &out, int n)
{
uint16 num = 0;
uint8 *old = out.skip(sizeof(num));
int start = rand32() & HASH_MASK;
int i = start;
do {
i = ((i + 1) & HASH_MASK);
ListHead *pos, *head = &bucket[i].ipport;
LIST_FOR_EACH(pos, head) {
UdpSession *s = LIST_ENTRY(pos, UdpSession, ipportItem);
if (s->status != STATUS_INVIS && s->status != STATUS_OFFLINE) {
out << s->uin;
out << (uint8) 1; // online
out << s->face;
out << s->nickname;
out << s->province;
if (++num >= n)
break;
}
}
} while (num < n && i != start);
old = out.setCursor(old);
out << num;
out.setCursor(old);
}
对于这样的管理,我也非常认同,这似乎是最好的方法.
内存分配:
在这里作者是引用了linux的slab的内存分配模式,我先来介绍一下slab,slab是早94年被开发出来的,用与sun microsystem solaris 2.4操作系统中,一般的内存分配如初试化,不用时进行回收.而slab引入了一个对象的概念,这个对象其实是存放一组数据结构的内存区,其方法是构造和构析函数,前者用于初始化,后者用于回收.为了避免重复初始化对象,slab分配模式并不丢弃已分配的对象,而是释放但他们依然保留在内存中.再次请求是就不用重新进行初始化了.请看myicq中的代码
struct SLAB;
struct OBJ {
OBJ *next;
SLAB *slab;
};
struct SLAB {
ListHead item;/*--一个cache的所有slab是一个双向链表,这个是链表指针*/
int inuse;/*-这个slab中被使用的对象数*/
OBJ *free; /*--指向一个空的对象的指针项,用于分配空的对象*/
};
class Cache {//对象进行管理
public:
Cache(int size, int n);
~Cache();
void *allocObj();
void freeObj(void *p);
static int reclaimAll();
private:
SLAB *newSlab();
int reclaim(int n = 0xffff);
Cache *nextCache;
ListHead slabList;
ListHead *firstNotFull;
int objSize; //对象大小
int numObjs; //对象记数
int numFreeSlabs; //空Slabs记数
int slabSize; //slab大小
static Cache *cacheList;
};
在看代码中我发现几乎所有的内存分配都采用了这种方法,它存在于各个类中的定义,在这里我到认为这种内存分配是否值得,能否保证服务器内存的高效分配呢!因我没有进行测试,所以我不敢断定.我突然想到了一个新的内存管理方法,也是我在关注和分析isee项目时得到的,我们是否可以用isee中的内存管理方法呢?这样是不是可以提高效率,毕竟服务器不能过几天就停机.关于isee中的内存管理可以到http://isee.126.com中去下载,顺便提一句那是一个非常好的学习工程和开发的例子.