spring cloudribbon应用植入

2024-01-18 21:32
文章标签 java 应用 spring 植入 cloudribbon

本文主要是介绍spring cloudribbon应用植入，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

spring cloud&ribbon应用植入

  • 简介
  • 应用总览
    • 模块总览
    • 技术栈
  • 注册中心eureka-server
    • pom配置
    • bootstrap配置
    • application配置
    • 启动类
  • 用户中心user-center
    • pom配置
    • application配置
    • 启动项目
  • 用户中心提供的api user-center
  • 访问调用api admin-client-api
  • 总结
  • 参看文献
  • 源码

简介

随着微服务普及，懂得微服务变得越来越重要，也是java程序员的必备基础，个人为了学习和了解微服务的负载均衡ribbon的实现原理和feignClient基础知识，针对性搭建了基础微服务架构并后面一章节简单介绍微服务符合发现服务的源码，同时介绍一下开发技巧。

应用总览

模块总览

  1. 注册中心eureka-server
  2. 用户中心user-center
  3. 用户中心提供的api user-center
  4. 前端访问调用api admin-client-api
    如下图：
    在这里插入图片描述

技术栈

  1. maven 构建工具
  2. IntelliJ IDEA 开发工具
  3. spring boot 基础框架
  4. spring cloud rest微服务体系
  5. spring cloud feign 客户端调用
  6. ribbon 负载均衡

这里搭建是居于上一章节工程初始化，使用maven的模块化开发讲解。上一次工程源码（此步走可忽略，根据自己需要初始化）

注册中心eureka-server

服务注册中心主要提供发现服务功能，还有监听服务运行是否健康等情况

pom配置

这里使用spring security作为验证注册。配置如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.3.8.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><modelVersion>4.0.0</modelVersion><artifactId>eureka-server</artifactId><properties><spring-cloud.version>Hoxton.SR9</spring-cloud.version><eureka-server.version>2.2.6.RELEASE</eureka-server.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-security</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId><version>${eureka-server.version}</version></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><mainClass>com.lgh.server.ServerApplication</mainClass></configuration></plugin></plugins></build>
</project>

bootstrap配置

spring:application:name: eureka-servercloud:config:uri: http://localhost:8888/eureka/

application配置

server:port: 8761
eureka:client:registerWithEureka: falsefetchRegistry: falseserver:waitTimeInMsWhenSyncEmpty: 0
spring:security:user:name: adminpassword: admin123456

启动类

在启动类中添加@EnableEurekaServer，作为注册中心服务器启动

@SpringBootApplication
@EnableEurekaServer
public class ServerApplication {public static void main(String[] args) {SpringApplication.run(ServerApplication.class, args);}
}

在上面配置完后并未完事，因为我们启动了spring security配置，这是security会防止跨站访问，我们需要配置security的跨域访问权限，否则eureka客户端将无法注册进来。

@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {@Overrideprotected void configure(HttpSecurity http) throws Exception {http.csrf().disable();super.configure(http);}@Overridepublic void configure(WebSecurity web) throws Exception {web.ignoring().antMatchers("/favicon.ico");super.configure(web);}
}

接下来我们启动main方法访问http://localhost:8761/ ，eureka服务器讲启动成功，如图
在这里插入图片描述

用户中心user-center

pom配置

这里因为是上一章节配置文件比较多，所以比较负责，简单项目接入只需要接入如下引入即可：

   <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>com.netflix.feign</groupId><artifactId>feign-okhttp</artifactId><version>8.18.0</version></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>

以及添加cloud管理

<dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

application配置

eureka:instance:leaseRenewalIntervalInSeconds: 1leaseExpirationDurationInSeconds: 2preferIpAddress: trueclient:serviceUrl:defaultZone: http://admin:admin123456@127.0.0.1:8761/eureka/

启动项目

在你的启动项目添加如下注解
@EnableFeignClients
@EnableEurekaClient
启动项目后查看eureka服务器是否已经注册上
在这里插入图片描述

