微服务与Nacos概述-2

news2024/11/24 0:12:22

微服务间消息传递

微服务是一种软件开发架构，它将一个大型应用程序拆分为一系列小型、独立的服务。每个服务都可以独立开发、部署和扩展，并通过轻量级的通信机制进行交互。

应用开发

  • common模块中包含服务提供者和服务消费者共享的内容

  • provider模块是服务的提供者，用于通过SpringMVC的控制器提供访问接口

服务提供者

@RestController
@RequestMapping("/users")
public class HelloController {
    @GetMapping("/hello")
    public String sayHello(@RequestParam String username) {
        if (username == null || username.trim().length() < 1)
        username = "MicroService";
        return "Provider: hello " + username + "!";
    }
}

服务消费者

服务消费者通过http协议访问服务提供者，可以使用JDK的URL或者使用HttpClient之类的工具，但是直接使用工具比较繁琐，所以使用SpringBoot提供的RestTemplate进行访问

在主类或者当前应用的配置类上声明RestTemplate

@SpringBootApplication
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

核心配置，主要修改一下访问端口号，因为应用的默认端口都是8080，会有端口号冲突的问题

server.port=7081

定义控制器实现访问服务提供者

@RestController
@RequestMapping("/consumer")
public class ConsumerController {
    @Autowired
    private RestTemplate restTemplate;
    @GetMapping("/{name}")
    public String test(@PathVariable String name){
//RestTemplate针对RESTful中的get/post/delete/put分别提供了对应的方法
        String res =
restTemplate.getForObject("http://localhost:7080/users/hello?username=" +
name, String.class);
        return res;
    }
}

测试验证

在这里插入图片描述

面试题

  • http协议的访问流程，在浏览器中输入一个URL地址都发生了什么事情

  • http协议的不同版本的区别，与https的区别

  • http协议中get和post之间的区别

Nacos服务治理

Nacos即Naming and Configuration Service是一个用于动态服务发现、配置管理和服务元数据的开源平台。

Nacos的主要功能包括：

  • 服务注册和发现：Nacos允许服务实例向注册中心注册自己的信息，并且其他服务可以通过查询注册中心来发现可用的服务实例

  • 配置管理：Nacos提供了一个中心化的配置管理平台，可以动态地管理应用程序的配置信息。开发人员可以在运行时更新配置，而不需要重启应用程序

  • 服务元数据管理：Nacos可以帮助开发人员管理服务的元数据，包括版本号、权重、健康状态等。这些元数据可以用于服务路由、负载均衡等场景

  • 动态DNS服务：Nacos支持将服务名称解析为具体的网络地址，从而实现动态DNS服务的功能

应用开发步骤

服务提供者

需要添加额外的依赖，也就是Nacos的客户端

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacosdiscovery</artifactId>
</dependency>

添加配置application.properties

# 配置当前应用名称，默认情况下向nacos注册的服务名称就是这个名称
spring.application.name=service-provider
# Nacos 服务发现与注册配置，其中子属性 server-addr 指定 Nacos 服务器主机和端口
spring.cloud.nacos.discovery.server-addr=localhost:8848
# 注册到 nacos 的指定 namespace，默认为 public
spring.cloud.nacos.discovery.namespace=public
# 应用服务 WEB 访问端口
server.port=6080

添加JavaConfig配置或者在主类上添加注解以启用Nacos客户端

@EnableDiscoveryClient
@Configuration
public class NacosDiscoveryConfiguration {
}

定义服务提供者接口

@RestController
@RequestMapping("/users")
public class HelloController {
    @GetMapping("/hello")
    public String sayHello(@RequestParam String username) {
        if (username == null || username.trim().length() < 1)
        username = "MicroService";
        return "Provider: hello " + username + "!";
    }
}
服务消费者

依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacosdiscovery</artifactId>
</dependency>

添加核心配置application.properties

server.port=6081
spring.application.name=service-consumer
# Nacos 服务发现与注册配置，其中子属性 server-addr 指定 Nacos 服务器主机和端口
spring.cloud.nacos.discovery.server-addr=localhost:8848
# 注册到 nacos 的指定 namespace，默认为 public
spring.cloud.nacos.discovery.namespace=public

