C++博客-aa19870406

关于微信和QQ的一点思考

MrRightLeft — Tue, 28 Aug 2012 10:24:00 GMT

微信要打败qq，如果仅仅局限于陌生人交友，是肯定不行的。所以现在微信会兼顾陌生人交友和熟人交友。因为陌生人交友的模式是调动大家猎奇、尝试新鲜的欲望，如果大家都想去“约炮”，但是又经常约不到，就会渐渐失去对它的好奇和新鲜刺激感，那么微信的发展就会遇到瓶颈。qq最大的优势在于它的用户关系链，用户关系链是强联系的，用户很难从它转到别处，当然现在微信的快速发展也是离不开qq的支持的，比如从qq导入好友到微信。所以qq被微信取代的可能性还不是很大，应该是互补的，两强并立。微信的火并不一定在于它的功能强大，或者创新（如摇一摇、漂流瓶），火的本质原因在于用户的“约炮”需求，这也是陌陌能异军突起的原因，而相比之下，米聊就后劲不足，因为它没有抓住这个本质需求。

由于一开始大部分人的的“约炮”需求无法得到满足，继而对于陌生人交友工具的使用会由原来的原始“约炮”需求，进化为“结识新朋友”的需求，现代大部分人都花费大量时间在互联网上，与人接触的时间会比较少，剩男剩女、宅男宅女很多，这部分需求会比较大，也比较不那么原始。相信不久后会是这部分需求来主导陌生人交友工具的发展。

MrRightLeft 2012-08-28 18:24 发表评论

redis源码剖析-main流程

MrRightLeft — Tue, 17 Jul 2012 05:28:00 GMT

一、redis运行流程
以下是redis main函数的运行流程

MrRightLeft 2012-07-17 13:28 发表评论

socket accept()返回的socket描述符的端口和listen描述符端口是一样的吗？

MrRightLeft — Sun, 15 Jul 2012 13:01:00 GMT

as you know,一个socket是由一个五元组来唯一标示的，即(协议，server_ip, server_port, client_ip, client_port)。只要该五元组中任何一个值不同，则其代表的socket就不同。这里忽略协议的区别，在同一协议的基础上，服务器端的listen socket的端口可以看成(server_ip, server_port, ***, ***),其中***是通配符，它跟任何一个client_ip, client_port值都不同，可以简单看成是（0,0）对，当然实现不是这样的。这样在服务器端accept之后，返回的连接socket的四元组就是(server_ip, server_port, client_ip, client_port)，这里的client_ip，client_port因连接的客户端的不同而不同。所以accept返回的socket和listen socket是不同的，不同之处就在于四元组中的客户端ip和port，而服务器端的server_ip和server_port还是相同的，也就是accpet()函数返回的新的socket描述符的端口和listen端口是一样的。可以使用getsockname()函数来查看它们之间的不同。

MrRightLeft 2012-07-15 21:01 发表评论

同步io与异步io

MrRightLeft — Fri, 13 Jul 2012 07:45:00 GMT

详见《unix网络编程第1卷：套接口API》 p136
阻塞io模型、非阻塞io模型、I/O复用模型和信号驱动I/O模型都是同步io模型，因为其中真正的io操作将阻塞进程。只有异步I/O模型才是异步的

MrRightLeft 2012-07-13 15:45 发表评论

socket close_on_exec

MrRightLeft — Fri, 13 Jul 2012 07:08:00 GMT

socket close_on_exec

父进程fork子进程后，子进程会复制父进程的socket描述符。如果想让子进程在exec时，释放掉所拥有的父进程的socket描述符，可以设置父进程的socket close_on_exec特性。

if( fcntl(iSockFd, F_GETFD, arg) < 0 ) /* 这个很重要，要不下面设置不成功 */
{
exit(-1);
}

arg |= FD_CLOEXEC;

if( fcntl(iSockFd, F_SETFD, 1) < 0 )
{
exit(-1);
}

MrRightLeft 2012-07-13 15:08 发表评论

SO_REUSEADDR

MrRightLeft — Thu, 12 Jul 2012 09:16:00 GMT

SO_REUSEADDR

编写 TCP/SOCK_STREAM 服务程序时，SO_REUSEADDR到底什么意思？这个套接字选项通知内核，如果端口忙，但TCP状态位于 TIME_WAIT ，可以重用端口。如果端口忙，而TCP状态位于其他状态，重用端口时依旧得到一个错误信息，指明"地址已经使用中"。如果你的服务程序停止后想立即重启，而新套接字依旧使用同一端口，此时SO_REUSEADDR 选项非常有用。必须意识到，此时任何非期望数据到达，都可能导致服务程序反应混乱，不过这只是一种可能，事实上很不可能。

MrRightLeft 2012-07-12 17:16 发表评论

linux 文件操作之close

MrRightLeft — Thu, 12 Jul 2012 08:13:00 GMT

#include <iostream>
#include <fcntl.h>
using namespace std;

