526互联

springcloud搭建项目二nacos

发布时间 2023-09-21 11:56:36作者: xclyydss

在微服务架构中，服务的数量可能会非常庞大，并且会动态地进行扩缩容。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就算完成了

图片：