关于springboot:简单使用spring-cloud-服务注册做一个请求转发中心

1次阅读

共计 8030 个字符，预计需要花费 21 分钟才能阅读完成。

上篇文章记录多我的项目共用一个公众号逻辑批改，实现了多个我的项目共用一个公众号。
然而也存在几点问题，比方：

两头服务器拦挡了微信的申请，尽管不便了我的项目不再须要写微信受权的代码，但如果当前须要再拓展新的微信申请，就须要再去两头服务器写 api
须要搭建前台，手动保护各个我的项目的地址和 key。

咱们能够让两头服务器只是简略地转发申请，不再拦挡，解决第一点问题。

同时利用服务发现与注册解决第二个问题。

用服务注册的益处就是，咱们不须要再手动地保护我的项目信息、各个我的项目的 ip，只须要让新来的我的项目向服务中心注册一下就好了。

服务注册是指向服务注册核心注册一个服务实例，服务提供者将本人的服务信息（如 IP 地址等）告知服务注册核心。

服务发现是指当服务消费者须要生产另外一个服务时，服务注册核心可能告知服务消费者它所要生产服务的实例信息（如服务名、IP 地址等）。

通常状况下，一个服务既是服务提供者，也是服务消费者。

所以，如下图形式，每个我的项目都向注册核心注册，就不须要建表保护各个我的项目的 ip 地址了。

可能实现服务注册的组件很多，比方 ZooKeeper、Eureka、Consul、Nacos 等。

这里选用比拟常见的 Eureka。

Eureka 是 Netflix 开发的服务发现框架，SpringCloud 将它集成在本人的子项目 spring-cloud-netflix 中，实现 SpringCloud 的服务发现性能。

上图简要形容了 Eureka 的根本架构，由 3 个角色组成：

Eureka Server 提供服务注册和发现
Service Provider 服务提供方将本身服务注册到 Eureka，从而使服务生产方可能找到
Service Consumer 服务生产方从 Eureka 获取注册服务列表，从而可能生产服务

当 Eureka Client 向 Eureka Server 注册时，Eureka Client 提供本身的元数据，比方 IP 地址、端口、运行状况指标的 Url、主页地址等信息。

Eureka Client 在默认的状况下会每隔 30 秒发送一次心跳来进行服务续约。通过服务续约来告知 Eureka Server 该 Eureka Client 依然可用，没有呈现故障。失常状况下，如果 Eureka Server 在 90 秒内没有收到 Eureka Client 的心跳，Eureka Server 会将 Eureka Client 实例从注册列表中删除。留神：官网倡议不要更改服务续约的间隔时间。

在默认状况下（当然咱们能够批改），当 Eureka Client 间断 90 秒没有向 Eureka Server 发送服务续约（即心跳）时，Eureka Server 会将该服务实例从服务注册列表删除，即服务剔除。

Eureka Client 从 Eureka Server 获取服务注册表信息，并将其缓存在本地。Eureka Client 会应用服务注册列表信息查找其余服务的信息，从而进行近程调用。该注册列表信息定时（每 30 秒）更新一次，每次返回注册列表信息可能与 Eureka Client 的缓存信息不同，Eureka Client 会本人解决这些信息。如果因为某种原因导致注册列表信息不能及时匹配，Eureka Client 会从新获取整个注册表信息。

上面就来用 Eureka 实现服务的注册与发现

角色如下

<properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>2021.0.5</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            <version>2.2.10.RELEASE</version>
        </dependency>

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

这里有个比拟深的坑，就是 spring cloud 的版本肯定要和 spring boot 的版本绝对应.

否则就会报异样

java.lang.ClassNotFoundException: org.springframework.boot.context.properties.ConfigurationBeanFactoryMetadata

首先 pom.xml 外面是否有 dependencyManagement 版本治理的设置，因为这块是会辨认并加载所须要的依赖版本，比方我要加载 spring-cloud-starter-netflix-eureka-client , 首先确定好你的 SpringBoot 版本是否兼容依赖的 SpringCloud 版本。