添加配置类或者在主类上添加注解启用Nacos客户端

@EnableDiscoveryClient
@SpringBootApplication
public class Consumer1Application {
    public static void main(String[] args) {
        SpringApplication.run(Consumer1Application.class, args);
    }
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

定义服务消费者

@RestController
@RequestMapping("/consumer")
public class ConsumerController{ 
    @Autowired
    private RestTemplate restTemplate;
    @Autowired
    private DiscoveryClient discoveryClient;
    @GetMapping("/{name}")
    public String test(@PathVariable String name){
//服务的名称对应的是服务提供者的application.properties中的配置
        spring.application.name=service-provider
        List<ServiceInstance> instances =
discoveryClient.getInstances("service-provider"); //因为一个服务可以运行在多个节点上或者使用多个进程
//自定义负载均衡策略实现从多个服务提供者实例中选择一个
        Random r=new Random();
        ServiceInstance instance =
instances.get(r.nextInt(instances.size()));
        String res =
restTemplate.getForObject(instance.getUri()+"/users/hello?username=" + name,
String.class);
        return res;
    }
}

验证测试

  • 首先启动nacos中间件 startup -m standalone ，对应的管理控制台为http://localhost:8848/nacos

  • 启动服务提供者。在Nacos的webUI中就可以看到服务提供者的注册信息

在这里插入图片描述

使用该管理控制台可以针对服务提供者的详细信息进行查看，例如节点情况

在这里插入图片描述

