在微服务架构中,服务的数量可能会非常庞大,并且会动态地进行扩缩容。Nacos提供了服务发现功能,允许服务实例在注册到Nacos后,其他服务可以通过Nacos查询到它们的地址和信息,从而实现服务之间的通信和调用。当一个服务实例发生变化(比如新增、下线、失败等),Nacos能够及时感知这些变化,确保其他服务可以动态地感知到这些变化,从而保证了服务之间的高可用性和灵活性。
下面我们开始整合nacos
由于我们用的是2021.0.5.0版本,所以对应的nacos版本为2.2.0
资源我们可以直接去https://github.com/alibaba/nacos/tags下面找
记住一定要点那个2.2.0进去,在这个页面最下面:https://github.com/alibaba/nacos/releases/tag/2.2.0
有需要资源文件的也可以联系我
我在本地安装了VMware+centOS 7,没有linux服务器的可以试着安装一下,这里就不教怎么安装这个了
安装前我们需要先确认服务器上安装了jdk,没有安装的自己先安装jdk,配置好环境变量
将文件上传到nacos目录下后解压:tar -zxvf nacos-server-2.2.0.tar.gz
解压后旁边会多出一个nacos文件夹
直接进到bin目录启动就好了:cd nacos/bin
启动nacos:sudo sh startup.sh -m standalone
启动成功后我们在浏览器输入:http://192.168.43.128:8848/nacos
在面这个页面填入用户名:nacos 密码:nacos
如果出现无法访问的情况可能是服务器端口未开放
可以用下面的命令试一下
firewall-cmd --query-port=8848/tcp // 查询8848端口是否开发,如果显示no则未开放
firewall-cmd --add-port=8848/tcp --permanent // 开放端口8848
firewall-cmd --reload // 重启一下端口配置
// 加两个端口9848 9849,这是nacos2.2.0版本新加的内容,不然后面项目会连不上去
firewall-cmd --add-port=9848/tcp --permanent
firewall-cmd --add-port=9849/tcp --permanent
还有nacos集群以及数据源配置什么的我这里都不讲了,都很简单,多部署几套改下配置文件就可以了
接下来我们在项目中集成nacos
首先我修改order的pom文件,直接覆盖就好了
<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">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.sakura.springcloud</groupId>
<artifactId>springcloudalibaba</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<artifactId>order</artifactId>
<packaging>jar</packaging>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- nacos服务注册发现 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- loadbalancer启动器 naocs2.2版本取消了自带的负载均衡器需要加这个 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
</dependencies>
</project>
接着我们修改order的application.yml配置文件,直接覆盖
server:
port: 8010
spring:
application:
name: order-service
cloud:
# loadbalancer只是为了后面的测试,因为nacos2.2.0关闭了这个,低版本的也不需要这个
loadbalancer:
nacos:
enabled: true
nacos:
server-addr: 192.168.43.128:8848
discovery:
username: nacos
password: nacos
namespace: public
然后为了方便测试我们改一下OrderController和OrderApplication文件
OrderController主要是将ip地址换成了服务名称stock-service,证明我们的服务可用
package com.sakura.order.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
/**
* @author Sakura
* @date 2023/7/19 11:25
*/
@RestController
@RequestMapping("/order")
public class OrderController {
@Autowired
RestTemplate restTemplate;
@RequestMapping("/add")
public String add(){
System.out.println("下单成功");
String msg = restTemplate.getForObject("http://stock-service/stock/reduct", String.class);
return "下单成功" + msg;
}
}
OrderApplication在下面的RestTemplate加了个注解@LoadBalanced,用来启动负载均衡,使它可以找到stock-service服务
package com.sakura.order;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
/**
* @author Sakura
* @date 2023/7/19 11:43
*/
@SpringBootApplication
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
}
@Bean
@LoadBalanced
public RestTemplate restTemplate(RestTemplateBuilder builder) {
RestTemplate restTemplate = builder.build();
return restTemplate;
}
}
然后我们在stock模块里面也改一下pom文件,直接覆盖
<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">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.sakura.springcloud</groupId>
<artifactId>springcloudalibaba</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<artifactId>stock</artifactId>
<packaging>jar</packaging>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- nacos服务注册发现 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
</dependencies>
</project>
再覆盖一下stock的application.yml
server:
port: 8011
spring:
application:
name: stock-service
cloud:
nacos:
server-addr: 192.168.43.128:8848
discovery:
username: nacos
password: nacos
namespace: public
启动这两个项目,登录nacos看一下服务是否注册成功
然后我们在浏览器测试一下,可以看到依然是请求成功的,说明在order服务里面通过http://stock-service/stock/reduct就可以访问到stock了,这样我们就里微服务架构近了一大步
当然我们还可以启动两个stock服务看一下负载均衡的效果
我们利用idea的run Dashboard组件开两个库存服务,不会的可以去了解下这个怎么用
这里我开了一个8011和8012两个stock服务
然后稍微调整了下stock的controller接口用来输出一下我们调的是哪一个服务
package com.sakura.stock.controller;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @author Sakura
* @date 2023/7/19 11:35
*/
@RestController
@RequestMapping("/stock")
public class StockController {
@Value("${server.port}")
String port;
@RequestMapping("/reduct")
public String reduct(){
System.out.println("扣减库存");
return "扣减库存" + port;
}
}
我们还是在浏览器输入:http://localhost:8010/order/add
再点一下
可以看到负载均衡生效了,轮询机制,一个服务一下
好了,到这里springcloud整合nacos就算完成了
图片:
标签:springcloud,nacos,springframework,import,org,搭建,port,stock From: https://www.cnblogs.com/xcl1-yyds/p/17719595.html