2012年8月28日

关于微信和QQ的一点思考

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

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

posted @ 2012-08-28 18:24 MrRightLeft 阅读(2591) | 评论 (8)编辑 收藏

2012年7月17日

redis源码剖析-main流程

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


posted @ 2012-07-17 13:28 MrRightLeft 阅读(1131) | 评论 (0)编辑 收藏

2012年7月15日

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

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()函数来查看它们之间的不同。

posted @ 2012-07-15 21:01 MrRightLeft 阅读(3866) | 评论 (2)编辑 收藏

2012年7月13日

同步io与异步io

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

posted @ 2012-07-13 15:45 MrRightLeft 阅读(338) | 评论 (0)编辑 收藏

socket close_on_exec

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);
 }

posted @ 2012-07-13 15:08 MrRightLeft 阅读(672) | 评论 (0)编辑 收藏

2012年7月12日

SO_REUSEADDR

SO_REUSEADDR

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

posted @ 2012-07-12 17:16 MrRightLeft 阅读(499) | 评论 (0)编辑 收藏

linux 文件操作之close

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

posted @ 2012-07-12 16:13 MrRightLeft 阅读(1026) | 评论 (0)编辑 收藏

2012年7月3日

redis源码剖析-字符串

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首地址的偏移。

posted @ 2012-07-03 00:59 MrRightLeft 阅读(1418) | 评论 (0)编辑 收藏

2012年6月20日

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

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

}

 

posted @ 2012-06-20 16:50 MrRightLeft 阅读(6598) | 评论 (1)编辑 收藏

2012年6月14日

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

如何定义变长的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 <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;
}




posted @ 2012-06-14 15:46 MrRightLeft 阅读(6478) | 评论 (4)编辑 收藏

仅列出标题  下一页
<2024年11月>
272829303112
3456789
10111213141516
17181920212223
24252627282930
1234567

导航

统计

随笔分类

随笔档案

文章分类

文章档案

搜索

最新评论

阅读排行榜

评论排行榜