  • 启动服务消费者

在这里插入图片描述

引入负载均衡

在消费方引入负载均衡机制，同时简化获取服务提供者信息的流程

Spring Cloud引入组件LoadBalance实现负载均衡

添加依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacosdiscovery</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>

properties配置

spring.application.name=service-consumer
# Nacos 服务发现与注册配置，其中子属性 server-addr 指定 Nacos 服务器主机和端口
spring.cloud.nacos.discovery.server-addr=localhost:8848
# 注册到 nacos 的指定 namespace，默认为 public
spring.cloud.nacos.discovery.namespace=public
server.port=6082

主类上添加对应的注解

@EnableDiscoveryClient
@SpringBootApplication
public class Consumer2Application {
    public static void main(String[] args) {
        SpringApplication.run(Consumer2Application.class, args);
    }
    @LoadBalanced
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

定义对应的控制器，需要访问服务提供者

@RestController
@RequestMapping("/consumer")
public class ConsumerController {
    @Autowired
    private RestTemplate restTemplate;
    @GetMapping("/{name}")
    public String test(@PathVariable String name){
//使用LB后具体的URL地址中使用服务提供者的名称来替代原始的主机名和端口号
        String res = restTemplate.getForObject("http://serviceprovider/users/hello?username=" + name, String.class);
        return res;
    }
}

验证测试

在这里插入图片描述

缓存配置

使用LB从Nacos获取服务的注册信息，可以在本地进行缓存。添加配置即可

spring.cloud.loadbalancer.cache.enabled=true 启用本地缓存，可以根据实际情况权衡
spring.cloud.loadbalancer.cache.capacity=1000 设置缓存空间大小
spring.cloud.loadbalancer.cache.ttl=20 缓存的存活时间，单位为s

订阅更新

缓存有可能和远程的注册信息不一致，所以引入长连接的订阅实现Nacos的主动通知更改

spring.cloud.nacos.discovery.watch.enabled=true

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/856419.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【数学】CF1796 C

【数学】CF1796 C

Problem - 1796C - Codeforces 题意&#xff1a; 思路&#xff1a; 模拟一下样例可以发现一些规律 Code&#xff1a; #include <bits/stdc.h>#define int long longusing i64 long long;constexpr int N 1e6 10; constexpr int mod 998244353;void solve() {int l…
阅读更多...
搭建 Java 部署环境

搭建 Java 部署环境

yum 认识 yum yum(Yellow dog Updater, Modified)是Linux下非常常用的一种包管理器. 主要应用在Fedora, RedHat, Centos等发行版上. 包管理器就好比 "应用商店", 我们可以在应用商店上下载一些 app. yum 起到的功能和 Maven 的依赖管理功能类似. 使用 Maven 能帮…
阅读更多...
kubernetes pod 资源限制 探针

kubernetes pod 资源限制 探针

资源限制 当定义 Pod 时可以选择性地为每个容器设定所需要的资源数量。 最常见的可设定资源是 CPU 和内存大小&#xff0c;以及其他类型的资源。 当为 Pod 中的容器指定了 request 资源时&#xff0c;代表容器运行所需的最小资源量&#xff0c;调度器就使用该信息来决定将 Pod …
阅读更多...
JS逆向系列之猿人学爬虫第8题-验证码-图文点选

JS逆向系列之猿人学爬虫第8题-验证码-图文点选

题目地址 https://match.yuanrenxue.cn/match/8本题的难点就在于验证码的识别，没啥js加密，只要识别对了携带坐标就给返回数据 回过头来看验证码 这里复杂的字体比较多，人看起来都有点费劲（感觉可能对红绿色盲朋友不太又好）&#x
阅读更多...
为什么说Java是值传递？

为什么说Java是值传递？

值传递、引用传递 首要我们需要明确什么是值传递、什么是引用传递。 值传递&#xff1a;形参接收的是实参的拷贝&#xff08;副本&#xff09;。因此对形参的修改&#xff0c;不一定会影响实参。引用传递&#xff1a;形参接收的是实参本身&#xff0c;不会创建副本。因此对形…
阅读更多...
flutter 手写日历组件

flutter 手写日历组件

先看效果 直接上代码 calendar_popup_view.dart import package:flutter/material.dart; import package:intl/intl.dart;import custom_calendar.dart; import hotel_app_theme.dart;class CalendarPopupView extends StatefulWidget {const CalendarPopupView({required th…
阅读更多...
翻出了我当时学习的笔记来了html

翻出了我当时学习的笔记来了html

php&#xff1a;高级语言 web应用程序 万维网 浏览器中查看 apache&#xff1a;服务器 mysql&#xff1a;数据库 html 标签 css&#xff1a;层叠样式表 javascript&#xff1a;客户端脚本 js jquery mysql数据库基础 php语法基础 面向对象&#xff08;物件&#xff09; smar…
阅读更多...
WebRTC | 实现数据流的一对一通信

WebRTC | 实现数据流的一对一通信

目录 一、浏览器对WebRTC的支持 二、MediaStream与MediaStreamTrack 三、RTCPeerConnection 1. RTCPeerConnection与本地音视频数据绑定 2. 媒体协商SDP 3. ICE &#xff08;1&#xff09;Candidate信息 &#xff08;2&#xff09;WebRTC收集Candidate &#xff08;3&…
阅读更多...
LOTO示波器实测过压保护芯片LP5300工作效果

LOTO示波器实测过压保护芯片LP5300工作效果

过压保护电路是电子产品设置中经常要用到的&#xff0c;以前都是用分立元件搭的各种经典电路&#xff0c;最近LOTO虚拟示波器客户推荐了一款很便宜的集成的过压保护芯片LP5300&#xff0c;体积很小&#xff0c;使用简单&#xff0c;外接两个电容就可以了&#xff0c;下图是它的…
阅读更多...
linux自定义网络访问规则

linux自定义网络访问规则

1.更改防火墙默认区域为trusted firewall-cmd --set-default-zonetrusted 2.新建一个zone&#xff0c;将想要访问本机80端口的ip&#xff0c;如&#xff1a;192.168.3.99 &#xff0c;添加的这个zone中&#xff0c;同时在这个zone中放行80端口。 firewall-cmd --permanent --ne…
阅读更多...
django中使用bootstrap-datepicker时间插件

django中使用bootstrap-datepicker时间插件

1、插件的下载 Bootstrap Datepicker是一款基 于Bootstrap框架的日期选择控件&#xff0c;可以方便地在Web应用中添加可交互的日期选择功能。Bootstrap Datepicker拥有丰富的选项和API,支持多种日期格式&#xff0c;可以自定义样式并支持各种语言。 Bootstrap Datepicker 依赖…
阅读更多...
DolphinScheduler集群搭建详细笔记

DolphinScheduler集群搭建详细笔记

1.DolphinScheduler Cluster部署 1.1 集群部署规划 集群模式下&#xff0c;可配置多个Master及多个Worker。通常可配置2~3个Master&#xff0c;若干个Worker。由于集群资源有限&#xff0c;此处配置一个Master&#xff0c;三个Worker&#xff0c;集群规划如下。 主机名ip服务…
阅读更多...
Hybrid App 技术发展的趋势解读

Hybrid App 技术发展的趋势解读

Hybrid这个词&#xff0c;在App开发领域&#xff0c;相信大家都不陌生。Hybrid App是指介于web-app、native-app这两者之间的app&#xff0c;它虽然看上去是一个Native App&#xff0c;但只有一个UI WebView&#xff0c;里面访问的是一个Web App。Hybrid在移动领域的发展&#…
阅读更多...
为什么要从 Splashtop Business Access 升级到 Enterprise？

为什么要从 Splashtop Business Access 升级到 Enterprise？

远程工作只是偶尔为之的时代已经一去不复返了。它已成为一种战略必需品&#xff0c;使企业能够利用全球人才库&#xff0c;提供灵活的工作安排&#xff0c;并在不可预测的情况下确保业务连续性。 拥有安全、可靠、高效的远程访问解决方案已变得至关重要。Splashtop Business A…
阅读更多...
【学习】若依源码（前后端分离版）之 “ 用户的权限注解”

【学习】若依源码（前后端分离版）之 “ 用户的权限注解”

大型纪录片&#xff1a;学习若依源码&#xff08;前后端分离版&#xff09;之 “ 用户的权限注解” 前言前端部分后端部分公开接口 结语 前言 接着来聊聊若依前后端分离版的权限注解吧。若依前后端分离版的权限注解是一种基于Spring Security和Vue的权限管理系统&#xff0c;它…
阅读更多...
快速获得图像中像素值的小工具

快速获得图像中像素值的小工具

之前项目中为了做lka中获得rgb图像信息&#xff0c;网上大多方案是确定相关的区域然后输出像素值&#xff0c;这个方法太麻烦&#xff0c;做了一个简单的使用鼠标点击图片某区域&#xff0c;然后直接在终端输出该区域的像素值。下面是源码&#xff1a; import cv2 import matp…
阅读更多...
解析湖仓一体的支撑技术及实践路径

解析湖仓一体的支撑技术及实践路径

自2021年“湖仓一体”首次写入Gartner数据管理领域成熟度模型报告以来&#xff0c;随着企业数字化转型的不断深入&#xff0c;“湖仓一体”作为新型的技术受到了前所未有的关注&#xff0c;越来越多的企业视“湖仓一体” 为数字化转型的重要基础设施。 01 数据平台的发展历程…
阅读更多...
kubernetes高性能存储-piraeus简介

kubernetes高性能存储-piraeus简介

piraeus简介 Piraeus 是面向 Kubernetes 的高性能、高可用性、简单、安全且与云无关的云原生存储解决方案&#xff0c;号称性能和稳定性都优于 Ceph/OpenEBS/Longhorn 等项目。Piraeus 对应的商业产品为LINSTOR 。 众所周知&#xff0c;本地存储具有高性能的优势&#xff0c;…
阅读更多...
基于Python 简易实现接口测试自动化

基于Python 简易实现接口测试自动化

目录 实现思路 统筹脚本 请求封装 日志封装 结果比对 结果邮件 用例获取及数据格式化 请求url转换 测试用例excel结构 测试报告 邮件接收结果 资料获取方法 实现思路 使用excel管理用例用例信息&#xff0c;requests模块发送http请求&#xff0c;实现了记录日志&…
阅读更多...
科聪控制系统六大行业典型应用案例合集

科聪控制系统六大行业典型应用案例合集

01. 纺织行业 科聪移动机器人通用控制系统赋能无人接丝AGV实现丝盘自动化上下料 应用难点&#xff1a;无人接丝AGV是纺织行业无人工厂重要环节之一&#xff0c;这个环节对机器人到点精度要求非常高&#xff0c;无人接丝AGV的到位精度&#xff0c;必须确保“丝级”的准确无误&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023