SpringCloudAlibaba随笔目录
二、 SpringCloudAlibaba项目之Nacos搭建及服务注册
三、SpringCloudAlibaba项目之生产者与消费者
四、SpringCloud Alibaba项目之Ribbon负载均衡
五、SpringCloud Alibaba项目之 OpenFeign远程调用
六、SpringCloud Alibaba项目之Nacos-config配置中心
七、SpringCloud Alibaba项目之Sentinel流量控制
八、SpringCloudAlibaba项目之Seata分布式事务
九、SpringCloudAlibaba项目之GateWay网关
十、SpringCloudAlibaba项目之SkyWalking链路 追 踪
SpringCloudAlibaba项目之生产者与消费者
1、生产者与消费者
本篇文章，我们搭建俩个服务，生产者服务与消费者服务。
我们以电商系统为例：服务生产者 service-order，服务消费者service-stock <br>
说明：service-order 作为消费者提供新增订单信息的功能，service-stock作为生产者提供库存的扣减服务功能；这里调用者为消费者，被掉用者为生产者。
项目目录
2、生产者服务搭建
使用Spring Initializr创建
修改pom.xml文件：
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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0modelVersion> <parent> <artifactId>spring-cloud-alibabaartifactId> <groupId>com.qtgroupId> <version>1.0-SNAPSHOTversion> parent> <groupId>com.qtgroupId> <artifactId>service-stockartifactId> <version>0.0.1-SNAPSHOTversion> <name>service-stockname> <description>service-stock project for Spring Bootdescription> <dependencies> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-webartifactId> dependency> <dependency> <groupId>com.alibaba.cloudgroupId> <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId> dependency> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-testartifactId> <scope>testscope> <exclusions> <exclusion> <groupId>org.junit.vintagegroupId> <artifactId>junit-vintage-engineartifactId> exclusion> exclusions> dependency> dependencies> <build> <plugins> <plugin> <groupId>org.apache.maven.pluginsgroupId> <artifactId>maven-compiler-pluginartifactId> <version>3.8.1version> <configuration> <source>1.8source> <target>1.8target> <encoding>UTF-8encoding> configuration> plugin> <plugin> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-maven-pluginartifactId> <version>2.3.7.RELEASEversion> <configuration> <mainClass>com.qt.servicestock.ServiceStockApplicationmainClass> configuration> <executions> <execution> <id>repackageid> <goals> <goal>repackagegoal> goals> execution> executions> plugin> plugins> build> project>
父工程的pom.xml文件添加：
<modules> <module>service-stockmodule> modules>
application.properties修改：
应用名称
spring.application.name=service-stock
应用服务 WEB 访问端口
server.port=8030
Nacos帮助文档: https://nacos.io/zh-cn/docs/concepts.html
Nacos认证信息
spring.cloud.nacos.discovery.username=nacos
spring.cloud.nacos.discovery.password=nacos
Nacos 服务发现与注册配置，其中子属性 server-addr 指定 Nacos 服务器主机和端口
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
注册到 nacos 的指定 namespace，默认为 public
spring.cloud.nacos.discovery.namespace=public
新增StockController：
/**
* 库存服务
*/
@RestController
@RequestMapping("/stock")
public class StockController {
@Value("${server.port}")
private String port;
/**
* 库存新增
* @return
*/
@RequestMapping("/addStock")
public String addStock(){
System.out.println("库存新增成功");
return "库存服务-库存新增成功";
}
/**
* 库存扣减
* @return
*/
@RequestMapping("/subStock")
public String subStock(){
System.out.println("库存扣减成功");
return "库存服务-库存扣减成功 - 端口：" + port;
}
}
启动类：
@SpringBootApplication
@EnableDiscoveryClient //可加可不加，依版本而定，从Spring Cloud Edgware开始，@EnableDiscoveryClient可省略。只需加上相关依赖，并进行相应配置，即可将微服务注册到服务发现组件上。
public class ServiceStockApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceStockApplication.class, args);
}
}
3、消费 者服务搭建（和生产者创建一样）
使用Spring Initializr创建
修改pom.xml文件：
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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0modelVersion> <parent> <artifactId>spring-cloud-alibabaartifactId> <groupId>com.qtgroupId> <version>1.0-SNAPSHOTversion> parent> <groupId>com.qtgroupId> <artifactId>service-orderartifactId> <version>0.0.1-SNAPSHOTversion> <name>service-ordername> <description>service-order project for Spring Bootdescription> <dependencies> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-webartifactId> dependency> <dependency> <groupId>com.alibaba.cloudgroupId> <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId> dependency> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-testartifactId> <scope>testscope> <exclusions> <exclusion> <groupId>org.junit.vintagegroupId> <artifactId>junit-vintage-engineartifactId> exclusion> exclusions> dependency> dependencies> <build> <plugins> <plugin> <groupId>org.apache.maven.pluginsgroupId> <artifactId>maven-compiler-pluginartifactId> <version>3.8.1version> <configuration> <source>1.8source> <target>1.8target> <encoding>UTF-8encoding> configuration> plugin> <plugin> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-maven-pluginartifactId> <version>2.3.7.RELEASEversion> <configuration> <mainClass>com.qt.serviceorder.ServiceOrderApplicationmainClass> configuration> <executions> <execution> <id>repackageid> <goals> <goal>repackagegoal> goals> execution> executions> plugin> plugins> build> project>
父工程的pom.xml文件添加：
<modules> <module>service-stockmodule> <module>service-ordermodule> modules>
application.properties修改：
应用名称
spring.application.name=service-order
应用服务 WEB 访问端口
server.port=8040
Nacos帮助文档: https://nacos.io/zh-cn/docs/concepts.html
Nacos认证信息
spring.cloud.nacos.discovery.username=nacos
spring.cloud.nacos.discovery.password=nacos
Nacos 服务发现与注册配置，其中子属性 server-addr 指定 Nacos 服务器主机和端口
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
注册到 nacos 的指定 namespace，默认为 public
spring.cloud.nacos.discovery.namespace=public
新增OrderController：
/**
* 新增订单
* @return
*/
@RequestMapping("/addOrder")
public String addOrder(){
System.out.println("订单新增成功");
//调用库存扣减
String apiReqResult = restTemplate.getForObject("http://service-stock/stock/subStock",String.class);
return "订单服务-订单新增成功:" + apiReqResult;
}
启动类：
@SpringBootApplication
@EnableDiscoveryClient //可加可不加，依版本而定，从Spring Cloud Edgware开始，@EnableDiscoveryClient可省略。只需加上相关依赖，并进行相应配置，即可将微服务注册到服务发现组件上。
public class ServiceOrderApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceOrderApplication.class, args);
}
}
4、使用RestTemplate实现调用（后面使用OpenFeign远程调用）
/**
* SpringBoot-RestTemplate实现调用第三方API
*/
@Configuration
@Component
public class RestTemplateConfig {
@Bean
@LoadBalanced //使RestTemplate请求支持负载均衡
public RestTemplate restTemplate(RestTemplateBuilder builder){
RestTemplate restTemplate = builder.build();
return restTemplate;
}
}
5、运行效果
服务注册
访问接口地址：http://localhost:8040/order/addOrder
总结：实践是检验真理的唯一标准。
Original: https://www.cnblogs.com/qiantao/p/15719500.html
Author: QianTM
Title: SpringCloudAlibaba项目之生产者与消费者
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/572518/
转载文章受原作者版权保护。转载请注明原作者出处！