2012年8月28日
微信要打敗qq,如果僅僅局限于陌生人交友,是肯定不行的。所以現(xiàn)在微信會(huì)兼顧陌生人交友和熟人交友。因?yàn)槟吧私挥训哪J绞钦{(diào)動(dòng)大家獵奇、嘗試新鮮的欲望,如果大家都想去“約炮”,但是又經(jīng)常約不到,就會(huì)漸漸失去對(duì)它的好奇和新鮮刺激感,那么微信的發(fā)展就會(huì)遇到瓶頸。qq最大的優(yōu)勢(shì)在于它的用戶(hù)關(guān)系鏈,用戶(hù)關(guān)系鏈?zhǔn)菑?qiáng)聯(lián)系的,用戶(hù)很難從它轉(zhuǎn)到別處,當(dāng)然現(xiàn)在微信的快速發(fā)展也是離不開(kāi)qq的支持的,比如從qq導(dǎo)入好友到微信。所以qq被微信取代的可能性還不是很大,應(yīng)該是互補(bǔ)的,兩強(qiáng)并立。微信的火并不一定在于它的功能強(qiáng)大,或者創(chuàng)新(如搖一搖、漂流瓶),火的本質(zhì)原因在于用戶(hù)的“約炮”需求,這也是陌陌能異軍突起的原因,而相比之下,米聊就后勁不足,因?yàn)樗鼪](méi)有抓住這個(gè)本質(zhì)需求。
由于一開(kāi)始大部分人的的“約炮”需求無(wú)法得到滿足,繼而對(duì)于陌生人交友工具的使用會(huì)由原來(lái)的原始“約炮”需求,進(jìn)化為“結(jié)識(shí)新朋友”的需求,現(xiàn)代大部分人都花費(fèi)大量時(shí)間在互聯(lián)網(wǎng)上,與人接觸的時(shí)間會(huì)比較少,剩男剩女、宅男宅女很多,這部分需求會(huì)比較大,也比較不那么原始。相信不久后會(huì)是這部分需求來(lái)主導(dǎo)陌生人交友工具的發(fā)展。
2012年7月17日
一、redis運(yùn)行流程
以下是redis main函數(shù)的運(yùn)行流程
2012年7月15日
as you know,一個(gè)socket是由一個(gè)五元組來(lái)唯一標(biāo)示的,即(協(xié)議,server_ip, server_port, client_ip, client_port)。只要該五元組中任何一個(gè)值不同,則其代表的socket就不同。這里忽略協(xié)議的區(qū)別,在同一協(xié)議的基礎(chǔ)上,服務(wù)器端的listen socket的端口可以看成(server_ip, server_port, ***, ***),其中***是通配符,它跟任何一個(gè)client_ip, client_port值都不同,可以簡(jiǎn)單看成是(0,0)對(duì),當(dāng)然實(shí)現(xiàn)不是這樣的。這樣在服務(wù)器端accept之后,返回的連接socket的四元組就是(server_ip, server_port, client_ip, client_port),這里的client_ip,client_port因連接的客戶(hù)端的不同而不同。所以accept返回的socket和listen socket是不同的,不同之處就在于四元組中的客戶(hù)端ip和port,而服務(wù)器端的server_ip和server_port還是相同的,也就是accpet()函數(shù)返回的新的socket描述符的端口和listen端口是一樣的??梢允褂胓etsockname()函數(shù)來(lái)查看它們之間的不同。
2012年7月13日
詳見(jiàn)《unix網(wǎng)絡(luò)編程 第1卷:套接口API》 p136
阻塞io模型、非阻塞io模型、I/O復(fù)用模型和信號(hào)驅(qū)動(dòng)I/O模型都是同步io模型,因?yàn)槠渲姓嬲膇o操作將阻塞進(jìn)程。只有異步I/O模型才是異步的
socket close_on_exec
父進(jìn)程fork子進(jìn)程后,子進(jìn)程會(huì)復(fù)制父進(jìn)程的socket描述符。如果想讓子進(jìn)程在exec時(shí),釋放掉所擁有的父進(jìn)程的socket描述符,可以設(shè)置父進(jìn)程的socket close_on_exec特性。
if( fcntl(iSockFd, F_GETFD, arg) < 0 ) /* 這個(gè)很重要,要不下面設(shè)置不成功 */
{
exit(-1);
}
arg |= FD_CLOEXEC;
if( fcntl(iSockFd, F_SETFD, 1) < 0 )
{
exit(-1);
}
2012年7月12日
SO_REUSEADDR
編寫(xiě) TCP/SOCK_STREAM 服務(wù)程序時(shí),SO_REUSEADDR到底什么意思?這個(gè)套接字選項(xiàng)通知內(nèi)核,如果端口忙,但TCP狀態(tài)位于 TIME_WAIT ,可以重用端口。如果端口忙,而TCP狀態(tài)位于其他狀態(tài),重用端口時(shí)依舊得到一個(gè)錯(cuò)誤信息, 指明"地址已經(jīng)使用中"。如果你的服務(wù)程序停止后想立即重啟,而新套接字依舊使用同一端口,此時(shí)SO_REUSEADDR 選項(xiàng)非常有用。必須意識(shí)到,此時(shí)任何非期望數(shù)據(jù)到達(dá),都可能導(dǎo)致服務(wù)程序反應(yīng)混亂,不過(guò)這只是一種可能,事實(shí)上很不可能。
2012年7月3日
redis源碼剖析-字符串
redis實(shí)現(xiàn)了自己的字符串結(jié)構(gòu)。在文件sds.h/dsd.c中定義。redis中的字符串叫sds(simple dynamic string)。
sds實(shí)質(zhì)是char*:
typedef char *sds;
sds通過(guò)sdsnewlen()函數(shù)來(lái)創(chuàng)建,sds sdsnewlen(const void *init, size_t initlen)。該函數(shù)內(nèi)部會(huì)創(chuàng)建一個(gè)sdshdr的結(jié)構(gòu),返回值sds,即char *,該結(jié)構(gòu)定義如下:
struct sdshdr
{
int len;
int free;
char buf[];
};
其中l(wèi)en存儲(chǔ)當(dāng)前字符串的長(zhǎng)度,free存儲(chǔ)該結(jié)構(gòu)體剩余可存儲(chǔ)字節(jié)數(shù),buf存儲(chǔ)字符串值。sdsnewlen()函數(shù)在創(chuàng)建sdshdr后,會(huì)返回buf的地址(sdshdr->buf)。
sdsnewlen()函數(shù)創(chuàng)建了字符串,并返回字符串地址sds,要使用sdshdr中的len和free,則需要獲取sdshdr結(jié)構(gòu)體的地址。如何根據(jù)獲得的sds得到sdshdr結(jié)構(gòu)體的地址呢?
redis中參考了linux內(nèi)核關(guān)于通用list(list_head)的實(shí)現(xiàn)機(jī)制,實(shí)現(xiàn)方法如下:
struct sdshdr *sh = (void*) (sds-(sizeof(struct sdshdr)));
sds是返回的字符串地址,即sdshdr->buf,用sds的地址減去其在結(jié)構(gòu)體中的偏移,即可得到sdshdr的地址。由于buf在sdshdr結(jié)構(gòu)體的最后,所以其偏移就是sizeof(len)+sizeof(free),該偏移恰好是sizeof(struct sdshdr)。
如果buf在sdshdr中的位置是任意的,如何根據(jù)buf的地址獲取sdshdr的地址呢?實(shí)現(xiàn)如下:
假設(shè)現(xiàn)在sdshdr聲明如下:
struct sdshdr
{
int len;
char buf[];
int free;
};
則sdshdr地址如下獲取:
int offset_buf = (int)((struct sdshdr *)0)->buf;
struct sdshdr *sh =(struct sdshdr *)( (int)sdsbuf - offset_buf);
其中sdsbuf是調(diào)用sdsnewlen()返回的buf地址。即 sds sdsbuf = sdsnewlen(...);
((struct sdshdr *)0)->buf 表示當(dāng)結(jié)構(gòu)體sdshdr在地址0時(shí),buf相對(duì)于sdshdr首地址的偏移。
2012年6月20日
2012年6月14日
如何定義變長(zhǎng)的TLV結(jié)構(gòu)體?
TLV是一種常用的用于通信的結(jié)構(gòu)體格式。T表示tag,L表示length,V表示value。其中T和L是固定大小的,V是可變大小,L表示的是V的長(zhǎng)度。通常用于結(jié)構(gòu)化網(wǎng)絡(luò)通信中的數(shù)據(jù)流。如0x3 3 'aa\0',0x3 5 'aaaa\0',其中0x3表示tag的值,3 or 5表示的是后面的字符串的長(zhǎng)度。由于V是可變長(zhǎng)度的,所以在定義TLV結(jié)構(gòu)時(shí),需要將V定義成為可變大小。可定義如下:
struct TLV
{
uint8_t tag;
uint16_t len;
char value[0];
}__attribute__((packed));
注意value分配的是0大小,最后一個(gè)成員為可變長(zhǎng)的數(shù)組,對(duì)于TLV(Type-Length-Value)形式的結(jié)構(gòu),或者其他需要變長(zhǎng)度的結(jié)構(gòu)體,用這種方式定義最好。使用起來(lái)非常方便,創(chuàng)建時(shí),malloc一段結(jié)構(gòu)體大小加上可變長(zhǎng)數(shù)據(jù)長(zhǎng)度的空間給它,可變長(zhǎng)部分可按數(shù)組的方式訪問(wèn),釋放時(shí),直接把整個(gè)結(jié)構(gòu)體free掉就可以了。__attribute__(packed)用來(lái)強(qiáng)制不對(duì)struct TLV進(jìn)行4字節(jié)對(duì)齊,目的是為了獲取真實(shí)的TLV的空間使用情況。
int main()
{
char *szMsg = "aaaaaaaaa";
cout << sizeof(TLV) << endl; //the size of TLV
uint16_t len = strlen(szMsg) + 1;
struct TLV *pTLV;
pTLV = (struct TLV*)malloc(sizeof(struct TLV) + sizeof(char)*len);
pTLV->tag = 0x2;
pTLV->len = len;
memcpy(pTLV->value, szMsg, len);
cout << pTLV->value << endl;
free(pTLV);
pTLV = NULL;
return 0;
}
這里有關(guān)于設(shè)置變長(zhǎng)TLV的詳細(xì)說(shuō)明:
http://www.douban.com/note/213324857/
這里有一個(gè)問(wèn)題,如何實(shí)現(xiàn)嵌套TLV結(jié)構(gòu)呢?大家有什么好的思路嗎?歡迎交流
簡(jiǎn)單實(shí)現(xiàn)了一下嵌套TLV,不知道有沒(méi)有問(wèn)題。
#include <iostream>
using namespace std;
struct TLVNODE
{
uint8_t tag;
uint16_t len;
char value[0];
}__attribute__ ((packed));
struct TLV
{
int hei;
uint8_t tag;
uint16_t len;
struct TLVNODE value[0];
} __attribute__ ((packed));
int main()
{
//char *szMsg = "aaaaaaaaaaa";
cout << sizeof(TLV) << endl;
//uint16_t len = strlen(szMsg) + 1;
char *szNodeMsg = "bbbbbbbbbb";
uint16_t nodelen = strlen(szNodeMsg) + 1;
struct TLVNODE *pNode = (struct TLVNODE *) malloc(sizeof(struct TLVNODE) + sizeof(char)*nodelen);
pNode->tag = 0x3;
pNode->len = nodelen;
memcpy(pNode->value, szNodeMsg, nodelen);
struct TLV *pTlv;
uint16_t nodeSize = sizeof(struct TLVNODE) + sizeof(char)*nodelen;
pTlv = (struct TLV*)malloc(sizeof(struct TLV) + nodeSize);
pTlv->tag = 0x2;
pTlv->len = nodeSize;
// pTlv->value[0] = (struct TLVNODE)*pNode;
memcpy(pTlv->value, pNode, nodeSize);
free(pNode);
pNode = NULL;
cout << sizeof(*pTlv) << endl;
/*for (int i = 0; i < len; ++i)
{
pTlv->value[i] = szMsg[i];
}*/
/*memcpy(pTlv->value, szMsg, len);*/
//cout << pTlv->value << endl;
free(pTlv);
pTlv = NULL;
return 0;
}