pubsub 에뮬레이터에서 주제 만들기

Question

새 주제를 만들 때 pubsub 에뮬레이터를 사용하여 기본 구현을 테스트하고 문제가 발생했습니다. 8085을하고 난 API를 통해 항목을 만들 경우

PUT http://localhost:8085/v1/projects/testproject/topics/test 

모든 것이 잘 작동하고 항목이 생성됩니다 :

내 에뮬레이터는 localhost를 수신합니다. 그러나 내가 의도 한대로 작동 다음 코드 아무것도 실행하지 않고 화제가 작성되지됩니다 경우 :

TopicName topicName = TopicName.create("testproject", "test"); 
    ChannelProvider channelProvider = 
      TopicAdminSettings.defaultChannelProviderBuilder() 
       .setEndpoint("localhost:8085") 
       .setCredentialsProvider(
         FixedCredentialsProvider.create(NoCredentials.getInstance())) 
       .build(); 
    TopicAdminClient topicClient = TopicAdminClient.create(
      TopicAdminSettings.defaultBuilder().setChannelProvider(channelProvider).build()); 
     topicClient.createTopic(topicName); 

내가 내 ChannelProvider에 뭔가 실종이에게 에뮬레이터 로그

[pubsub] Apr 27, 2017 1:10:47 PM io.gapi.emulators.grpc.GrpcServer$3 operationComplete 
[pubsub] INFORMATION: Adding handler(s) to newly registered Channel. 
[pubsub] Apr 27, 2017 1:10:47 PM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead 
[pubsub] INFORMATION: Detected non-HTTP/2 connection. 
[pubsub] Apr 27, 2017 1:10:47 PM io.gapi.emulators.netty.NotFoundHandler handleRequest 
[pubsub] INFORMATION: Unknown request URI: /bad-request 
[pubsub] Apr 27, 2017 1:10:47 PM io.gapi.emulators.grpc.GrpcServer$3 operationComplete 
[pubsub] INFORMATION: Adding handler(s) to newly registered Channel. 
[pubsub] Apr 27, 2017 1:10:47 PM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead 
[pubsub] INFORMATION: Detected non-HTTP/2 connection. 
[pubsub] Apr 27, 2017 1:10:47 PM io.gapi.emulators.netty.NotFoundHandler handleRequest 
[pubsub] INFORMATION: Unknown request URI: /bad-request 

...  

[pubsub] Apr 27, 2017 1:10:49 PM io.gapi.emulators.grpc.GrpcServer$3 operationComplete 
[pubsub] INFORMATION: Adding handler(s) to newly registered Channel. 
[pubsub] Apr 27, 2017 1:10:49 PM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead 
[pubsub] INFORMATION: Detected non-HTTP/2 connection. 

을 실행하는 동안? 또는 TopicAdminClient를 올바르게 구성하지 않았습니까? 나는 무엇을 잘못 사용했는지 모르겠다. this as reference.

어쩌면 누군가 나를 도와 줄 수 있습니다.

Answer 1

에뮬레이터와 통신하는 데 사용되는 채널은 negotiationType 속성을 NegotiationType.PLAINTEXT으로 설정해야합니다. 즉, 사용자 정의 ChannelProvider을 작성해야합니다. 다음과 같은 것이 작동해야합니다.

public class PlainTextChannelProvider implements ChannelProvider { 
    @Override 
    public boolean shouldAutoClose() { 
    return false; 
    } 

    @Override 
    public boolean needsExecutor() { 
    return false; 
    } 

    @Override 
    public ManagedChannel getChannel() throws IOException { 
    return NettyChannelBuilder.forAddress("localhost", 8085) 
     .negotiationType(NegotiationType.PLAINTEXT) 
     .build(); 
    } 

    @Override 
    public ManagedChannel getChannel(Executor executor) throws IOException { 
    return getChannel(); 
    } 
}