SpringCloud Feign多参数传递及需要注意的问题

SpringCloud Feign多参数传递及需要注意的问题

目录Feign多参数传递及注意的问题在服务提供者cloud-shop-userservice中新增几个方法修改feign的UserService,新增对应的方法在feign的controller中调用方法重启修改过的服务,查看服务注册是否正常使用工具调用这几个方法进行测试Feign如何接收多个参数1.API2.Feign3.controller

Feign多参数传递及注意的问题

这边沿用前面的Eureka，Feign，Service

在服务提供者cloud-shop-userservice中新增几个方法

/**

* 保存用户

* 2018年1月18日

*/

@PostMapping("/user")

public String aveUser(@RequestBody User user) {

logger.info("保存用户 :" +user.toString());

return "Success";

}

/**

* 根据用户名和密码查询用户

* 2018年1月18日

*/

@GetMapping("/findUser")

public User findUserByNameAndPassword(String name ,String password) {

logger.info("name :"+name +"---password :" +password);

User user= new User();

user.setName(name);

user.setPassword(password);

return user;

}

修改feign的UserService,新增对应的方法

package cn.sh.daniel.service;

import org.springframework.cloud-flix.feign.FeignClient;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestBody;

import cn.sh.daniel.entity.User;

@FeignClient(value = "cloud-shop-userservice")

public interface UserService {

@GetMapping("/user/{id}")

public User findUserById(@PathVariable("id")Long id);

@PostMapping("/user/user")

public String aveUser(@RequestBody User user) ;

@GetMapping("/user/findUser")

public User findUserByNameAndPassword(String name ,String password);

}

在feign的controller中调用方法

/**

* 保存用户

* 2018年1月18日

*/

@PostMapping("/user")

public String aveUser(@RequestBody User user) {

return userService.aveUser(user);

}

/**

* 根据用户名和密码查询用户

* 2018年1月18日

*/

@GetMapping("/findUser")

public User findUserByNameAndPassword(String name ,String password) {

return userService.findUserByNameAndPassword(name, password);

}

重启修改过的服务,查看服务注册是否正常

在启动过程中可以发现Feign服务启动报错：

为什么会报错呢？

这个方法有两个参数，而Feign去映射的时候它不会去自动给你区分那个参数是哪个，会直接给你报错

解决方法：添加注解，自己去指定要映射的属性

重新启动Feign服务:

启动成功！！！！

使用工具调用这几个方法进行测试

成功调用两个方法！！！！

Feign如何接收多个参数

feigin多个参数POST情况下

method(String str1,String str2,String str3);

method2(String str1,@RequestParam Map map,String str3);

1.API

package com.hwasee.hsc.api.redis;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestParam;

import java.util.Map;

/**

* @author limaojing

* @date 2020-07-28

*/

public interface RedisMapAPI {

//===============================Map===============================

@PostMapping("/redis/map/get")

String getMap(@RequestParam(value = "key") String key, @RequestParam(value = "item") String item);

@PostMapping("/redis/map/getAll")

Map

@PostMapping("/redis/map/set")

Boolean setMap(@RequestParam(value = "key") String key, @RequestParam Map map);

@PostMapping("/redis/map/setMapAndTime")

Boolean setMapAndTime(@RequestParam(value = "key") String key, @RequestParam Map map, @RequestParam(value = "time") Long time);

@PostMapping("/redis/map/setMapItem")

Boolean setMapItem(@RequestParam(value = "key") String key, @RequestParam(value = "item") String item, @RequestParam(value = "value") String value);

@PostMapping("/redis/map/setMapItemAndTime")

Boolean setMapItemAndTime(@RequestParam(value = "key") String key, @RequestParam(value = "item") String item, @RequestParam(value = "value") String value, @RequestParam(value = "time") Long time);

@PostMapping("/redis/map/del")

void delMap(@RequestParam(value = "key") String key, @RequestParam(value = "items") Object[] items);

@PostMapping("/redis/map/hashKey")

Boolean mhashKey(@RequestParam(value = "key") String key, @RequestParam(value = "item") String item);

@PostMapping("/redis/map/incr")

Double incrMap(@RequestParam(value = "key") String key, @RequestParam(value = "item") String item, @RequestParam(value = "delta") Double delta);

@PostMapping("/redis/map/decr")

Double decrMap(@RequestParam(value = "key") String key, @RequestParam(value = "item") String item, @RequestParam(value = "delta") Double delta);

}

2.Feign

package com.hwasee.hsc.feign.redis;

import com.hwasee.hsc.api.redis.RedisMapAPI;

import com.hwasee.hsc.constants.ServiceConstants;

import org.springframework.cloud.openfeign.FeignClient;

