FastDFS源码分析之tracker协议分析

待我称王封你为后i 2022-08-23 08:26 335阅读 0赞

本篇博客主要讲解fastdfs中tracker协议的讲解。

fastdfs主要是存储文件，直接把整个文件存储到磁盘上，所以，简单直接。但是也有很大的局限性。

因此，fastdfs对文件的目录设置和存储是最为核心的。

为什么这么突然的讲解这些。因为我已经看了一段时间的fastdfs，主要结构都已经搞的比较清晰了。因此，这篇文章，我就主要一tracker这一部分的协议来分析。

其他具体介绍tracker的请百度。我就不介绍了，我就直接从

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **int** tracker\_deal\_task(**struct** fast\_task\_info \*pTask)

这个方法开始对每个case分析。

**1、storage心跳协议**

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **case** TRACKER\_PROTO\_CMD\_STORAGE\_BEAT:  
2.              TRACKER\_CHECK\_LOGINED(pTask)  
3.              result = tracker\_deal\_storage\_beat(pTask);  
4.              **break**;

自然，该协议是从storage层发送给tracker层的数据包，

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#define TRACKER\_PROTO\_CMD\_STORAGE\_BEAT              83  //storage heart beat

那么，storage主要是做了什么：

storage在启动的时候，会开启一个线程，该线程为

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **static** **void** \*tracker\_report\_thread\_entrance(**void** \*arg)

