微服务如何实现各个模块之间相互调用
Posted 穆雄雄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了微服务如何实现各个模块之间相互调用相关的知识,希望对你有一定的参考价值。
大家好,我是雄雄,现在是:2022年8月23日21:08:53
前言
在做微服务项目时,我们可能都会遇到这样的情况,那就是A服务需要调用B服务中的某个接口,那有这样的需求时,我们应该怎么处理呢?
实现
使用**@FeignClient** 注解。
其实吧,网上也有好多关于Feign的相关知识和教程,一搜一大堆,有的看眼就会了,有的看眼就废了。。。
我来整理下我的方法吧,尽量的简单明了,不为别的,就为了报答你能在茫茫人海中找到我,让你别浪费时间,抓紧CV到工程中就能跑,到时候想起来了给我点个赞,想不起来了就算了,你好我好,大家都好!
A服务调用B服务的接口:
第一步:
检查下B服务中的接口,能不能直接用(主要看看返回值和参数,如果是普通的Stirng
、int
之类的都能直接用)
如果是实体或者对象集合,我们就使用JSON
传递数据。
如下我写了个接口:
/**
* 根据id查询网站的配置
*
* @return
*/
@ApiOperation(value = "网站设置表-通过id查询", notes = "网站设置表-通过id查询")
@GetMapping(value = "/queryConfigById")
public String queryConfigById(String id)
JSONObject jsonObject = new JSONObject();
WebConfig webConfig = webConfigService.getById(id);
if (webConfig == null)
jsonObject.put("code", 200);
jsonObject.put("data", null);
return jsonObject.toJSONString();
jsonObject.put("code", 200);
jsonObject.put("data", webConfig);
return jsonObject.toJSONString();
我这个就是返回了JSON
数据。
第二步
在A服务模块中,新建个接口,添加@FeignClient
注解,注解的值为B服务的模块名,也就是yml
文件中的name
。
spring:
application:
name: xxx-web
main:
allow-bean-definition-overriding: true
接口代码如下:
@FeignClient("xxx-web")
public interface WebClient
/**
* 根据编号查询网站的配置信息
* @param id
* @return
*/
@GetMapping(value = "/config/webConfig/queryConfigById")
String queryConfigById(@RequestParam("id") String id);
第三步
在controller
控制器中,自动注入B服务的模块。
@Autowired
private WebClient webClient;
这个名字:WebClient
就是我们创建的那个接口的名字。
至此,你就可以在控制器中随便用了,通过webClient
点里面的方法即可,我的业务代码如下:
String huifu = "欢迎关注~";
try
//查询网站的配置信息,主要获取的是关注用户回复的内容
String webConfig = webClient.queryConfigById("1");
if(Strings.isNotBlank(webConfig))
JSONObject object = JSONObject.parseObject(webConfig);
Integer code = object.getInteger("code");
if(code==200)
String data = object.getString("data");
JSONObject dataObject = JSONObject.parseObject(data);
if(Strings.isNotBlank(dataObject.getString("xcxReply")))
//拿到数据库中的关注之后回复的信息
huifu = dataObject.getString("xcxReply");
return new TextBuilder().build(huifu, wxMessage, weixinService);
catch (Exception e)
this.logger.error(e.getMessage(), e);
完事儿了!!!
以上是关于微服务如何实现各个模块之间相互调用的主要内容,如果未能解决你的问题,请参考以下文章