graph TD
A(Server)

B1(MonitorService)
B2(PrecreatorService)
B3(SnapshotterService)
B4(ContinuousQueryService)
B5(HTTPDService)
    B5_A1(handler)
        B5_B1(serveOptions)
        B5_B2(serveQuery)
            B5_B2_A1(InfluxQL)
        B5_B3(serveWrite)
            B5_B3_A1(PointWriter)
                B5_B3_A1_A1(TSM-engine)
                    B5_B3_A1_A1_A1(WAL)
                    B5_B3_A1_A1_A2(FileStore)
                    B5_B3_A1_A1_A3(Compactor)
                B5_B3_A1_A2(TSI)
        B5_B4(servePromWrite)
        B5_B5(servePromRead)
        B5_B6(servePing)
        B5_B7(serveStatus)
        B5_B8(promhttp_ServeHTTP)
B6(StorageService)
B7(RetentionPolicyService)
B8(GraphiteService/CollectdService/OpenTSDBService/UDPService)

A-->B1
A-->B2
A-->B3
A-->B4
A-->B5
A-->B6
A-->B7
A-->|可选|B8
B5-->B5_A1

subgraph HTTPDService
B5_A1-->|query-options/write-options|B5_B1
B5_A1-->|query|B5_B2
B5_A1-->|write|B5_B3
B5_A1-->|prometheus-write|B5_B4
B5_A1-->|prometheus-read|B5_B5
B5_A1-->|ping/ping-head|B5_B6
B5_A1-->|status/status-head|B5_B7
B5_A1-->|prometheus-metrics|B5_B8
B5_B3-->B5_B3_A1
end

subgraph InfluxQL
B5_B2-->B5_B2_A1
end

subgraph TSDB
B5_B3_A1-->B5_B3_A1_A1
B5_B3_A1_A2
end


subgraph TSM-engine
B5_B3_A1_A1-->B5_B3_A1_A1_A1
B5_B3_A1_A1-->B5_B3_A1_A1_A2
B5_B3_A1_A1-->B5_B3_A1_A1_A3
end

B5_B2_A1-->B5_B3_A1_A1
B5_B2_A1-->B5_B3_A1_A2

// Open shared TCP connection.
ln, err := net.Listen("tcp", s.BindAddress)
if err != nil {
	return fmt.Errorf("listen: %s", err)
}
s.Listener = ln

// Multiplex listener.
mux := tcp.NewMux()
go mux.Serve(ln)

// Append services.
s.appendMonitorService()
s.appendPrecreatorService(s.config.Precreator)
s.appendSnapshotterService()
s.appendContinuousQueryService(s.config.ContinuousQuery)
s.appendHTTPDService(s.config.HTTPD)
s.appendStorageService(s.config.Storage)
s.appendRetentionPolicyService(s.config.Retention)
for _, i := range s.config.GraphiteInputs {
	if err := s.appendGraphiteService(i); err != nil {
		return err
	}
}
for _, i := range s.config.CollectdInputs {
	s.appendCollectdService(i)
}
for _, i := range s.config.OpenTSDBInputs {
	if err := s.appendOpenTSDBService(i); err != nil {
		return err
	}
}
for _, i := range s.config.UDPInputs {
	s.appendUDPService(i)
}

s.Subscriber.MetaClient = s.MetaClient
s.PointsWriter.MetaClient = s.MetaClient
s.Monitor.MetaClient = s.MetaClient

s.SnapshotterService.Listener = mux.Listen(snapshotter.MuxHeader)
....... } ```

// Limit the number of concurrent & enqueued write requests.
h.writeThrottler = NewThrottler(c.MaxConcurrentWriteLimit, c.MaxEnqueuedWriteLimit)
h.writeThrottler.EnqueueTimeout = c.EnqueuedWriteTimeout

// Disable the write log if they have been suppressed.
writeLogEnabled := c.LogEnabled
if c.SuppressWriteLog {
	writeLogEnabled = false
}

h.AddRoutes([]Route{
	Route{
		"query-options", // Satisfy CORS checks.
		"OPTIONS", "/query", false, true, h.serveOptions,
	},
	Route{
		"query", // Query serving route.
		"GET", "/query", true, true, h.serveQuery,
	},
	Route{
		"query", // Query serving route.
		"POST", "/query", true, true, h.serveQuery,
	},
	Route{
		"write-options", // Satisfy CORS checks.
		"OPTIONS", "/write", false, true, h.serveOptions,
	},
	Route{
		"write", // Data-ingest route.
		"POST", "/write", true, writeLogEnabled, h.serveWrite,
	},
	Route{
		"prometheus-write", // Prometheus remote write
		"POST", "/api/v1/prom/write", false, true, h.servePromWrite,
	},
	Route{
		"prometheus-read", // Prometheus remote read
		"POST", "/api/v1/prom/read", true, true, h.servePromRead,
	},
	Route{ // Ping
		"ping",
		"GET", "/ping", false, true, h.servePing,
	},
	Route{ // Ping
		"ping-head",
		"HEAD", "/ping", false, true, h.servePing,
	},
	Route{ // Ping w/ status
		"status",
		"GET", "/status", false, true, h.serveStatus,
	},
	Route{ // Ping w/ status
		"status-head",
		"HEAD", "/status", false, true, h.serveStatus,
	},
	Route{
		"prometheus-metrics",
		"GET", "/metrics", false, true, promhttp.Handler().ServeHTTP,
	},
}...)

return h }

# 读写流程

## 数据写入代码调用流程

## 数据读取代码调用流程