该函数主要是做了根据配置连接相应的它的组的tacker，做一些事情，这里有个while循环，代码如下

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  current\_time = g\_current\_time;  
2.              **if** (current\_time - last\_beat\_time >= \\  
3.                      g\_heart\_beat\_interval)  
4.              \{  
5.                  **if** (tracker\_heart\_beat(pTrackerServer, \\  
6.                      &stat\_chg\_sync\_count, \\  
7.                      &bServerPortChanged) != 0)  
8.                  \{  
9.                      **break**;  
10.                 \}

也就是至少30秒钟来一次心跳，心跳包的主要数据是包头和当前storage的状态信息，

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **char** out\_buff\[**sizeof**(TrackerHeader) + **sizeof**(FDFSStorageStatBuff)\];

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  /\* struct for network transfering \*/  
2.  **typedef** **struct**  
3.  \{  
4.      **char** sz\_total\_upload\_count\[8\];  
5.      **char** sz\_success\_upload\_count\[8\];  
6.      **char** sz\_total\_append\_count\[8\];  
7.      **char** sz\_success\_append\_count\[8\];  
8.      **char** sz\_total\_modify\_count\[8\];  
9.      **char** sz\_success\_modify\_count\[8\];  
10.     **char** sz\_total\_truncate\_count\[8\];  
11.     **char** sz\_success\_truncate\_count\[8\];  
12.     **char** sz\_total\_set\_meta\_count\[8\];  
13.     **char** sz\_success\_set\_meta\_count\[8\];  
14.     **char** sz\_total\_delete\_count\[8\];  
15.     **char** sz\_success\_delete\_count\[8\];  
16.     **char** sz\_total\_download\_count\[8\];  
17.     **char** sz\_success\_download\_count\[8\];  
18.     **char** sz\_total\_get\_meta\_count\[8\];  
19.     **char** sz\_success\_get\_meta\_count\[8\];  
20.     **char** sz\_total\_create\_link\_count\[8\];  
21.     **char** sz\_success\_create\_link\_count\[8\];  
22.     **char** sz\_total\_delete\_link\_count\[8\];  
23.     **char** sz\_success\_delete\_link\_count\[8\];  
24.     **char** sz\_total\_upload\_bytes\[8\];  
25.     **char** sz\_success\_upload\_bytes\[8\];  
26.     **char** sz\_total\_append\_bytes\[8\];  
27.     **char** sz\_success\_append\_bytes\[8\];  
28.     **char** sz\_total\_modify\_bytes\[8\];  
29.     **char** sz\_success\_modify\_bytes\[8\];  
30.     **char** sz\_total\_download\_bytes\[8\];  
31.     **char** sz\_success\_download\_bytes\[8\];  
32.     **char** sz\_total\_sync\_in\_bytes\[8\];  
33.     **char** sz\_success\_sync\_in\_bytes\[8\];  
34.     **char** sz\_total\_sync\_out\_bytes\[8\];  
35.     **char** sz\_success\_sync\_out\_bytes\[8\];  
36.     **char** sz\_total\_file\_open\_count\[8\];  
37.     **char** sz\_success\_file\_open\_count\[8\];  
38.     **char** sz\_total\_file\_read\_count\[8\];  
39.     **char** sz\_success\_file\_read\_count\[8\];  
40.     **char** sz\_total\_file\_write\_count\[8\];  
41.     **char** sz\_success\_file\_write\_count\[8\];  
42.     **char** sz\_last\_source\_update\[8\];  
43.     **char** sz\_last\_sync\_update\[8\];  
44.     **char** sz\_last\_synced\_timestamp\[8\];  
45.     **char** sz\_last\_heart\_beat\_time\[8\];  
46. \} FDFSStorageStatBuff;

tracker主要是做了什么呢？

对其进行解包，然后对这个保存在本地的storage的信息进行保存到文件中，调用

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  status = tracker\_save\_storages();

调用

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  tracker\_mem\_active\_store\_server(pClientInfo->pGroup, \\  
2.              pClientInfo->pStorage);

将这个存储服务器如果没有，就插入到group中。

最后调用

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **static** **int** tracker\_check\_and\_sync(**struct** fast\_task\_info \*pTask, \\  
2.              **const** **int** status)

检查相应的改变状态，并将其同步等。（需要再详细看看）

2、报告相应同步时间

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#define TRACKER\_PROTO\_CMD\_STORAGE\_SYNC\_REPORT       89  //report src last synced time as dest server

同样在storage的report线程执行

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **if** (sync\_time\_chg\_count != g\_sync\_change\_count && \\  
2.                  current\_time - last\_sync\_report\_time >= \\  
3.                      g\_heart\_beat\_interval)  
4.              \{  
5.                  **if** (tracker\_report\_sync\_timestamp( \\  
6.                      pTrackerServer, &bServerPortChanged)!=0)  
7.                  \{  
8.                      **break**;  
9.                  \}  
10.   
11.                 sync\_time\_chg\_count = g\_sync\_change\_count;  
12.                 last\_sync\_report\_time = current\_time;  
13.             \}

具体的数据包为

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1. pEnd = g\_storage\_servers + g\_storage\_count;  
2.     **for** (pServer=g\_storage\_servers; pServer<pEnd; pServer++)  
3.     \{  
4.         memcpy(p, pServer->server.id, FDFS\_STORAGE\_ID\_MAX\_SIZE);  
5.         p += FDFS\_STORAGE\_ID\_MAX\_SIZE;  
6.         int2buff(pServer->last\_sync\_src\_timestamp, p);  
7.         p += 4;  
8.     \}

也就是遍历当前进程的本组所有storage服务器，和上次同步的时间戳，给tracker服务器。

然后tracker的服务器存储结构为

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  pClientInfo->pGroup->last\_sync\_timestamps \\  
2.                  \[src\_index\]\[dest\_index\] = sync\_timestamp;

dest\_index 值为当前连接所在组的索引值

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1. dest\_index = tracker\_mem\_get\_storage\_index(pClientInfo->pGroup,  
2.             pClientInfo->pStorage);  
3.     **if** (dest\_index < 0 || dest\_index >= pClientInfo->pGroup->count)  
4.     \{  
5.         status = 0;  
6.         **break**;  
7.     \}

因为 本链接的storage是固定不变的，而src\_index就是为本组的其他storage的id索引，

首相通过id，（ip地址）找到具体的storage，然后在通过指针找到索引位置，

最后，调用

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **if** (++g\_storage\_sync\_time\_chg\_count % \\  
2.          TRACKER\_SYNC\_TO\_FILE\_FREQ == 0)  
3.  \{  
4.      status = tracker\_save\_sync\_timestamps();  
5.  \}  
6.  **else**  
7.  \{  
8.      status = 0;  
9.  \}  
10. \} **while** (0);  
11.   
12. **return** tracker\_check\_and\_sync(pTask, status);

