public synchronized void publishService(Class clazz, Object serviceInstance,
            int listenPort, ExecutorService threadPool,
            RpcConfig config) throws Exception {
        ServiceRpcServer server = servers.get(listenPort);
        if (server == null) {
            server = new NettyRpcServer(config);
            server.start(listenPort);
            servers.put(listenPort, server);
        }
        try {
            server.publishService(clazz.getName(), serviceInstance, threadPool);
        } catch (Exception e) {
            logger.error("Publish service failed!", e);
            throw e;
        }
    }
start an tube netty server

@param clazz             the class object
@param serviceInstance   the service instance
@param listenPort        the listen port
@param threadPool        the thread pool
@param config            the configure
@throws Exception        the excepition while processing
inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/RpcServiceFactory.java