SpringCloud学习[7]-OpenFeign组件服务间调用之参数传递

三、OpenFeign服务间调用之参数传递1. 微服务架构服务间通讯方式http协议springcloud两种方式： 1. RestTemplate + Ribbon2. OpenFeign（推荐）2. 服务间通信参数传递参数传递类型零散类型对象类型数组或集合类型参数零散类型参数传递QueryString方式传递参数：?name=zhangsan&age=20被调用Share服务定义一个接

春盏77

3488人浏览 · 2021-07-01 14:23:34

春盏77 · 2021-07-01 14:23:34 发布

三、OpenFeign服务间调用之参数传递

1. 微服务架构服务间通讯方式

http协议
springcloud两种方式： 1. RestTemplate + Ribbon 2. OpenFeign（推荐）

2. 服务间通信参数传递

参数传递类型

零散类型
对象类型
数组或集合类型参数

零散类型参数传递

QueryString方式传递参数：?name=zhangsan&age=20

被调用Share服务定义一个接受零散参数类型的接口QueryString

@RestController
@RequestMapping("shareConApi")
public class ShareController {

    private static Logger log = LoggerFactory.getLogger(ShareController.class);

    /**
     * 定义一个接受零散参数类型的接口QueryString
     */
    @GetMapping("testQueryString")
    public String testQueryString(String name, Integer age) {
        log.info("testQueryString name={} age={}", name, age);
        return "testQueryString Ok";
    }

}

调用方Friend开发需要调用的服务客户端接口

/**
 * 调用Share服务的接口
 */
@FeignClient(value = "SHARE") // value=调用服务的ID
public interface ShareClients {
    /**
     * 声明调用Share服务中 零散参数传递的接口
     */
    @GetMapping("shareConApi/testQueryString")
    public String invokeQueryString(String name, Integer age);
}

调用方Friend调用客户端接口

@RestController
@RequestMapping("friendConApi")
public class FriendController {

    private static Logger log = LoggerFactory.getLogger(FriendController.class);
    @Resource
    private ShareClients shareClients;

    @GetMapping("testInvokeQueryString")
    public String testInvokeQueryString() {
        String result = shareClients.invokeQueryString("zhangsan", 20);
        log.info("testInvokeQueryString result={}", result);
        return "testInvokeQueryString Ok";
    }
}

启动测试

此时调用方Friend抛出异常，ShareClients…invokeQueryString() Method has too many Body parameters

原因：ShareClients是一个OpenFeign接口，是一个伪HttpClient，底层在请求testQueryString地址的时候，不知道参数该如何组织（意思就是零散类型参数传递方式有’?name=zhangsan&age=20’和’/zhangsan/20’两种方式）
。但是当你只有一个参数的时候，服务接口是可以调用的（很神奇…当只有一个参数的时候，默认是?name=zhangsan这种方式传递参数）
解决：在OpenFeign接口申明中必须给参数加入注解，明确告诉OpenFeign参数组织方式@RequestParam或@PathVariable

/**
     * 声明调用Share服务中 零散参数传递的接口
     * testQueryString?name=zhangsan&age=20
     */
    @GetMapping("shareConApi/testQueryString")
    public String invokeQueryString(@RequestParam("name") String name, @RequestParam("age") Integer age);

在这里插入图片描述
PathVariable方式传递参数：/zhangsan/20

被调用Share服务定义一个接受零散参数类型的接口 PathVariable

@RestController
@RequestMapping("shareConApi")
public class ShareController {

    private static Logger log = LoggerFactory.getLogger(ShareController.class);

    /**
     * 定义一个接受零散参数类型的接口PathVariable
     * @param name
     * @return
     */
    @GetMapping("testPathVariable/{name}/{age}")
    public String testPathVariable(@PathVariable("name") String name, @PathVariable("age") Integer age) {
        log.info("testPathVariable name={} age={}", name, age);
        return "testPathVariable Ok";
    }
}

调用方Friend开发需要调用的服务客户端接口

/**
 * 调用Share服务的接口
 */
@FeignClient(value = "SHARE") // value=调用服务的ID
public interface ShareClients {
    /**
     * 声明调用Share服务中 零散参数传递的接口
     * testQueryString/zhangsan/20
     */
    @GetMapping("shareConApi/testPathVariable/{name}/{age}")
    public String invokePathVariable(@PathVariable("name") String name, @PathVariable("age") Integer age);
}

调用方Friend调用客户端接口

@RestController
@RequestMapping("friendConApi")
public class FriendController {

    private static Logger log = LoggerFactory.getLogger(FriendController.class);
    @Resource
    private ShareClients shareClients;

    @GetMapping("testInvokePathVariable")
    public String testInvokePathVariable() {
        String result = shareClients.invokePathVariable("zhangsan", 20);
        log.info("testInvokePathVariable result={}", result);
        return "testInvokePathVariable Ok";
    }

}

启动测试