定时保存文件和检查等

3、上报磁盘情况

\#define TRACKER\_PROTO\_CMD\_STORAGE\_REPORT\_DISK\_USAGE 84  //report disk usage

同样线程定时调用，

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **if** (current\_time - last\_df\_report\_time >= \\  
2.                  g\_stat\_report\_interval)  
3.          \{  
4.              **if** (tracker\_report\_df\_stat(pTrackerServer, \\  
5.                      &bServerPortChanged) != 0)  
6.              \{  
7.                  **break**;  
8.              \}  
9.    
10.             last\_df\_report\_time = current\_time;  
11.         \}

同样上报这些数据

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1. **for** (i=0; i<g\_fdfs\_store\_paths.count; i++)  
2.     \{  
3.         **if** (statvfs(g\_fdfs\_store\_paths.paths\[i\], &sbuf) != 0)  
4.         \{  
5.             logError("file: "\_\_FILE\_\_", line: %d, " \\  
6.                 "call statfs fail, errno: %d, error info: %s.",\\  
7.                 \_\_LINE\_\_, errno, STRERROR(errno));  
8.   
9.             **if** (pBuff != out\_buff)  
10.             \{  
11.                 free(pBuff);  
12.             \}  
13.             **return** errno != 0 ? errno : EACCES;  
14.         \}  
15.   
16.         g\_path\_space\_list\[i\].total\_mb = ((int64\_t)(sbuf.f\_blocks) \* \\  
17.                     sbuf.f\_frsize) / FDFS\_ONE\_MB;  
18.         g\_path\_space\_list\[i\].free\_mb = ((int64\_t)(sbuf.f\_bavail) \* \\  
19.                     sbuf.f\_frsize) / FDFS\_ONE\_MB;  
20.         long2buff(g\_path\_space\_list\[i\].total\_mb, pStatBuff->sz\_total\_mb);  
21.         long2buff(g\_path\_space\_list\[i\].free\_mb, pStatBuff->sz\_free\_mb);  
22.   
23.         pStatBuff++;  
24.     \}

tracker这边存储在

int64\_t \*path\_total\_mbs; //total disk storage in MB  
int64\_t \*path\_free\_mbs;  //free disk storage in MB

这里

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  path\_total\_mbs\[i\] = buff2long(pStatBuff->sz\_total\_mb);  
2.          path\_free\_mbs\[i\] = buff2long(pStatBuff->sz\_free\_mb);  
3.    
4.          pClientInfo->pStorage->total\_mb += path\_total\_mbs\[i\];  
5.          pClientInfo->pStorage->free\_mb += path\_free\_mbs\[i\];

4、storage服加入到tracker

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#define TRACKER\_PROTO\_CMD\_STORAGE\_JOIN              81

storage线程同样在该处调用

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **if** (tracker\_report\_join(pTrackerServer, tracker\_index, \\  
2.                      sync\_old\_done) != 0)  
3.          \{  
4.              sleep(g\_heart\_beat\_interval);  
5.              **continue**;  
6.          \}

发送的包体数据包为：

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **typedef** **struct**  
2.  \{  
3.      **char** group\_name\[FDFS\_GROUP\_NAME\_MAX\_LEN+1\];  
4.      **char** storage\_port\[FDFS\_PROTO\_PKG\_LEN\_SIZE\];  
5.      **char** storage\_http\_port\[FDFS\_PROTO\_PKG\_LEN\_SIZE\];  
6.      **char** store\_path\_count\[FDFS\_PROTO\_PKG\_LEN\_SIZE\];  
7.      **char** subdir\_count\_per\_path\[FDFS\_PROTO\_PKG\_LEN\_SIZE\];  
8.      **char** upload\_priority\[FDFS\_PROTO\_PKG\_LEN\_SIZE\];  
9.      **char** join\_time\[FDFS\_PROTO\_PKG\_LEN\_SIZE\]; //storage join timestamp  
10.     **char** up\_time\[FDFS\_PROTO\_PKG\_LEN\_SIZE\];   //storage service started timestamp  
11.     **char** version\[FDFS\_VERSION\_SIZE\];   //storage version  
12.     **char** domain\_name\[FDFS\_DOMAIN\_NAME\_MAX\_SIZE\];  
13.     **char** init\_flag;  
14.     **signed** **char** status;  
15.     **char** tracker\_count\[FDFS\_PROTO\_PKG\_LEN\_SIZE\];  //all tracker server count  
16. \} TrackerStorageJoinBody;

