Spring Boot Thrift - PullRequest
Новая
       7

Spring Boot Thrift

0 голосов
/ 26 октября 2018

Я следую этому уроку https://dzone.com/articles/building-microservices-spring, чтобы использовать Thrift в Spring.Когда я запускаю учебник, он работает нормально, однако, когда я делаю пример, он не выполняет правильное сопоставление. 

@Configuration
@EnableAutoConfiguration
@ComponentScan
public class CacheApplication {

public static void main(String[] args) {
    SpringApplication.run(CacheApplication.class, args);
}

@Bean
public TProtocolFactory tProtocolFactory() {
    return new TBinaryProtocol.Factory();
}

@Bean
public Servlet cache(TProtocolFactory protocolFactory, CacheServiceHandler handler) {
    return new TServlet(new TCacheService.Processor<>(handler), protocolFactory);
}


}

Это мой основной файл, и когда я запускаю сервер, он говорит: «Кэш сервлета сопоставленв [/] "когда это будет" кеш сервлета сопоставлен с [/ cache /] "

учебник находится в режиме ожидания, но я использую maven 

 <?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.example</groupId>
<artifactId>demo_thrift</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>



<name>Demo  Thrift</name>
<description>Demo project for Spring Boot</description>

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.6.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
</properties>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>

    <dependency>
        <groupId>org.apache.thrift</groupId>
        <artifactId>libthrift</artifactId>
        <version>0.11.0</version>
    </dependency>

</dependencies>

<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

При запуске сервера я не получаю ошибки, однако, когда я запускаю клиент с этим кодом 

@EnableAutoConfiguration
@ComponentScan(basePackageClasses = {CacheApplication.class})

public class ClientTest {
    protected int port;

    @Autowired
    protected TProtocolFactory protocolFactory;

    public static void main(String[] args)  throws Exception {
        new SpringApplicationBuilder().sources(ClientTest.class).profiles("client").web(false).run(args);

    }
    @Bean
    public String test() throws Exception{
        TTransport transport= new THttpClient("http://localhost:8080/cache/");
        TProtocol protocol = protocolFactory.getProtocol(transport);
        TCacheService.Client client;
        client = new TCacheService.Client(protocol);
        return client.query(10);
    }

}

И это ошибка, которую я получил: 

Caused by: org.apache.thrift.transport.TTransportException: HTTP Response code: 406
at org.apache.thrift.transport.THttpClient.flush(THttpClient.java:352) ~[libthrift-0.11.0.jar:0.11.0]
at org.apache.thrift.TServiceClient.sendBase(TServiceClient.java:73) ~[libthrift-0.11.0.jar:0.11.0]
at org.apache.thrift.TServiceClient.sendBase(TServiceClient.java:62) ~[libthrift-0.11.0.jar:0.11.0]
at com.example.demo.Generated.TCacheService$Client.send_query(TCacheService.java:56) ~[classes/:na]
at com.example.demo.Generated.TCacheService$Client.query(TCacheService.java:48) ~[classes/:na]
at com.example.demo.Client.ClientTest.test(ClientTest.java:36) [classes/:na]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_181]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_181]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]
at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]

1 Ответ

0 голосов
/ 03 апреля 2019

Удалось решить это, изменив bean-компонент сервлета следующим образом: 

@Bean
public ServletRegistrationBean cache(TProtocolFactory protocolFactory, CacheServiceHandler handler) {
    TServlet servlet = new TServlet(new TCacheService.Processor<SampleServiceControllerHandler>(handler), protocolFactory);
    return new ServletRegistrationBean(servlet, "/cache");
}
...