public static void main()

in aliyun-sdk-opensearch/src/server/java/com/aliyun/opensearch/sdk/SdkThriftServer.java [28:74]


	public static void main(String[] args) throws InvalidParameterException {

		TMultiplexedProcessor multiplexedProcessor = new TMultiplexedProcessor();
		if (args.length < 4) {
			throw new RuntimeException("accessKey secret host port");
		}
		//String accessKey = "your_access_key";
		//String secret = "your_secret";
		//String host = "http://106.11.30.131";

		String accessKey = args[0];
		String secret = args[1];
		String host = args[2];
		int port = Integer.valueOf(args[3]);

		OpenSearch opensearch = new OpenSearch(accessKey, secret, host);
		OpenSearchClient openSearchClient = new OpenSearchClient(opensearch);

		OpenSearchService.Processor opensearchServiceprocessor = new OpenSearchService.Processor(openSearchClient);

		SearcherClient searcherClient = new SearcherClient(openSearchClient);
		OpenSearchSearcherService.Processor opensearchSearcherServiceProcessor = new OpenSearchSearcherService.Processor(searcherClient);

		DocumentClient documentClient = new DocumentClient(openSearchClient);
		DocumentService.Processor documentServiceprocessor = new DocumentService.Processor(documentClient);

		AppClient appClient = new AppClient(openSearchClient);
		AppService.Processor appServiceProcessor = new AppService.Processor(appClient);
		multiplexedProcessor.registerProcessor("opensearchServiceProcessor", opensearchServiceprocessor);
		multiplexedProcessor.registerProcessor("opensearchSearcherServiceProcessor", opensearchSearcherServiceProcessor);
		multiplexedProcessor.registerProcessor("documentServiceProcessor", documentServiceprocessor);
		multiplexedProcessor.registerProcessor("appServiceProcessor", appServiceProcessor);

		try {
			TServerTransport serverTransport = new TServerSocket(new InetSocketAddress("0.0.0.0", port));
			Args trArgs = new Args(serverTransport);
			trArgs.processor(multiplexedProcessor);
			trArgs.protocolFactory(new TBinaryProtocol.Factory(true, true));
			trArgs.transportFactory(new TTransportFactory());
			TServer server = new TThreadPoolServer(trArgs);
			System.out.println("starting server...");
			server.serve();
			server.stop();
		} catch (Exception e) {
			throw new RuntimeException("index thrift server start failed!!" + "/n" + e.getMessage());
		}
	}