用户中心提供的api user-center

用户中心api主要提供feignClient给外部调用的jar包，这里只是简单描述,一个登录接口服务，一个验证登录服务，具体请查看后面源码：

@FeignClient(name = ServerConfig.USER_CENTER, path = "/login")
public interface ILogonClient {@PostMapping("/sign")LogonRepDTO login(@RequestBody LogonReqDTO logonReqDTO);@GetMapping("/verify")LogonRepDTO verify(@RequestParam("token") String token);
}

访问调用api admin-client-api

环境搭建和用户中心一致，不做重复讲解，这里主要讲解如何调用，针对前面文章讲解使用security验证登录，
spring获取feign ApplicationUtil.getBean(ILogonClient.class)，如下：

public class MyAuthenticationFilter extends OncePerRequestFilter {@Overrideprotected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {String token = request.getHeader("token");if (StringUtils.isEmpty(token)) {filterChain.doFilter(request, response);} else {ILogonClient iLogonClient = ApplicationUtil.getBean(ILogonClient.class);LogonRepDTO logonRepDTO = iLogonClient.verify(token);if (logonRepDTO == null) {ObjectMapper objectMapper = ApplicationUtil.getBean(ObjectMapper.class);response.setContentType("application/json;charset=utf-8");response.getWriter().print(objectMapper.writeValueAsString(CommonResult.deny()));return;} else {UserDetail userDetail = new UserDetail();userDetail.setId(logonRepDTO.getId());userDetail.setName(logonRepDTO.getUserName());List<MySimpleGrantedAuthority> roles = new ArrayList<>();if (logonRepDTO.getUserResources() != null) {roles = logonRepDTO.getUserResources().stream().map(ResourceDomain::getResourceCode).map(MySimpleGrantedAuthority::new).collect(Collectors.toList());}MyAuthentication myAuthentication = new MyAuthentication(userDetail, roles);SecurityContextHolder.getContext().setAuthentication(myAuthentication);filterChain.doFilter(request, response);}}}
}

自动注入形式调用，如登录访问接口

@Api(tags = "登录服务")
@RestController
@RequestMapping("/login")
@Validated
public class LogonController {@Autowiredprivate ILogonClient iLogonClient;@ApiOperation("登录服务接口")@PostMapping("/sign")@Validpublic IResult<LogonRepDTO> login(@RequestBody LogonReqDTO logonReqDTO) {LogonRepDTO logonRepDTO = iLogonClient.login(logonReqDTO);return CommonResult.successData(logonRepDTO);}@GetMapping("/testFilter")public String testFilter() {return "available!";}
}

总结

这里总结自己在搭建过程中问题总结

  1. spring cloud和boot版本不一致问题，以及解决版本冲突方式，我们可以通过找到对应匹配版本或者通过maven的exclusions
  2. eurake server注册中心没法注册，因为开启了security跨站拦截，即使设置了用户名密码也无法访问，## http://admin:admin123456@127.0.0.1:8761/eureka/ ,需要设置http.csrf().disable()，在解决过程中可以通过去掉security看是否是security问题
  3. feign可指定IP访问，以便开发链条或者百名单形式配置
        eureka.client.enabled = false
        user-center.ribbon.listOfServers: localhost:8085 # 黑体是feign的name实例名
  4. 更多问题查看FeignClient如何寻址

参看文献

【1】HowToDoInJava
【2】feignClient

源码

spring cloud demo

这篇关于spring cloudribbon应用植入的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/620318。

相关文章

Java实现检查多个时间段是否有重合

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1：定义时间段类步骤2：添加时间段步骤3：检查时间段是否有重合步骤4：输出结果示例代码结语作
阅读更多...
Java中String字符串使用避坑指南

Java中String字符串使用避坑指南