其次是否设置了 spring-cloud.version , 接着确认是否设置了 dependencyManagement 上面的 spring-cloud-dependencies 依赖，最初确认好要加载的 spring-cloud-starter-netflix-eureka-client , 这样最终保障你所须要的依赖包可能争取无误的加载下来。

能够去 https://spring.io/projects/spring-cloud 查看两者对应的版本

spring:
  application:
    name: wechat-service #配置注册的名字

server:
  port: 8761

eureka:
  client:
    register-with-eureka: true #是否将本人注册到 eureka-server 中
    fetch-registry: true #是否从 eureka-server 中获取服务注册信息
    service-url:
      defaultZone: http://localhost:${server.port}/eureka/  #设置服务注册核心地址
  datacenter: cloud
  environment: product

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

}

之后关上 localhost:8761, 看到如下界面阐明注册核心启动胜利，能够看到目前注册了一个服务 wechat-service, 即该我的项目自身。

另起一个 spring boot 我的项目作为服务。

<properties>
  <java.version>1.8</java.version>
  <spring-cloud.version>2020.0.4</spring-cloud.version>
</properties>

<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>
<dependencies>
  <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-dependencies</artifactId>
      <version>Hoxton.SR8</version>
      <type>pom</type>
      <scope>import</scope>
  </dependency>

  <dependency>
            <groupId>org.springframework.cloud</groupId>
            <version>2.2.5.RELEASE</version>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
</dependencies>

这里也要留神 spring boot 的版本和 spring cloud 的对应。

spring:
  application:
    name: schedule  # 注册名称

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/  #注册到 eureka
  instance:
    preferIpAddress: true

增加 @EnableEurekaClient 注解

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

之后启动该我的项目, 而后去注册核心查看，能够看到 schedule 我的项目胜利注册。

那么注册胜利之后，咱们怎么获取呢？

获取所有服务：

如果注册中心想获取所有服务能够应用 eurekaClient 提供的 getRegisteredApplications 办法获取所有服务。

@Controller
@RequestMapping("/eurekacenter")
public class EuServiceController {

  @Autowired
  private EurekaClient eurekaClient;

  @GetMapping("/services")
  @ResponseBody
  public List<Application> getServices() {return eurekaClient.getApplications().getRegisteredApplications();}
}

获取指定服务：

一般来说，咱们更罕用的是获取某一个服务。能够应用 discoveryClient.getInstances(“ 服务的 name”)，来获取一个服务。

@Autowired
private DiscoveryClient discoveryClient;

// 依据服务名称获取服务
List<ServiceInstance> serviceInstances = discoveryClient.getInstances("wechat-service");
if (CollectionUtils.isEmpty(serviceInstances)) {return null;}
ServiceInstance si = serviceInstances.get(0);

String requestUrl = "http://" + si.getHost() + ":" + si.getPort() + "/request/getQrCode";

当初咱们晓得了，能够依据服务的 name 来获取一个服务，那么作为一个申请转发核心，怎么晓得一个申请要转发给哪个服务呢？

上一篇文章实现第三方登陆：微信扫码登录 (spring boot) 理解到，申请微信服务器须要生成一个场景值，并且微信返回的申请也会返回这个场景值。

所以，咱们只有简略地在场景值后面加一个服务的关键字就能够了. 逻辑如下

接管微信申请后，转发申请的逻辑如下：

获取申请源客户端
设置转发申请的参数，转发给客户端
获取客户端响应数据
返回响应数据给微信

代码如下：