当赋值完成后，在气候变加入

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1. p = out\_buff + **sizeof**(TrackerHeader) + **sizeof**(TrackerStorageJoinBody);  
2.     pServerEnd = g\_tracker\_group.servers + g\_tracker\_group.server\_count;  
3.     **for** (pServer=g\_tracker\_group.servers; pServer<pServerEnd; pServer++)  
4.     \{  
5.         /\* 
6.         if (strcmp(pServer->ip\_addr, pTrackerServer->ip\_addr) == 0 && \\ 
7.             pServer->port == pTrackerServer->port) 
8.         \{  
9.             continue; 
10.         \} 
11.         tracker\_count++; 
12.         \*/  
13.   
14.         sprintf(p, "%s:%d", pServer->ip\_addr, pServer->port);  
15.         p += FDFS\_PROTO\_IP\_PORT\_SIZE;  
16.     \}

加入所有tracker的服务器信息格式为ip:port

tracker 服务器接收

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **case** TRACKER\_PROTO\_CMD\_STORAGE\_JOIN:  
2.          result = tracker\_deal\_storage\_join(pTask);  
3.          **break**;

获取到的相关信息存储到

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **typedef** **struct**  
2.  \{  
3.      **int** storage\_port;  
4.      **int** storage\_http\_port;  
5.      **int** store\_path\_count;  
6.      **int** subdir\_count\_per\_path;  
7.      **int** upload\_priority;  
8.      **int** join\_time; //storage join timestamp (create timestamp)  
9.      **int** up\_time;   //storage service started timestamp  
10.         **char** version\[FDFS\_VERSION\_SIZE\];   //storage version  
11.     **char** group\_name\[FDFS\_GROUP\_NAME\_MAX\_LEN + 1\];  
12.         **char** domain\_name\[FDFS\_DOMAIN\_NAME\_MAX\_SIZE\];  
13.         **char** init\_flag;  
14.     **signed** **char** status;  
15.     **int** tracker\_count;  
16.     ConnectionInfo tracker\_servers\[FDFS\_MAX\_TRACKERS\];  
17. \} FDFSStorageJoinBody;

这些结构体内

同时插入本地内存

result = tracker\_mem\_add\_group\_and\_storage(pClientInfo, \\  
pTask->client\_ip, &joinBody, true);

同时把发消息报的id传过来

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  pJoinBodyResp = (TrackerStorageJoinBodyResp \*)(pTask->data + \\  
2.              **sizeof**(TrackerHeader));  
3.  memset(pJoinBodyResp, 0, **sizeof**(TrackerStorageJoinBodyResp));  
4.    
5.  **if** (pClientInfo->pStorage->psync\_src\_server != NULL)  
6.  \{  
7.      strcpy(pJoinBodyResp->src\_id, \\  
8.          pClientInfo->pStorage->psync\_src\_server->id);  
9.  \}

5、报告存储状态

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#define TRACKER\_PROTO\_CMD\_STORAGE\_REPORT\_STATUS     76  //report specified storage server status

storage服务器调用

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **int** tracker\_report\_storage\_status(ConnectionInfo \*pTrackerServer, \\  
2.          FDFSStorageBrief \*briefServer)

内容主要是组名字

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  strcpy(out\_buff + **sizeof**(TrackerHeader), g\_group\_name);

和简要信息

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  memcpy(out\_buff + **sizeof**(TrackerHeader) + FDFS\_GROUP\_NAME\_MAX\_LEN, \\  
2.          briefServer, **sizeof**(FDFSStorageBrief));

其结构体如下

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **typedef** **struct**  
2.  \{  
3.      **char** status;  
4.      **char** port\[4\];  
5.      **char** id\[FDFS\_STORAGE\_ID\_MAX\_SIZE\];  
6.      **char** ip\_addr\[IP\_ADDRESS\_SIZE\];  
7.  \} FDFSStorageBrief;