/**

* @author limaopeng

* @date 2020-11-25

*/

@FeignClient(name = ServiceConstants.Services.SERVICE_REDIS)

public interface RedisMapFeign extends RedisMapAPI {

}

3.controller

如果实现了API就不用添加，没有实现就要添加

package com.hwasee.hsc.redis.controller;

import com.hwasee.hsc.redis.util.RedisUtil;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.RestController;

import java.util.List;

import java.util.Map;

import java.util.Set;

/**

* @author limaojing

* @date 2020-07-28

*/

@RestController

@RequestMapping("/redis")

public class RedisController {

@Autowired

private RedisUtil redisUtil;

@Autowired

private RedisUtil.redisMap redisMap;

@Autowired

private RedisUtil.redisString redisString;

@Autowired

private RedisUtil.redisSet redisSet;

@Autowired

private RedisUtil.redisList redisList;

//===============================Common===============================

@PostMapping("/changeDatabase")

public void changeDatabase(Integer index){

redisUtil.changeDatabase(index);

}

/**

* 指定缓存失效时间

*

* @param key 键

* @param time 时间（秒）

* @return

*/

@PostMapping("/expire")

public Boolean expire(String key, Long time) {

return redisUtil.expire(key, time);

}

/**

* 根据key获取过期时间

*

* @param key 键，不能为空

* @return 时间秒，返回0代表永久有效

*/

@PostMapping("/getExpire")

public Long getExpire(String key) {

return redisUtil.getExpire(key);

}

/**

* 判断key是否存在

*

* @param key 键

* @return 存在返回true，不存在返回false

*/

@PostMapping("/hasKey")

public Boolean hasKey(String key) {

return redisUtil.hasKey(key);

}

/**

* 删除缓存

*

* @param keys 可以传一个值，或多个值

*/

@SuppressWarnings("unchecked")

@PostMapping("/del")

public void del(@RequestParam String[] keys) {

redisUtil.del(keys);

}

//===============================String===============================

/**

* 获取缓存

*

* @param key 键

* @return 值

*/

@PostMapping("/string/get")

public String getString(String key) {

return redisString.get(key).toString();

}

/**

* 缓存存入

*

* @param key 键

* @param value 值

* @return 操作成功返回true，失败返回false

*/

@PostMapping("/string/set")

public Boolean setString(String key, String value) {

return redisString.set(key, value);

}

/**

* 普通缓存放入并设置时间

*

* @param key 键

* @param value 值

* @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期

* @return 操作成功返回true，失败返回false

*/

@PostMapping("/string/setValueAndTime")

public Boolean setValueAndTime(String key, String value, Long time) {

return redisString.set(key, value, time);

}

/**

* 递增

*

* @param key 键

* @param delta 要增加的值

* @return

*/

@PostMapping("/string/incr")

public Long incrString(String key, Long delta) {

return redisString.incr(key, delta);

}

/**

* 递减

*

* @param key 键

* @param delta 要减小的值

* @return

*/

@PostMapping("/string/decr")

public Long decrString(String key, Long delta) {

return redisString.decr(key, delta);

}

//===============================Map===============================

/**

* 取得对应键值

*

* @param key 键

* @param item 项

* @return 值

*/

@PostMapping("/map/get")

public String getMap(String key, String item) {

return redisMap.get(key, item);

}

/**

* 获取hashKey对应的所有键值

*

* @param key 键

* @return map形式返回键值对

*/

@PostMapping("/map/getAll")

public Map

return redisMap.getAll(key);

}

/**

* 顾名思义，当然是set值啦

*

* @param key 键

* @param map 对应的多个键值

* @return 操作成功返回true，失败返回false

*/

@PostMapping("/map/set")

public Boolean setMap(String key, @RequestParam Map map) {

return redisMap.set(key, map);

}

/**

* 加强版set，可设置时间

*

* @param key 键

* @param map 对应的多个键值

* @param time 缓存失效时间

* @return 操作成功返回true，失败返回false

*/

@PostMapping("/map/setMapAndTime")

public Boolean setMapAndTime(@RequestParam String key,@RequestParam Map map,@RequestParam Long time) {

return redisMap.set(key, map, time);

}

/**

* 向一张hash表中放入数据,如果不存在将创建

*

* @param key 键

* @param item 项

* @param value 值

* @return 操作成功返回true，失败返回false

*/

@PostMapping("/map/setMapItem")

public Boolean setMapItem(String key, String item, String value) {

return redisMap.set(key, item, value);

}

/**

* 加强版set，可设置时间

*

* @param key 键

* @param item 项

* @param value 值

* @param time 缓存失效时间

* @return 操作成功返回true，失败返回false

*/