《Java中String字符串使用避坑指南》Java中的String字符串是我们日常编程中用得最多的类之一,看似简单的String使用,却隐藏着不少“坑”,如果不注意,可能会导致性能问题、意外的错误容... 目录8个避坑点如下：1. 字符串的不可变性：每次修改都创建新对象2. 使用 == 比较字符串，陷阱满
阅读更多...
Java判断多个时间段是否重合的方法小结

Java判断多个时间段是否重合的方法小结

《Java判断多个时间段是否重合的方法小结》这篇文章主要为大家详细介绍了Java中判断多个时间段是否重合的方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录判断多个时间段是否有间隔判断时间段集合是否与某时间段重合判断多个时间段是否有间隔实体类内容public class D
阅读更多...
IDEA编译报错“java: 常量字符串过长”的原因及解决方法

IDEA编译报错“java: 常量字符串过长”的原因及解决方法

《IDEA编译报错“java:常量字符串过长”的原因及解决方法》今天在开发过程中,由于尝试将一个文件的Base64字符串设置为常量,结果导致IDEA编译的时候出现了如下报错java:常量字符串过长,... 目录一、问题描述二、问题原因2.1 理论角度2.2 源码角度三、解决方案解决方案①：StringBui
阅读更多...
Java覆盖第三方jar包中的某一个类的实现方法

Java覆盖第三方jar包中的某一个类的实现方法

《Java覆盖第三方jar包中的某一个类的实现方法》在我们日常的开发中,经常需要使用第三方的jar包,有时候我们会发现第三方的jar包中的某一个类有问题,或者我们需要定制化修改其中的逻辑,那么应该如何... 目录一、需求描述二、示例描述三、操作步骤四、验证结果五、实现原理一、需求描述需求描述如下：需要在
阅读更多...
Java中ArrayList和LinkedList有什么区别举例详解

Java中ArrayList和LinkedList有什么区别举例详解

《Java中ArrayList和LinkedList有什么区别举例详解》：本文主要介绍Java中ArrayList和LinkedList区别的相关资料,包括数据结构特性、核心操作性能、内存与GC影... 目录一、底层数据结构二、核心操作性能对比三、内存与 GC 影响四、扩容机制五、线程安全与并发方案六、工程
阅读更多...
JavaScript中的reduce方法执行过程、使用场景及进阶用法

JavaScript中的reduce方法执行过程、使用场景及进阶用法

《JavaScript中的reduce方法执行过程、使用场景及进阶用法》：本文主要介绍JavaScript中的reduce方法执行过程、使用场景及进阶用法的相关资料,reduce是JavaScri... 目录1. 什么是reduce2. reduce语法2.1 语法2.2 参数说明3. reduce执行过程
阅读更多...
如何使用Java实现请求deepseek

如何使用Java实现请求deepseek

《如何使用Java实现请求deepseek》这篇文章主要为大家详细介绍了如何使用Java实现请求deepseek功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1.deepseek的api创建2.Java实现请求deepseek2.1 pom文件2.2 json转化文件2.2
阅读更多...
Java调用DeepSeek API的最佳实践及详细代码示例

Java调用DeepSeek API的最佳实践及详细代码示例

《Java调用DeepSeekAPI的最佳实践及详细代码示例》：本文主要介绍如何使用Java调用DeepSeekAPI,包括获取API密钥、添加HTTP客户端依赖、创建HTTP请求、处理响应、... 目录1. 获取API密钥2. 添加HTTP客户端依赖3. 创建HTTP请求4. 处理响应5. 错误处理6.
阅读更多...
Spring AI集成DeepSeek的详细步骤

Spring AI集成DeepSeek的详细步骤

《SpringAI集成DeepSeek的详细步骤》DeepSeek作为一款卓越的国产AI模型,越来越多的公司考虑在自己的应用中集成,对于Java应用来说,我们可以借助SpringAI集成DeepSe... 目录DeepSeek 介绍Spring AI 是什么？1、环境准备2、构建项目2.1、pom依赖2.2
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2