sentinel功能強大，但是開源出來的sentinel可以說是一個半成品，bug多，並且很多功能沒有實現，可能是因為它有收費的版本吧。因此我們如果想在生產上應用就要戒驕戒躁，瞭解它的原始碼，對它進行優化改造。在改造過程中不可避免的要呼叫sentinel的api介面進行一些規則的同步等操作。

監聽埠

服務整合sentinel的方式

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
 

啟動服務後，一旦訪問了介面，sentinel會通過websocket或netty的方式監聽8719（預設）埠，提供一些介面方便我們以http的方式呼叫取獲取、修改sentinel的限流規則，叢集配置等。

監聽的埠預設是8719，但是如果埠被佔用，就會換自動換埠，具體換埠邏輯是8719+重試次數/3，這個沒什麼意思，不比深究。

程式碼實現

具體啟動埠監聽的邏輯在com.alibaba.csp.sentinel.transport.init.CommandCenterInitFunc中，該類在sentinel-transport-common模組中，具體依賴如下

@InitOrder(-1)
public class CommandCenterInitFunc implements InitFunc {

    @Override
    public void init() throws Exception {
        //commandCenter預設是SimpleHttpCommandCenter
        CommandCenter commandCenter = CommandCenterProvider.getCommandCenter();

        if (commandCenter == null) {
            RecordLog.warn("[CommandCenterInitFunc] Cannot resolve CommandCenter");
            return;
        }

        commandCenter.beforeStart();
        //啟動監聽
        commandCenter.start();
        RecordLog.info("[CommandCenterInit] Starting command center: "
                + commandCenter.getClass().getCanonicalName());
    }
}
 

上述程式碼中commandCenter預設是SimpleHttpCommandCenter，如果引入sentinel-transport-netty-http，則它就會變成NettyHttpCommandCenter，具體原因是sentinel為spi類定義了一個order屬性，NettyHttpCommandCenter的order屬性更高

具體模組之間的關係如下如

埠可通過引數：csp.sentinel.api.port指定。

具體啟動邏輯可以自己跟一下，比較簡單。

api介面

具體有哪些介面呢?

com.alibaba.csp.sentinel.command.CommandHandler介面的所有實現類

我們可以通過呼叫localhost:port/api獲取到所有的api

這些handler基本上分佈在三個模組中

• sentinel-transport-common：提供一些規則相關的，基本的介面

• sentinel-cluster-client-default：叢集客戶端相關介面

• sentinel-cluster-server-default：叢集服務端相關介面

sentinel-transport-common

sentinel-cluster-client-default

sentinel-cluster-server-default

public class SimpleHttpCommandCenter implements CommandCenter {

       public void run() {
                boolean success = false;
                ServerSocket serverSocket = SimpleHttpCommandCenter.getServerSocketFromBasePort(this.port);
                if (serverSocket != null) {
                    CommandCenterLog.info("[CommandCenter] Begin listening at port " + serverSocket.getLocalPort(), new Object[0]);
                    SimpleHttpCommandCenter.this.socketReference = serverSocket;
                    SimpleHttpCommandCenter.this.executor.submit(SimpleHttpCommandCenter.this.new ServerThread(serverSocket));
                    success = true;
                    this.port = serverSocket.getLocalPort();
                } else {
                    CommandCenterLog.info("[CommandCenter] chooses port fail, http command center will not work", new Object[0]);
                }

                if (!success) {
                    this.port = -1;
                }

                TransportConfig.setRuntimePort(this.port);
                SimpleHttpCommandCenter.this.executor.shutdown();
            }
}

專案整合sentinel啟動後，api服務並不會啟動，而是等到專案被訪問的時候才會被啟動，具體的方式是啟動一個netty服務監聽8719埠（預設）

SphU.entry("testRule1", EntryType.IN, 1, id);