我计划创建一个微服务应用程序，其中包含用于处理数据的专用服务（主要是基于 Mongodb 的服务）。我想知道是否有一种方法可以让我的其他微服务能够与该服务通信以使用共享数据。 JHipster API Gateway 可以吗？ 如果不是我怎么能做到这一点。我不想在每个微服务中保留相同数据的多个副本。
【问题讨论】：
您还可以将 Feign 客户端与 JHipster 一起使用。
用@EnableFeignClients注释你的SpringBootApplication
...
import org.springframework.cloud.openfeign.EnableFeignClients;
...
@SpringBootApplication
@EnableConfigurationProperties({LiquibaseProperties.class, ApplicationProperties.class})
@EnableDiscoveryClient
@EnableFeignClients
public class MyApp {
...
}
在你的微服务中创建一个 Feign 客户端
...
import org.springframework.cloud.openfeign.FeignClient;
...
@FeignClient("another-service")
public interface AnotherClient {
@RequestMapping(method = RequestMethod.GET, value = "/api/another")
List<AnotherDTO> getAll();
}
使用@Autowired 注入Feign 客户端并调用它。它应该可以使用了。
@RestController
@RequestMapping("/api")
public class MyResource {
...
@Autowired
private AnotherClient anotherClient;
...
@GetMapping("/another")
@Timed
public List<AnotherDTO> getAll() {
log.debug("REST request to get all");
return anotherClient.getAll();
}
}
对我们来说，它在没有实现 ClientHttpRequestInterceptor 和设置 JWT 令牌的情况下工作。
【讨论】：
您可以将您的微服务注册到同一个注册中心，然后它们就可以相互调用。
更新：这是我的工作方式。 在使用数据的微服务一中，在 API 调用的 Authorization-header 中将 RestTemplate 与当前用户的 jwt-token 一起使用：
@Component
public class AuthenticateClientHttpRequestInterceptor implements ClientHttpRequestInterceptor {
@Override
public ClientHttpResponse intercept(HttpRequest httpRequest, byte[] bytes, ClientHttpRequestExecution clientHttpRequestExecution) throws IOException {
String token = SecurityUtils.getCurrentUserJWT();
httpRequest.getHeaders().add("Authorization","Bearer "+token);
return clientHttpRequestExecution.execute( httpRequest, bytes );
}
}
我的自定义 restTemplate 使用 ClientHttpRequestInterceptor 在标头中添加令牌。
@Configuration
public class CustomBean {
@Autowired
AuthenticateClientHttpRequestInterceptor interceptor;
@Bean
@LoadBalanced
public RestTemplate restTemplate() {
RestTemplate restTemplate = new RestTemplate();
restTemplate.setInterceptors(Collections.singletonList(interceptor));
return restTemplate;
}
}
在您调用数据的资源控制器中：
@RestController
@RequestMapping("/api")
public class DataResource {
@Autowired
RestTemplate restTemplate;
@PostMapping("/hello")
@Timed
public ResponseEntity<Hello> createHello(@RequestBody Hello Hello) throws URISyntaxException {
//The name your data micro service registrated in the Jhipster Registry
String dataServiceName = "data_micro_service";
URI uri = UriComponentsBuilder.fromUriString("//" + dataServiceName + "/api/datas")
.build()
.toUri();
//call the data microservice apis
List<Data> result = restTemplate.getForObject(uri, Data[].class);
return ResponseEntity.created(new URI("/api/hellos/" + result.getId()))
.headers(HeaderUtil.createEntityCreationAlert(ENTITY_NAME, result.getId().toString()))
.body(result);
}
}
【讨论】：
通常，微服务会相互通信。这就是重点。有了 Eureka 发现，您只需按名称调用微服务，而不是我们通常在没有微服务的情况下使用的 FQDN。
例如你的book-service 会像这样调用author-service
http://author-service/authors
请不要忘记 JHipster 是一个基于 Spring Cloud 的固执己见的框架，因此您可以通过搜索 Spring 文档找到其中的大部分内容。
【讨论】：
您可以使用以下解决方案： 微服务 A（即 UAA-SERVICE）和微服务 B 微服务 B 想连接微服务 A 并通过 Feign 客户端调用服务。
1)微服务 B 的代码 客户端代理：- @AuthorizedFeignClient(name = "UAA-SERVICE")
@AuthorizedFeignClient(name = "UAA-SERVICE")
公共接口 UaaServiceClient {
@RequestMapping(method = RequestMethod.GET, path = "api/users")
public List<UserDTO> getUserList();
@RequestMapping(method = RequestMethod.PUT, path = "api/user-info")
public String updateUserInfo(@RequestBody UserDTO userDTO);
}
UAA-SERVICE : 通过注册表运行应用程序实例找到此名称。
2) 在微服务 B (application.yml)中
增加feign客户端连接超时：
假装：
客户：
配置：
默认值：
连接超时：10000
读取超时：50000
增加 hystrix 线程超时时间：-
hystrix: 命令： 默认： 执行： 隔离： 线： 超时毫秒：60000 shareSecurityContext: 真
3) 在@SpringBootApplication 主类中添加@EnableFeignClients。 这个解决方案对我来说很好。
【讨论】：