/**
   * 当设置完微信公众号的接口后，微信会把用户发送的音讯，扫码事件等推送过去
   *
   * @param signature 微信加密签名，signature 联合了开发者填写的 token 参数和申请中的 timestamp 参数、nonce 参数。* @param encType 加密类型（暂未启用加密音讯）* @param msgSignature 加密的音讯
   * @param timestamp 工夫戳
   * @param nonce 随机数
   * @throws IOException
   */
  @PostMapping(produces = "text/xml; charset=UTF-8")
  public void api(HttpServletRequest httpServletRequest,
                  HttpServletResponse httpServletResponse,
                  @RequestParam("signature") String signature,
                  @RequestParam(name = "encrypt_type", required = false) String encType,
                  @RequestParam(name = "msg_signature", required = false) String msgSignature,
                  @RequestParam("timestamp") String timestamp,
                  @RequestParam("nonce") String nonce) throws IOException {if (!this.weChatMpService.checkSignature(timestamp, nonce, signature)) {this.logger.warn("接管到了未通过校验的微信音讯，这可能是 token 配置错了，或是接管了非微信官网的申请");
      return;
    }

    // 获取客户端 url
    String targetUrl = this.wechatService.selectClientUrl(httpServletRequest);

    UriComponentsBuilder builder = UriComponentsBuilder.fromUriString(targetUrl + RequestUrl)
        .queryParam("signature", signature)
        .queryParam("timestamp", timestamp)
        .queryParam("nonce", nonce);

    if (msgSignature != null) {builder.queryParam("msg_signature", msgSignature);
    }
    if (encType != null) {builder.queryParam("encrypt_type", encType);
    }

    URI uri = builder.build().encode().toUri();
    // 设置转发申请的参数
    HttpURLConnection connection = (HttpURLConnection) uri.toURL().openConnection();
    connection.setRequestMethod("POST");
    connection.setRequestProperty("Content-Type", "text/xml; charset=UTF-8");
    connection.setDoOutput(true);
    connection.setDoInput(true);
    if (msgSignature != null) {connection.setRequestProperty("msg_signature", msgSignature);
    }
    if (encType != null) {connection.setRequestProperty("encrypt_type", encType);
    }

    // 将 httpServletRequest 中的数据写入 转发申请中
    OutputStream outputStream = connection.getOutputStream();
    String requestBody =  new RequestWrapper(httpServletRequest).getBodyString();
    outputStream.write(requestBody.getBytes(StandardCharsets.UTF_8));
    outputStream.flush();
    outputStream.close();

    // 获取 client 的响应数据
    InputStream inputStream = connection.getInputStream();
    ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
    byte[] buffer = new byte[1024];
    int bytesRead;
    while ((bytesRead = inputStream.read(buffer)) != -1) {byteArrayOutputStream.write(buffer, 0, bytesRead);
    }
    byte[] responseBytes = byteArrayOutputStream.toByteArray();
    inputStream.close();

    // 将响应数据返回给微信
    httpServletResponse.setContentType("text/xml; charset=UTF-8");
    httpServletResponse.setContentLength(responseBytes.length);
    httpServletResponse.getOutputStream().write(responseBytes);
    httpServletResponse.getOutputStream().flush();
    httpServletResponse.getOutputStream().close();
  }

效果图和以前一样：

源代码：https://github.com/weiweiyi189/weChatServiceCenter

参考：

https://juejin.cn/post/6910031138048180238
https://blog.51cto.com/u_10401840/5179710
https://juejin.cn/post/6910031138048180238#heading-8

正文完

springboot

发表至： springboot

2023-04-08

0

关于springboot:支持多种前后端组合的代码生成项目终于不用写CRUD了

关于springboot:SpringBoot基础入门2Day02笔记

关于springboot:Springboot中如何优雅进行字段校验

关于springboot:京淘day05京淘项目前端js

关于后端:Milvus在电商广告中的素材搜索实践

关于springboot:简单使用spring-cloud-服务注册做一个请求转发中心

背景

服务发现与注册

常见的注册核心

Eureka

Eureka 基本概念

Register——服务注册

Renew——服务续约

Eviction——服务剔除

Fetch Registries——获取服务注册列表信息

注册核心

1. 引入依赖

2. 配置 application.yml(全局配置)

3. 配置启动类

服务注册到 Eureka 注册核心

1. 引入依赖

2. 配置 application.yml 文件

3. 批改启动类

获取服务

转发申请性能实现

注册核心转发申请逻辑

站内搜索