SpringBoot微服务间调用解决方案
SpringBoot微服务间调用解决方案方式一:中间服务方式二:互相调用方式三:两者组合使用问题方式一:中间服务优势:将服务间的耦合度降到最低 ;降低服务复杂度,各服务不需要变动;缺点:增加了服务数量,需要维护 ;实现:在网关与微服务间构建一个中间服务(汇聚服务),需要多个服务共同完成业务时,由该服务调用多个微服务方式二:互相调用优势维持原有服务数量;缺点...
·
在SpringBoot开发中,常有服务间互相调用的需求,使用最简单的方式当然是直接远程调用即可,但是为了避免这种混乱的调用机制,也为了方便维护,需要折中考虑较为方便的形式调用
方式一:中间服务
优势:
- 将服务间的耦合度降到最低 ;
- 降低服务复杂度,各服务不需要变动;
缺点:
- 增加了服务数量,需要维护 ;
实现:
在网关与微服务间构建一个中间服务(汇聚服务),需要多个服务共同完成业务时,由该服务调用多个微服务
@Autowired
private LoadBalancerClient loadBalancerClient;
@Value("${fire_base_service.serviceId}")
private String firebaseservice;// 基础服务
JSONObject result = new JSONObject();
// 获取片区的单位、人员、建筑、设备信息
Map<String, Object> buildfloorparams = new HashMap<String, Object>();
JSONObject baseresult = RestTempleUtil.getForObject(loadBalancerClient, firebaseservice, "/basezone/base/" + code, buildfloorparams);
if (HttpStatus.OK.value() == baseresult.getInt("status")) {
JSONObject base = baseresult.getJSONObject("data");
result.putAll(base);
}
方式二:互相调用
优势
- 维持原有服务数量;
缺点
- 增加了业务的复杂性 ;
- 服务的主次难以决定
实现
需要多个服务共同完成业务时,选其中一个服务作为调用方,调用其他服务接口
步骤与方式一类似
方式三:两者组合使用
优势
- 既保留方式一的灵活性,又拥有方式二的自主性
实现
由于某些场景下,汇聚服务操作业务过于复杂,可以选择性的使用相互调用的方式
问题及解决
- 远程调用put时需要封装Header,但是RestTemplate的put方法没有提供这个功能
/**
* put请求
*
* @param loadBalancerClient
* @param serviceId
* @param url
* @param params
* @return
*/
public static void put(LoadBalancerClient loadBalancerClient, String serviceId, String url, Map<String, Object> params) {
RestTemplate restTemplate = new RestTemplate();
restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));// 中文参数处理
ServiceInstance firebusinessseviceInstance = loadBalancerClient.choose(serviceId); // PRODUCT为注册到中心的服务名
String firebusinessseviceUrl = String.format("http://%s:%s", firebusinessseviceInstance.getHost(), firebusinessseviceInstance.getPort()) + url;
HttpHeaders headers = new HttpHeaders();//header参数
headers.setContentType(MediaType.APPLICATION_JSON);
JSONObject jsonObj = JSONObject.fromObject(params);
HttpEntity<String> formEntity = new HttpEntity<String>(jsonObj.toString(), headers);
ResponseEntity<String> response = restTemplate.exchange(firebusinessseviceUrl,HttpMethod.PUT,formEntity,String.class);
}
直接使用exchange方法操作。
博文说明:文章通过亲身使用及参考其他博客,若有雷同,敬请见谅!
更多推荐
已为社区贡献1条内容
所有评论(0)