6、从tracker获取storage状态。

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#define TRACKER\_PROTO\_CMD\_STORAGE\_GET\_STATUS        71  //get storage status from tracker

该协议是由client发起

调用流程如下：

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **int** tracker\_get\_storage\_status(ConnectionInfo \*pTrackerServer, \\  
2.          **const** **char** \*group\_name, **const** **char** \*ip\_addr, \\  
3.          FDFSStorageBrief \*pDestBuff)  
4.  **int** tracker\_get\_storage\_max\_status(TrackerServerGroup \*pTrackerGroup, \\  
5.          **const** **char** \*group\_name, **const** **char** \*ip\_addr, \\  
6.          **char** \*storage\_id, **int** \*status)    
7.  **int** tracker\_get\_storage\_status(ConnectionInfo \*pTrackerServer, \\  
8.          **const** **char** \*group\_name, **const** **char** \*ip\_addr, \\  
9.          FDFSStorageBrief \*pDestBuff)

获取自己的状态，

包体格式   组名 ip的字符串

tracker通过获取了相应的数据，查找到storage的信息

结构体为：

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

赋值后，返回

7、通过tracker获取storageid

\#define TRACKER\_PROTO\_CMD\_STORAGE\_GET\_SERVER\_ID     70  //get storage server id from tracker

和上以协议请求一样 groupname+ip 组成。

tracker处理方法

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **static** **int** tracker\_deal\_get\_storage\_id(**struct** fast\_task\_info \*pTask)

tracker最后通过

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  FDFSStorageIdInfo \*fdfs\_get\_storage\_id\_by\_ip(**const** **char** \*group\_name, \\  
2.          **const** **char** \*pIpAddr)  
3.  \{  
4.      FDFSStorageIdInfo target;  
5.      memset(&target, 0, **sizeof**(FDFSStorageIdInfo));  
6.      snprintf(target.group\_name, **sizeof**(target.group\_name), "%s", group\_name);  
7.      snprintf(target.ip\_addr, **sizeof**(target.ip\_addr), "%s", pIpAddr);  
8.      **return** (FDFSStorageIdInfo \*)bsearch(&target, g\_storage\_ids\_by\_ip, \\  
9.          g\_storage\_id\_count, **sizeof**(FDFSStorageIdInfo), \\  
10.         fdfs\_cmp\_group\_name\_and\_ip);  
11. \}

该方法获取了了

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  FDFSStorageIdInfo

信息，然后赋值，返回。

**8、通过tracker获取所有storage服务器**

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#define TRACKER\_PROTO\_CMD\_STORAGE\_FETCH\_STORAGE\_IDS 69  //get all storage ids from tracker

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1. **for** (i=0; i<5; i++)  
2. \{  
3.     **for** (pGServer=pServerStart; pGServer<pServerEnd; pGServer++)  
4.     \{  
5.         memcpy(pTServer, pGServer, **sizeof**(ConnectionInfo));  
6.         pTServer->sock = -1;  
7.         result = fdfs\_get\_storage\_ids\_from\_tracker\_server(pTServer);  
8.         **if** (result == 0)  
9.         \{  
10.             **return** result;  
11.         \}  
12.     \}  
13.   
14.     **if** (pServerStart != pTrackerGroup->servers)  
15.     \{  
16.         pServerStart = pTrackerGroup->servers;  
17.     \}  
18.     sleep(1);  
19. \}

调用顺序

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **int** storage\_func\_init(**const** **char** \*filename, **char** \*bind\_addr, **const** **int** addr\_size)  
2.  **int** fdfs\_get\_storage\_ids\_from\_tracker\_group(TrackerServerGroup \*pTrackerGroup)  
3.  **int** fdfs\_get\_storage\_ids\_from\_tracker\_server(ConnectionInfo \*pTrackerServer)

tracker函数，每秒钟中调用，遍历所有的trackers服务器

tracker服务器获取

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **case** TRACKER\_PROTO\_CMD\_STORAGE\_FETCH\_STORAGE\_IDS:  
2.              result = tracker\_deal\_fetch\_storage\_ids(pTask);  
3.              **break**;