对象类型参数传递

对象方式传递参数：entity

被调用Share服务定义一个接受对象类型的接口RequestBody

@RestController
@RequestMapping("shareConApi")
public class ShareController {

    private static Logger log = LoggerFactory.getLogger(ShareController.class);
    
    /**
     * 定义一个接受对象类型的接口
     */
    @PostMapping("testRequestBody")
    public String testRequestBody(@RequestBody MemberEntity memberEntity) {
        log.info("testRequestBody memberEntity={}", memberEntity);
        return "testRequestBody Ok";
    }

}

调用方Friend开发需要调用的服务客户端接口

/**
 * 调用Share服务的接口
 */
@FeignClient(value = "SHARE") // value=调用服务的ID
public interface ShareClients {
    /**
     * 声明调用Share服务中 对象参数传递的接口
     * @param memberEntity
     * @return
     */
    @PostMapping("shareConApi/testRequestBody")
    public String invokeRequestBody(@RequestBody MemberEntity memberEntity);
}

调用方Friend调用客户端接口

@RestController
@RequestMapping("friendConApi")
public class FriendController {

    private static Logger log = LoggerFactory.getLogger(FriendController.class);
    @Resource
    private ShareClients shareClients;

    @GetMapping("testInvokeRequestBody")
    public String testInvokeRequestBody() {
        String result = shareClients.invokeRequestBody(new MemberEntity(1L, "zhangsan", 20, new Date()));
        log.info("testInvokeRequestBody result={}", result);
        return "testInvokeRequestBody Ok";
    }

}

启动测试

数组和集合类型参数传递

数组方式传递参数：String[]

被调用Share服务定义一个接受数组类型的接口 String[]

@RestController
@RequestMapping("shareConApi")
public class ShareController {
    private static Logger log = LoggerFactory.getLogger(ShareController.class);
    /**
     * 定义一个接受数组类型的接口
     */
    @GetMapping("testArray")
    public String testArray(String[] ids) {
        for (String id : ids) {
            log.info("testArray ids={}", id);
        }
        return "testArray Ok";
    }
}

调用方Friend开发需要调用的服务客户端接口

/**
 * 调用Share服务的接口
 */
@FeignClient(value = "SHARE") // value=调用服务的ID
public interface ShareClients {
    /**
     * 声明调用Share服务中 数组参数传递的接口
     * testArray?ids=1&ids=2&ids=3
     */
    @GetMapping("shareConApi/testArray")
    public String invokeArray(@RequestParam("ids") String[] ids);
}

调用方Friend调用客户端接口

@RestController
@RequestMapping("friendConApi")
public class FriendController {

    private static Logger log = LoggerFactory.getLogger(FriendController.class);
    @Resource
    private ShareClients shareClients;

    @GetMapping("testInvokeArray")
    public String testInvokeArray() {
        String result = shareClients.invokeArray(new String[]{"1", "2", "3"});
        log.info("testInvokeArray result={}", result);
        return "testInvokeArray Ok";
    }
}

启动测试

集合方式传递参数：List

被调用Share服务定义一个接受集合类型的接口 List
springmvc不能直接接受集合类型参数，必须将集合类型参数放入对象中，使用对象的方式传递参数才可接收

OO：oriented object 面向对象
VO：value object 值对象，用来传递数据对象
DTO：date transfer object 数据传输对象

public class ListVo {
    private List<String> ids;
    public List<String> getIds() {
        return ids;
    }
    public void setIds(List<String> ids) {
        this.ids = ids;
    }
}

@RestController
@RequestMapping("shareConApi")
public class ShareController {

    private static Logger log = LoggerFactory.getLogger(ShareController.class);
    
    /**
     * 定义一个接受集合List类型的接口
     */
    @GetMapping("testList")
    public String testList(ListVo listVo) {
        listVo.getIds().forEach(id -> log.info("testList id={}", id.toString()));
        return "testList Ok";
    }
}

调用方Friend开发需要调用的服务客户端接口

/**
 * 调用Share服务的接口
 */
@FeignClient(value = "SHARE") // value=调用服务的ID
public interface ShareClients {
    /**
     * 声明调用Share服务中 集合list参数传递的接口
     */
    @GetMapping("shareConApi/testList")
    public String invokeList(@RequestParam("ids") String[] ids);
}

调用方Friend调用客户端接口

@RestController
@RequestMapping("friendConApi")
public class FriendController {

    private static Logger log = LoggerFactory.getLogger(FriendController.class);
    @Resource
    private ShareClients shareClients;

    @GetMapping("testInvokeList")
    public String testInvokeList() {
        String result = shareClients.invokeList(new String[]{"1", "2", "3"});
        log.info("testInvokeList result={}", result);
        return "testInvokeList Ok";
    }
}

启动测试

向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

云原生

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

云原生

所有评论(0)

查看更多评论

春盏77

@qq_31832209

已为社区贡献1条内容