@PostMapping("/map/setMapItemAndTime")

public Boolean setMapItemAndTime(String key, String item, String value, Long time) {

return redisMap.set(key, item,value, time);

}

/**

* 删除hash表中的值

*

* @param key 键，不能为空

* @param items 项，不能为空，可以为多个

*/

@PostMapping("/map/del")

public void delMap(String key,@RequestParam Object[] items) {

redisMap.del(key, items);

}

/**

* 判断hash表中是否存在某值

*

* @param key 键，不能为空

* @param item 项，不能为空

* @return 存在返回true，不存在返回false

*/

@PostMapping("/map/hashKey")

public Boolean mhashKey(String key, String item) {

return redisMap.hasKey(key, item);

}

/**

* hash递增

*

* @param key

* @param item

* @param delta 要增加多少

* @return

*/

@PostMapping("/map/incr")

public Double incrMap(String key, String item, Double delta) {

return redisMap.incr(key, item, delta);

}

/**

* hash递减

*

* @param key

* @param item

* @param delta 要减少多少

* @return

*/

@PostMapping("/map/decr")

public Double decrMap(String key, String item, Double delta) {

return redisMap.decr(key, item, delta);

}

//===============================Set===============================

/**

* 根据key获取Set中的所有值

*

* @param key

* @return

*/

@PostMapping("/set/get")

public Set

return redisSet.get(key);

}

/**

* 将数据放入set缓存

*

* @param key

* @param values

* @return 成功个数

*/

@PostMapping("/set/setValue")

public Long setValue(String key,@RequestParam Object[] values) {

return redisSet.set(key, values);

}

/**

* 根据value从一个set中查询,是否存在

*

* @param key

* @param value

* @return 存在返回true，不存在返回false

*/

@PostMapping("/set/hashKey")

public Boolean hashKey(String key, String value) {

return redisSet.hasKey(key, value);

}

/**

* 将数据放入set缓存,可设置时间

*

* @param key

* @param time

* @param values

* @return 成功个数

*/

@PostMapping("/set/setValueAndTime")

public Long setValueAndTime(String key, Long time,@RequestParam Object[] values) {

return redisSet.set(key, time, values);

}

/**

* 获取set缓存的长度

*

* @param key

* @return

*/

@PostMapping("/set/getSize")

public Long getSize(String key) {

return redisSet.getSize(key);

}

/**

* 移除set中值为value的项

*

* @param key

* @param values

* @return 移除的个数

*/

@PostMapping("/set/remove")

public Long remove(String key,@RequestParam Object[] values) {

return redisSet.remove(key, values);

}

//===============================List===============================

/**

* 获取list缓存的内容

*

* @param key

* @param start

* @param end 0到结束，-1代表所有值

* @return

*/

@PostMapping("/list/get")

public List

return redisList.get(key, start, end);

}

/**

* 获取list缓存的长度

*

* @param key

* @return

*/

@PostMapping("/list/getSize")

public Long getListSize(String key) {

return redisList.getSize(key);

}

/**

* 通过索引 获取list中的值

*

* @param key

* @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推

* @return

*/

@PostMapping("/list/getByIndex")

public Object getByIndex(@RequestParam("key") String key, @RequestParam("index") Long index) {

return redisList.getByIndex(key, index);

}

/**

* 将list放入缓存

*

* @param key

* @param value

* @return

*/

@PostMapping("/list/setValue")

public Boolean setValue(String key, Object value) {

return redisList.set(key, value);

}

/**

* 将list放入缓存,可设置时间

*

* @param key

* @param value

* @param time

* @return

*/

@PostMapping("/list/setValueAndTime")

public Boolean setValueAndTime(String key, Object value, Long time) {

return redisList.set(key, value, time);

}

/**

* 将list放入缓存

*

* @param key

* @param value

* @return

*/

@PostMapping("/list/setList")

public Boolean setList(String key, List

return redisList.set(key, value);

}

/**

* 将list放入缓存,可设置时间

*

* @param key

* @param value

* @param time

* @return

*/

@PostMapping("/list/setListAndTime")

public Boolean setListAndTime(String key, List

return redisList.set(key, value, time);

}

/**

* 根据索引修改list中的某条数据

*

* @param key

* @param index

* @param value

* @return

*/

@PostMapping("/list/updateByIndex")

public Boolean updateByIndex(String key, Long index, Object value) {

return redisList.updateIndex(key, index, value);

}

/**

* 删除list中值为value的项

*

* @param key 键

* @param count 要移除的个数

* @param value

* @return 移除的个数

*/

@PostMapping("/list/remove")

public Long remove(String key, Long count, Object value) {

return redisList.remove(key, count, value);

}

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。