近来对着文档学习一波Redis的设计与实现，一边看一边记笔记。

1. SDS的定义

   SDS对应的结构体sds.h/sdshdr

   1 2 3 4 5 6 7 8 9

   >struct sdshdr{ > //记录buf数组已存入的字节数 > //sds结构体存入的字符串的长度 > int len; > //当前sds结构体未使用的字节数(可调整) > int free; > char buf[]; >}; >

下图为SDS一个示例

free的属性值为0，表示当前SDS还有5个可用字节
len的属性值为5，表示当前SDS存入的字符串长度是5个字节
buf是个字符数组，前len个字节保存存入的字符，最后一个字节默认一直是保存空字符‘\0’
SDS默认保存多一个空字符，这样就能沿用C的部分字符串语法，而SDS仅仅是多用了一个字节的空间

2. 字符串长度时间复杂度

涉及的算法如下：

adjacent_find&search_n&partition&binary_search&equal_range

准备工作

1
2
3
4
5
6
7
8
9
10
11
12
13
14

struct Msg {
	int index;
	int msg;
};
//用于打印显式
void PrintVec(vector<Msg>::iterator iter_begin, vector<Msg>::iterator iter_end) {
	for (auto iter = iter_begin; iter != iter_end; iter++) {
		if (iter != iter_begin) {
			cout << "--";
		}
		cout << iter->index << ":" << iter->msg;
	}
	cout << endl << endl;
}

生成数据（所有的排序针对index，msg只是为了标识稳定与否）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

vector<Msg> v_msg;
//vector<Msg> v_msg_sec;
Msg temp_msg;
int count = 10; 
srand((int)time(0));
for (int i = 0; i < count; i++) {
	temp_msg.index = rand() % 100;
	temp_msg.msg = i;
	v_msg.push_back(temp_msg);
	//if (rand() % 2 == 0 && i != 0) {
	//	temp_msg.index = rand() % 100;
	//	temp_msg.msg = i;
	//	v_msg_sec.push_back(temp_msg);
	//}
}

• adjacent_find

本次所有的算法如下：

stable_sort&partial_sort&nth_element&is_sorted&is_sorted_until&merge&inplace_merge&find_if

准备工作

1
2
3
4
5
6
7
8
9
10
11
12
13
14

struct Msg {
	int index;
	int msg;
};
//用于打印显式
void PrintVec(vector<Msg>::iterator iter_begin, vector<Msg>::iterator iter_end) {
	for (auto iter = iter_begin; iter != iter_end; iter++) {
		if (iter != iter_begin) {
			cout << "--";
		}
		cout << iter->index << ":" << iter->msg;
	}
	cout << endl << endl;
}

生成数据（所有的排序针对index，msg只是为了标识稳定与否）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

vector<Msg> v_msg;
//vector<Msg> v_msg_sec;
Msg temp_msg;
int count = 10; 
srand((int)time(0));
for (int i = 0; i < count; i++) {
	temp_msg.index = rand() % 100;
	temp_msg.msg = i;
	v_msg.push_back(temp_msg);
	//if (rand() % 2 == 0 && i != 0) {
	//	temp_msg.index = rand() % 100;
	//	temp_msg.msg = i;
	//	v_msg_sec.push_back(temp_msg);
	//}
}

• stable_sort

C++ 11的新特性之final

final是说明符而不是关键字，这意味着可以将它用作标识符(override同样)

说明符final，用于阻止派生类覆盖特定的虚方法。或者是阻止一个类成为基类。

一个简单的TCP socket通讯的实例。

功能简单说明：
服务端主线程一直阻塞在accept，每连接上一个客户端，就创建一个新的线程去处理这个客户端的消息。
其中新线程中一直处于接收客户端的消息中，每接收一次都回复一个keep alive，当收到来自客户端stop消息时，就断开连接，并关闭当前线程。

一.服务端

1. 创建套接字

   1 2 3 4 5 6

   WORD sockVersion = MAKEWORD(2, 2); WSADATA wsaData; if (WSAStartup(sockVersion, &wsaData) != 0) { return 0; } //WSA(Windows Sockets Asynchronous，Windows异步套接字)的启动命令

2. 绑定套接字到IP和端口

   1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

   //创建并初始化socket SOCKET listen_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if (listen_socket == INVALID_SOCKET) { printf("socket init error code:%d", WSAGetLastError()); return 0; } //绑定结构 struct sockaddr_in sin; sin.sin_family = AF_INET; sin.sin_port = htons(6666); sin.sin_addr.S_un.S_addr = INADDR_ANY; //绑定 if (bind(listen_socket, (LPSOCKADDR)&sin, sizeof(sin)) != 0) { printf("bind socket error code:%d", WSAGetLastError()); closesocket(listen_socket);//注意socket回收 return 0; }

3. 监听端口