int main()
{
    int fd = open("demo.txt", O_RDWR, 0);
    close(fd);
    int fd1 = open("demo1.txt", O_RDWR, 0);
    char *szMsg = "hello";
    int size = write(fd, szMsg, strlen(szMsg)+1);
    if (-1 == size)
    {
         cerr << "error!" << endl;
    }
    close(fd1);
    return 0;
}

猜一下上面程序的执行结果。
在write时，fd和fd1的值是一样的，write fd时，实际就是write fd1。
为了避免自己在程序中误操作，可以在close(fd)之后，加上fd = -1;

MrRightLeft 2012-07-12 16:13 发表评论

redis源码剖析-字符串

MrRightLeft — Mon, 02 Jul 2012 16:59:00 GMT

redis源码剖析-字符串

redis实现了自己的字符串结构。在文件sds.h/dsd.c中定义。redis中的字符串叫sds(simple dynamic string)。
sds实质是char*:

typedef char *sds;

sds通过sdsnewlen()函数来创建,sds sdsnewlen(const void *init, size_t initlen)。该函数内部会创建一个sdshdr的结构,返回值sds，即char *，该结构定义如下:

struct sdshdr
{
        int len;
        int free;
        char buf[];
};

其中len存储当前字符串的长度，free存储该结构体剩余可存储字节数，buf存储字符串值。sdsnewlen()函数在创建sdshdr后，会返回buf的地址（sdshdr->buf)。
sdsnewlen()函数创建了字符串，并返回字符串地址sds,要使用sdshdr中的len和free，则需要获取sdshdr结构体的地址。如何根据获得的sds得到sdshdr结构体的地址呢？

redis中参考了linux内核关于通用list(list_head)的实现机制,实现方法如下:

struct sdshdr *sh = (void*) (sds-(sizeof(struct sdshdr)));

sds是返回的字符串地址，即sdshdr->buf，用sds的地址减去其在结构体中的偏移，即可得到sdshdr的地址。由于buf在sdshdr结构体的最后，所以其偏移就是sizeof(len)+sizeof(free),该偏移恰好是sizeof(struct sdshdr)。
如果buf在sdshdr中的位置是任意的，如何根据buf的地址获取sdshdr的地址呢？实现如下:
假设现在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是调用sdsnewlen()返回的buf地址。即 sds sdsbuf = sdsnewlen(...);
((struct sdshdr *)0)->buf 表示当结构体sdshdr在地址0时，buf相对于sdshdr首地址的偏移。

MrRightLeft 2012-07-03 00:59 发表评论

64位网络字节序与主机字节序转换

MrRightLeft — Wed, 20 Jun 2012 08:50:00 GMT

64位网络字节序与主机字节序转换

unsigned long long ntohll(unsigned long long val)
{
    if (__BYTE_ORDER == __LITTLE_ENDIAN)
    {
        return (((unsigned long long )htonl((int)((val << 32) >> 32))) << 32) | (unsigned int)htonl((int)(val >> 32));
    }
    else if (__BYTE_ORDER == __BIG_ENDIAN)
    {
        return val;
    }
}

unsigned long long htonll(unsigned long long val)
{
    if (__BYTE_ORDER == __LITTLE_ENDIAN)
    {
        return (((unsigned long long )htonl((int)((val << 32) >> 32))) << 32) | (unsigned int)htonl((int)(val >> 32));
    }
    else if (__BYTE_ORDER == __BIG_ENDIAN)
    {
        return val;
    }
}

MrRightLeft 2012-06-20 16:50 发表评论

如何定义变长的TLV结构体？

MrRightLeft — Thu, 14 Jun 2012 07:46:00 GMT

如何定义变长的TLV结构体？

TLV是一种常用的用于通信的结构体格式。T表示tag，L表示length，V表示value。其中T和L是固定大小的，V是可变大小，L表示的是V的长度。通常用于结构化网络通信中的数据流。如0x3 3 'aa\0'，0x3 5 'aaaa\0',其中0x3表示tag的值，3 or 5表示的是后面的字符串的长度。由于V是可变长度的，所以在定义TLV结构时，需要将V定义成为可变大小。可定义如下：

struct TLV
{
    uint8_t tag;
    uint16_t len;
    char value[0];
}__attribute__((packed));

注意value分配的是0大小，最后一个成员为可变长的数组，对于TLV（Type-Length-Value）形式的结构，或者其他需要变长度的结构体，用这种方式定义最好。使用起来非常方便，创建时，malloc一段结构体大小加上可变长数据长度的空间给它，可变长部分可按数组的方式访问，释放时，直接把整个结构体free掉就可以了。__attribute__(packed)用来强制不对struct TLV进行4字节对齐，目的是为了获取真实的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;
}

这里有关于设置变长TLV的详细说明：http://www.douban.com/note/213324857/
这里有一个问题，如何实现嵌套TLV结构呢？大家有什么好的思路吗？欢迎交流
简单实现了一下嵌套TLV，不知道有没有问题。

#include
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;
}

MrRightLeft 2012-06-14 15:46 发表评论