SpringCloud系列——Feign 服务调用
xsobi 2024-12-15 17:31 1 浏览
前言
前面我们已经实现了服务的注册与发现(请戳:SpringCloud系列——Eureka 服务注册与发现),并且在注册中心注册了一个服务myspringboot,本文记录多个服务之间使用Feign调用。
Feign是一个声明性web服务客户端。它使编写web服务客户机变得更容易,本质上就是一个http,内部进行了封装而已。
GitHub地址:https://github.com/OpenFeign/feign
官方文档:https://cloud.spring.io/spring-cloud-static/spring-cloud-openfeign/2.1.0.RC2/single/spring-cloud-openfeign.html
服务提供者
提供者除了要在注册中心注册之外,不需要引入其他东西,注意以下几点即可:
1、经测试,默认情况下,feign只能通过@RequestBody传对象参数
2、接参只能出现一个复杂对象,例:public Result<List<UserVo>> list(@RequestBody UserVo entityVo) { ... }
3、提供者如果又要向其他消费者提供服务,又要向浏览器提供服务,建议保持原先的Controller,新建一个专门给消费者的Controller
测试Controller接口
@RestController
@RequestMapping("/user/")
public class UserController {
@Autowired
private UserService userService;
@RequestMapping("list")
public Result<List<UserVo>> list(@RequestBody UserVo entityVo) {
return userService.list(entityVo);
}
@RequestMapping("get/{id}")
public Result<UserVo> get(@PathVariable("id") Integer id) {
return userService.get(id);
}
}
服务消费者
消费者maven引入jar
<!-- feign -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
配置文件
对日期的解析,消费者要跟提供者一致,不然会报json解析错误
#超时时间
feign.httpclient.connection-timeout=30000
#mvc接收参数时对日期进行格式化
spring.mvc.date-format=yyyy-MM-dd HH:mm:ss
#jackson对响应回去的日期参数进行格式化
spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
spring.jackson.time-zone=GMT+8
服务调用
1、springdatejpa 应用名称,是服务提供者在eureka注册的名字,Feign会从注册中心获取实例
2、如果不想启动eureka服务,直连本地开发:@FeignClient(name = "springdatejpa", path = "/user/",url = "http://localhost:10086"),或者无eureka,调用第三方服务,关闭eureka客户端 (eureka.client.enabled=false),url直接指定第三方服务地址,path指定路径,接口的方法指定接口
3、如果使用@RequestMapping,最好指定调用方式
4、消费者的返回值必须与提供者的返回值一致,参数对象也要一致
5、2019-05-21补充:如需进行容错处理(服务提供者发生异常),则需要配置fallback,如果需要获取到报错信息,则要配置fallbackFactory<T>,例:
fallback = MyspringbootFeignFallback.class,fallbackFactory = MyspringbootFeignFallbackFactory.class
/**
* 容错处理(服务提供者发生异常,将会进入这里)
*/
@Component
public class MyspringbootFeignFallback implements MyspringbootFeign {
@Override
public Result<UserVo> get(Integer id) {
return Result.of(null,false,"糟糕,系统出现了点小状况,请稍后再试");
}
@Override
public Result<List<UserVo>> list(UserVo entityVo) {
return Result.of(null,false,"糟糕,系统出现了点小状况,请稍后再试");
}
}
/**
* 只打印异常,容错处理仍交给MyspringbootFeignFallback
*/
@Component
public class MyspringbootFeignFallbackFactory implements FallbackFactory<MyspringbootFeign> {
private final MyspringbootFeignFallback myspringbootFeignFallback;
public MyspringbootFeignFallbackFactory(MyspringbootFeignFallback myspringbootFeignFallback) {
this.myspringbootFeignFallback = myspringbootFeignFallback;
}
@Override
public MyspringbootFeign create(Throwable cause) {
cause.printStackTrace();
return myspringbootFeignFallback;
}
}
Feign接口
更多@FeignClient注解参数配置,请参阅官方文档
@FeignClient(name = "springdatejpa", path = "/user/")
public interface MyspringbootFeign {
@RequestMapping(value = "get/{id}")
Result<UserVo> get(@PathVariable("id") Integer id);
@RequestMapping(value = "list", method = RequestMethod.GET)
Result<List<UserVo>> list(@RequestBody UserVo entityVo);
}
Controller层
/**
* feign调用
*/
@GetMapping("feign/get/{id}")
Result<UserVo> get(@PathVariable("id") Integer id){
return myspringbootFeign.get(id);
}
/**
* feign调用
*/
@GetMapping("feign/list")
Result<List<UserVo>> list(UserVo userVo){
return myspringbootFeign.list(userVo);
}
启动类
启动类加入注解:@EnableFeignClients
@EnableEurekaClient
@EnableFeignClients
@SpringBootApplication
public class MyspringbootApplication{
public static void main(String[] args) {
SpringApplication.run(MyspringbootApplication.class, args);
}
}
效果
成功注册两个服务
成功调用
报错记录
1、启动时报了个SQL错误
解决:配置文件连接数据时指定serverTimezone=GMT%2B8
2、当我将之前搭好的一个springboot-springdata-jpa整合项目在eureka注册时出现了一个报错
然后在网上查了下说是因为springboot版本问题(请戳:http://www.cnblogs.com/hbbbs/articles/8444013.html),之前这个项目用的是2.0.1.RELEASE,现在要在eureka注册,pom引入了就出现了上面的报错
<!-- eureka-client -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<!-- actuator -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Greenwich.RC1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
</repository>
</repositories>
解决:升级了springboot版本,2.1.0,项目正常启动
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.0.RELEASE</version>
<!--<version>2.0.1.RELEASE</version>-->
<relativePath/> <!-- lookup parent from repository -->
</parent>
补充
2019-10-17补充:Feign设置header请求头
方法1,mapping的headers属性,单一设置
@FeignClient(name = "svc", path = "/modules/user/", url = "${feign.url}")
public interface UserFeign extends BaseFeign<UserVo> {
@PostMapping(value = "xxx",headers = {"Cookie", "JSESSIONID=xxx"})
ResultModel<List<UserVo>> xxx(UserVo entity);
}
方法2,自定义FeignInterceptor,全局设置
/**
* feign请求设置header参数
* 这里比如浏览器调用A服务,A服务Feign调用B服务,为了传递一致的sessionId
*/
@Component
public class FeignInterceptor implements RequestInterceptor{
public void apply(RequestTemplate requestTemplate){
String sessionId = RequestContextHolder.currentRequestAttributes().getSessionId();
requestTemplate.header("Cookie", "JSESSIONID="+sessionId);
}
}
这样就可以设置cookie,传递token等自定义值
常见场景1
通常我们一个服务web层、svc层、dao层,但有时候也会将拆分成两个服务:
web服务提供静态资源、页面以及controller控制器控制跳转,数据通过java调用svc服务获取;
svc服务,进行操作数据库以及业务逻辑处理,同时提供接口给web服务调用;
特殊情况下我们想svc服务的接口也做登录校验,所有接口(除了登录请求接口)都有做登录校验判断,未登录的无权访问,这时候就需要做sessionId传递,将web服务的sessionId通过Feign调用时传递到svc服务
web服务
注:登录成功后用sessionId作为key,登录用户的id作为value,保存到redis缓存中
登录拦截器
/**
* web登录拦截器
*/
@Component
public class LoginFilter implements Filter {
@Autowired
private StringRedisTemplate template;
@Override
public void init(FilterConfig filterConfig) {
}
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
HttpServletRequest request = (HttpServletRequest) servletRequest;
HttpServletResponse response = (HttpServletResponse) servletResponse;
String requestURI = request.getRequestURI();
//除了访问首页、登录页面、登录请求,其他的都要查看Redis缓存
String sessionId = request.getSession().getId();
String redis = template.opsForValue().get(sessionId);
if (!
//无需登录即可访问的接口
(requestURI.contains("/index/") || requestURI.contains("/login/index") || requestURI.contains("/login/login")
//静态资源
|| requestURI.contains(".js") || requestURI.contains(".css") || requestURI.contains(".json")
|| requestURI.contains(".ico")|| requestURI.contains(".png")|| requestURI.contains(".jpg"))
&& StringUtils.isEmpty(redis)) {//重定向登录页面
response.sendRedirect("/login/index?url=" + requestURI);
} else {
//正常处理请求
filterChain.doFilter(servletRequest, servletResponse);
}
}
@Override
public void destroy() {
}
}
自定义FeignInterceptor
/**
* feign请求设置header参数
* 这里比如浏览器调用A服务,A服务Feign调用B服务,为了传递一致的sessionId
*/
@Component
public class FeignInterceptor implements RequestInterceptor{
public void apply(RequestTemplate requestTemplate){
String sessionId = RequestContextHolder.currentRequestAttributes().getSessionId();
requestTemplate.header("Cookie", "JSESSIONID="+sessionId);
}
}
svc服务
/**
* svc登录拦截器
*/
@Component
public class LoginFilter implements Filter {
@Autowired
private StringRedisTemplate template;
@Override
public void init(FilterConfig filterConfig) {
}
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
HttpServletRequest request = (HttpServletRequest) servletRequest;
HttpServletResponse response = (HttpServletResponse) servletResponse;
String requestURI = request.getRequestURI();
//service服务,查看Redis缓存,登录后才允许访问(除了checkByAccountNameAndPassword)
String sessionId = request.getRequestedSessionId();
if (!(requestURI.contains("/modules/user/checkByAccountNameAndPassword")) && StringUtils.isEmpty(template.opsForValue().get(sessionId))) {
//提示无权访问
response.setCharacterEncoding("UTF-8");
response.setContentType("application/json; charset=utf-8");
PrintWriter out = response.getWriter();
out.print("对不起,你无权访问!");
out.flush();
out.close();
} else {
//正常处理请求
filterChain.doFilter(servletRequest, servletResponse);
}
}
@Override
public void destroy() {
}
}
七天免登陆
会话期的sessionId,关闭浏览器后就失效了,所以就会退出浏览器后就需要重新登陆,有些情况我们并不想这样,我们想实现七天免登陆,这时候就需要自定义token,并且存放在cookie
登陆拦截器
/**
* web登录拦截器
*/
@Component
public class LoginFilter implements Filter {
/** 静态资源 为防止缓存,加上时间戳标志 */
private static final String STATIC_TAIL = "_time_=";
@Autowired
private StringRedisTemplate template;
@Override
public void init(FilterConfig filterConfig) {
}
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
HttpServletRequest request = (HttpServletRequest) servletRequest;
HttpServletResponse response = (HttpServletResponse) servletResponse;
String requestURI = request.getRequestURI();
//无需登录即可访问的接口,登陆页面、登陆请求
if(requestURI.contains("/login/index") || requestURI.contains("/login/login")){
//正常处理请求
filterChain.doFilter(servletRequest, servletResponse);
return;
}
//静态资源
if(requestURI.contains(".js") || requestURI.contains(".css") || requestURI.contains(".json")
|| requestURI.contains(".woff2") || requestURI.contains(".ttf")|| requestURI.contains(".ico")
|| requestURI.contains(".png")|| requestURI.contains(".jpg")|| requestURI.contains(".gif")){
//检查是否有防缓存时间戳
String queryStr = request.getQueryString();
if(StringUtils.isEmpty(queryStr) || !queryStr.trim().contains(STATIC_TAIL)){
response.sendRedirect(requestURI + "?" + STATIC_TAIL + System.currentTimeMillis());
return;
}
//正常处理请求
filterChain.doFilter(servletRequest, servletResponse);
return;
}
//剩下的要检查redis缓存
String token = null;
for (Cookie cookie : request.getCookies()) {
if("TOKEN".equals(cookie.getName())){
token = cookie.getValue();
}
}
String redis = template.opsForValue().get(token);
if(StringUtils.isEmpty(redis)){
//重定向登录页面
response.sendRedirect("/login/index?url=" + requestURI);
return;
}
//如果都不符合,正常处理请求
filterChain.doFilter(servletRequest, servletResponse);
}
@Override
public void destroy() {
}
}
登陆成功,设置cookie
public ResultModel<UserVo> login(UserVo userVo) {
此处省略查询操作...
if (true) {
HttpServletResponse response = ((ServletRequestAttributes) RequestContextHolder.currentRequestAttributes()).getResponse();
//设置Redis,有效时长:7天
String uuid = UUID.randomUUID().toString();
template.opsForValue().set(uuid, userVo.getAccountNo());
template.expire(uuid, 7 * 60 * 60, TimeUnit.SECONDS);
//设置cookie,有效时长:7天
Cookie cookie = new Cookie("TOKEN", uuid);
cookie.setPath("/");
cookie.setMaxAge(7 * 24 * 60 * 60);
response.addCookie(cookie);
return ResultModel.of(userVo, true, "登录成功");
}
return ResultModel.of(null, false, "用户名或密码错误");
}
推出登陆,销毁cookie
public ResultModel<UserVo> logout() {
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.currentRequestAttributes()).getRequest();
HttpServletResponse response = ((ServletRequestAttributes) RequestContextHolder.currentRequestAttributes()).getResponse();
String token = "";
for (Cookie cookie : request.getCookies()) {
if("TOKEN".equals(cookie.getName())){
token = cookie.getValue();
cookie.setValue(null);
cookie.setPath("/");
cookie.setMaxAge(0);// 立即销毁cookie
response.addCookie(cookie);
break;
}
}
template.delete(token);
return ResultModel.of(null, true, "操作成功!");
}
代码开源
代码已经开源、托管到我的GitHub、码云:
GitHub:https://github.com/huanzi-qch/springCloud
码云:https://gitee.com/huanzi-qch/springCloud
版权声明
作者:huanzi-qch
出处:https://www.cnblogs.com/huanzi-qch
若标题中有“转载”字样,则本文版权归原作者所有。若无转载字样,本文版权归作者所有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文链接,否则保留追究法律责任的权利.
相关推荐
- js向对象中添加元素(对象,数组) js对象里面添加元素
-
一、添加一个元素对象名["属性名"]=值(值:可以是一个值,可以是一个对象,也可以是一个数组)这样添加进去的元素,就是一个值或对象或数组...
- JS小技巧,如何去重对象数组?(一)
-
大家好,关于数组对象去重的业务场景,想必大家都遇到过类似的需求吧,这对这样的需求你是怎么做的呢。下面我就先和大家分享下如果是基于对象的1个属性是怎么去重实现的。方法一:使用.filter()和....
- 「C/C++」之数组、vector对象和array对象的比较
-
数组学习过C语言的,对数组应该都不会陌生,于是这里就不再对数组进行展开介绍。模板类vector模板类vector类似于string,也是一种动态数组。能够在运行阶段设置vector对象的长度,可以在末...
- 如何用sessionStorage保存对象和数组
-
背景:在工作中,我将[{},{}]对象数组形式,存储到sessionStorage,然后ta变成了我看不懂的形式,然后我想取之用之,发现不可能了~记录这次深刻的教训。$clickCouponIndex...
- JavaScript Array 对象 javascript的array对象
-
Array对象Array对象用于在变量中存储多个值:varcars=["Saab","Volvo","BMW"];第一个数组元素的索引值为0,第二个索引值为1,以此类推。更多有...
- JavaScript中的数组Array(对象) js array数组
-
1:数组Array:-数组也是一个对象-数组也是用来存储数据的-和object不同,数组中可以存储一组有序的数据,-数组中存储的数据我们称其为元素(element)-数组中的每一个元素都有一...
- 数组和对象方法&数组去重 数组去重的5种方法前端
-
列举一下JavaScript数组和对象有哪些原生方法?数组:arr.concat(arr1,arr2,arrn);--合并两个或多个数组。此方法不会修改原有数组,而是返回一个新数组...
- C++ 类如何定义对象数组?初始化数组?linux C++第43讲
-
对象数组学过C语言的读者对数组的概念应该很熟悉了。数组的元素可以是int类型的变量,例如int...
- ElasticSearch第六篇:复合数据类型-数组,对象
-
在ElasticSearch中,使用JSON结构来存储数据,一个Key/Value对是JSON的一个字段,而Value可以是基础数据类型,也可以是数组,文档(也叫对象),或文档数组,因此,每个JSON...
- 第58条:区分数组对象和类数组对象
-
示例设想有两个不同类的API。第一个是位向量:有序的位集合varbits=newBitVector;bits.enable(4);bits.enable([1,3,8,17]);b...
- 八皇后问题解法(Common Lisp实现)
-
如何才能在一张国际象棋的棋盘上摆上八个皇后而不致使她们互相威胁呢?这个著名的问题可以方便地通过一种树搜索方法来解决。首先,我们需要写一个函数来判断棋盘上的两个皇后是否互相威协。在国际象棋中,皇后可以沿...
- visual lisp修改颜色的模板函数 怎么更改visual studio的配色
-
(defunBF-yansemokuai(tuyuanyanse/ss)...
- 用中望CAD加载LISP程序技巧 中望cad2015怎么加载燕秀
-
1、首先请加载lisp程序,加载方法如下:在菜单栏选择工具——加载应用程序——添加,选择lisp程序然后加载,然后选择添加到启动组。2、然后是添加自定义栏以及图标,方法如下(以...
- 图的深度优先搜索和广度优先搜索(Common Lisp实现)
-
为了便于描述,本文中的图指的是下图所示的无向图。搜索指:搜索从S到F的一条路径。若存在,则以表的形式返回路径;若不存在,则返回nil。...
- 两个有助于理解Common Lisp宏的例子
-
在Lisp中,函数和数据具有相同的形式。这是Lisp语言的一个重大特色。一个Lisp函数可以分析另一个Lisp函数;甚至可以和另一个Lisp函数组成一个整体,并加以利用。Lisp的宏,是实现上述特色的...
- 一周热门
- 最近发表
- 标签列表
-
- grid 设置 (58)
- 移位运算 (48)
- not specified (45)
- patch补丁 (31)
- strcat (25)
- 导航栏 (58)
- context xml (46)
- scroll (43)
- element style (30)
- dedecms模版 (53)
- vs打不开 (29)
- nmap (30)
- webgl开发 (24)
- parse (24)
- c 视频教程下载 (33)
- android 开发环境 (24)
- paddleocr (28)
- listview排序 (33)
- firebug 使用 (31)
- transactionmanager (30)
- characterencodingfilter (33)
- getmonth (34)
- commandtimeout (30)
- hibernate教程 (31)
- label换行 (33)