然后通过这种协议格式

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1. </pre>返回的数据<pre name="code" **class**="cpp">pIdsStart = g\_storage\_ids\_by\_ip + start\_index;  
2.     pIdsEnd = g\_storage\_ids\_by\_ip + g\_storage\_id\_count;  
3.     **for** (pIdInfo = pIdsStart; pIdInfo < pIdsEnd; pIdInfo++)  
4.     \{  
5.         **if** ((**int**)(p - pTask->data) > pTask->size - 64)  
6.         \{  
7.             **break**;  
8.         \}  
9.   
10.         p += sprintf(p, "%s %s %s\\n", pIdInfo->id, \\  
11.             pIdInfo->group\_name, pIdInfo->ip\_addr);  
12.     \}

返回给请求者。

9、回复给新的storage

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#define TRACKER\_PROTO\_CMD\_STORAGE\_REPLICA\_CHG       85  //repl new storage servers

storage服务器调用流程：

剩下的协议

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **static** **int** tracker\_merge\_servers(ConnectionInfo \*pTrackerServer, \\  
2.          FDFSStorageBrief \*briefServers, **const** **int** server\_count)

**\[cpp\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **case** TRACKER\_PROTO\_CMD\_SERVICE\_QUERY\_FETCH\_ONE:  
2.              result = tracker\_deal\_service\_query\_fetch\_update( \\  
3.                      pTask, pHeader->cmd);  
4.              **break**;  
5.          **case** TRACKER\_PROTO\_CMD\_SERVICE\_QUERY\_UPDATE:  
6.              result = tracker\_deal\_service\_query\_fetch\_update( \\  
7.                      pTask, pHeader->cmd);  
8.              **break**;  
9.          **case** TRACKER\_PROTO\_CMD\_SERVICE\_QUERY\_FETCH\_ALL:  
10.             result = tracker\_deal\_service\_query\_fetch\_update( \\  
11.                     pTask, pHeader->cmd);  
12.             **break**;  
13.         **case** TRACKER\_PROTO\_CMD\_SERVICE\_QUERY\_STORE\_WITHOUT\_GROUP\_ONE:  
14.             result = tracker\_deal\_service\_query\_storage( \\  
15.                     pTask, pHeader->cmd);  
16.             **break**;  
17.         **case** TRACKER\_PROTO\_CMD\_SERVICE\_QUERY\_STORE\_WITH\_GROUP\_ONE:  
18.             result = tracker\_deal\_service\_query\_storage( \\  
19.                     pTask, pHeader->cmd);  
20.             **break**;  
21.         **case** TRACKER\_PROTO\_CMD\_SERVICE\_QUERY\_STORE\_WITHOUT\_GROUP\_ALL:  
22.             result = tracker\_deal\_service\_query\_storage( \\  
23.                     pTask, pHeader->cmd);  
24.             **break**;  
25.         **case** TRACKER\_PROTO\_CMD\_SERVICE\_QUERY\_STORE\_WITH\_GROUP\_ALL:  
26.             result = tracker\_deal\_service\_query\_storage( \\  
27.                     pTask, pHeader->cmd);  
28.             **break**;  
29.         **case** TRACKER\_PROTO\_CMD\_SERVER\_LIST\_ONE\_GROUP:  
30.             result = tracker\_deal\_server\_list\_one\_group(pTask);  
31.             **break**;  
32.         **case** TRACKER\_PROTO\_CMD\_SERVER\_LIST\_ALL\_GROUPS:  
33.             result = tracker\_deal\_server\_list\_all\_groups(pTask);  
34.             **break**;  
35.         **case** TRACKER\_PROTO\_CMD\_SERVER\_LIST\_STORAGE:  
36.             result = tracker\_deal\_server\_list\_group\_storages(pTask);  
37.             **break**;  
38.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_SYNC\_SRC\_REQ:  
39.             result = tracker\_deal\_storage\_sync\_src\_req(pTask);  
40.             **break**;  
41.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_SYNC\_DEST\_REQ:  
42.             TRACKER\_CHECK\_LOGINED(pTask)  
43.             result = tracker\_deal\_storage\_sync\_dest\_req(pTask);  
44.             **break**;  
45.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_SYNC\_NOTIFY:  
46.             result = tracker\_deal\_storage\_sync\_notify(pTask);  
47.             **break**;  
48.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_SYNC\_DEST\_QUERY:  
49.             result = tracker\_deal\_storage\_sync\_dest\_query(pTask);  
50.             **break**;  
51.         **case** TRACKER\_PROTO\_CMD\_SERVER\_DELETE\_STORAGE:  
52.             result = tracker\_deal\_server\_delete\_storage(pTask);  
53.             **break**;  
54.         **case** TRACKER\_PROTO\_CMD\_SERVER\_SET\_TRUNK\_SERVER:  
55.             result = tracker\_deal\_server\_set\_trunk\_server(pTask);  
56.             **break**;  
57.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_REPORT\_IP\_CHANGED:  
58.             result = tracker\_deal\_storage\_report\_ip\_changed(pTask);  
59.             **break**;  
60.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_CHANGELOG\_REQ:  
61.             result = tracker\_deal\_changelog\_req(pTask);  
62.             **break**;  
63.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_PARAMETER\_REQ:  
64.             result = tracker\_deal\_parameter\_req(pTask);  
65.             **break**;  
66.         **case** FDFS\_PROTO\_CMD\_QUIT:  
67.             close(pTask->ev\_read.ev\_fd);  
68.             task\_finish\_clean\_up(pTask);  
69.             **return** 0;  
70.         **case** FDFS\_PROTO\_CMD\_ACTIVE\_TEST:  
71.             result = tracker\_deal\_active\_test(pTask);  
72.             **break**;  
73.         **case** TRACKER\_PROTO\_CMD\_TRACKER\_GET\_STATUS:  
74.             result = tracker\_deal\_get\_tracker\_status(pTask);  
75.             **break**;  
76.         **case** TRACKER\_PROTO\_CMD\_TRACKER\_GET\_SYS\_FILES\_START:  
77.             result = tracker\_deal\_get\_sys\_files\_start(pTask);  
78.             **break**;  
79.         **case** TRACKER\_PROTO\_CMD\_TRACKER\_GET\_ONE\_SYS\_FILE:  
80.             result = tracker\_deal\_get\_one\_sys\_file(pTask);  
81.             **break**;  
82.         **case** TRACKER\_PROTO\_CMD\_TRACKER\_GET\_SYS\_FILES\_END:  
83.             result = tracker\_deal\_get\_sys\_files\_end(pTask);  
84.             **break**;  
85.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_REPORT\_TRUNK\_FID:  
86.             TRACKER\_CHECK\_LOGINED(pTask)  
87.             result = tracker\_deal\_report\_trunk\_fid(pTask);  
88.             **break**;  
89.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_FETCH\_TRUNK\_FID:  
90.             TRACKER\_CHECK\_LOGINED(pTask)  
91.             result = tracker\_deal\_get\_trunk\_fid(pTask);  
92.             **break**;  
93.         **case** TRACKER\_PROTO\_CMD\_STORAGE\_REPORT\_TRUNK\_FREE:  
94.             TRACKER\_CHECK\_LOGINED(pTask)  
95.             result = tracker\_deal\_report\_trunk\_free\_space(pTask);  
96.             **break**;  
97.         **case** TRACKER\_PROTO\_CMD\_TRACKER\_PING\_LEADER:  
98.             result = tracker\_deal\_ping\_leader(pTask);  
99.             **break**;  
100.         **case** TRACKER\_PROTO\_CMD\_TRACKER\_NOTIFY\_NEXT\_LEADER:  
101.             result = tracker\_deal\_notify\_next\_leader(pTask);  
102.             **break**;  
103.         **case** TRACKER\_PROTO\_CMD\_TRACKER\_COMMIT\_NEXT\_LEADER:  
104.             result = tracker\_deal\_commit\_next\_leader(pTask);  
105.             **break**;

[view plain]: http://blog.csdn.net/wallwind/article/details/39696239#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/478453
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/478453/fork