微服务SpringCloudAlibaba配置汇总
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了微服务SpringCloudAlibaba配置汇总相关的知识,希望对你有一定的参考价值。
参考技术A在 pom.xml 中添加 spring-cloud-alibaba-dependencies 统一管理版本:
Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。
通过 @EnableDiscoveryClient 注解表明是一个 Nacos 客户端,该注解是 Spring Cloud 提供的原生注解
注:server-addr为Nacos Server 网址
Sentinel 以流量为切入点,从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。
Sentinel 以流量为切入点,从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。
使用 Spring Cloud Alibaba Nacos Config,您可以在 Nacos Server 集中管理你 Spring Cloud 应用的外部属性配置。
注意:Spring Boot 配置文件的加载顺序,依次为 bootstrap.properties -> bootstrap.yml -> application.properties -> application.yml ,其中 bootstrap.properties 配置为最高优先级
RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。
配置 Output(Source.class) 的 Binding 信息并配合 @EnableBinding 注解使其生效
运行成功后即可在 RocketMQ 控制台的 消息 列表中选择 test-topic 主题即可看到发送的消息
配置 Input(Sink.class) 的 Binding 信息并配合 @EnableBinding 注解使其生效
RPC框架分为提供方和消费方,提供方提供服务,消费方消费服务。这里采用nacos注册中心和Dubbo框架配置。
SpringCloudAlibaba微服务组件Dubbo
文章目录
1. provider端配置
引入依赖
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
application.yml
dubbo:
scan:
# 指定 Dubbo 服务实现类的扫描基准包
base-packages: com.cry.mall.user.service
# application:
# name: $spring.application.name
protocol:
# dubbo 协议
name: dubbo
# dubbo 协议端口( -1 表示自增端口,从 20880 开始)
port: -1
# registry:
# #挂载到 Spring Cloud 注册中心 高版本可选
# address: spring-cloud://127.0.0.1:8848
spring:
application:
name: spring-cloud-dubbo-provider-user
main:
# Spring Boot2.1及更高的版本需要设定
allow-bean-definition-overriding: true
cloud:
nacos:
# Nacos 服务发现与注册配置
discovery:
server-addr: 127.0.0.1:8848
服务实现类上配置@DubboService暴露服务
@DubboService
public class UserServiceImpl implements UserService
@Autowired
private UserMapper userMapper;
@Override
public List<User> list()
return userMapper.list();
@Override
public User getById(Integer id)
return userMapper.getById(id);
2. consumer端配置
引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
application.yml
dubbo:
cloud:
# 指定需要订阅的服务提供方,默认值*,会订阅所有服务,不建议使用
subscribed-services: spring-cloud-dubbo-provider-user
# application:
# name: $spring.application.name
protocol:
# dubbo 协议
name: dubbo
# dubbo 协议端口( -1 表示自增端口,从 20880 开始)
port: -1
# registry:
# #挂载到 Spring Cloud 注册中心 高版本可选
# address: spring-cloud://127.0.0.1:8848
spring:
application:
name: spring-cloud-dubbo-consumer-user
main:
# Spring Boot2.1及更高的版本需要设定
allow-bean-definition-overriding: true
cloud:
nacos:
# Nacos 服务发现与注册配置
discovery:
server-addr: 127.0.0.1:8848
当应用使用属性dubbo.cloud.subscribed-services
为默认值时,日志中将会输出警告:
服务消费方通过@DubboReference引入服务
@RestController
@RequestMapping("/user")
public class UserConstroller
@DubboReference
private UserService userService;
@RequestMapping("/info/id")
public User info(@PathVariable("id") Integer id)
return userService.getById(id);
@RequestMapping("/list")
public List<User> list()
return userService.list();
3. 从Open Feign迁移到Dubbo
Dubbo Spring Cloud 提供了方案,即 @DubboTransported
注解,支持在类,方法,属性上使用。能够帮助服务消费端的 Spring Cloud Open Feign 接口以及 @LoadBalanced RestTemplate Bean 底层走 Dubbo 调用(可切换 Dubbo 支持的协议),而服务提供方则只需在原有 @RestController 类上追加 Dubbo @Servce 注解(需要抽取接口)即可,换言之,在不调整 Feign 接口以及 RestTemplate URL 的前提下,实现无缝迁移。
修改服务提供者
@DubboService
@Slf4j
@RestController
@RequestMapping("/user")
public class UserServiceImpl implements UserService
@Autowired
private UserMapper userMapper;
@Override
@RequestMapping("/list")
public List<User> list()
log.info("查询user列表");
return userMapper.list();
@Override
@RequestMapping("/getById/id")
public User getById(@PathVariable("id") Integer id)
return userMapper.getById(id);
服务消费端引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
feign的实现,启动类上添加@EnableFeignClients
@SpringBootApplication
@EnableFeignClients
public class SpringCloudDubboConsumerUserFeignApplication
public static void main(String[] args)
SpringApplication.run(SpringCloudDubboConsumerUserFeignApplication.class, args);
feign接口添加 @DubboTransported
注解
@FeignClient(value = "spring-cloud-dubbo-provider-user-feign",path = "/user")
@DubboTransported(protocol = "dubbo")
public interface UserDubboFeignService
@RequestMapping("/list")
public List<User> list();
@RequestMapping("/getById/id")
public User getById(@PathVariable("id") Integer id);
@FeignClient(value = "spring-cloud-dubbo-provider-user-feign",path = "/user")
public interface UserFeignService
@RequestMapping("/list")
public List<User> list();
@RequestMapping("/getById/id")
public User getById(@PathVariable("id") Integer id);
调用对象添加@DubboTransported
注解
@RestController
@RequestMapping("/user")
public class UserConstroller
@DubboReference
private UserService userService;
@RequestMapping("/info/id")
public User info(@PathVariable("id") Integer id)
return userService.getById(id);
@Autowired
@DubboTransported
private UserFeignService userFeignService;
@RequestMapping("/list")
public List<User> list()
return userFeignService.list();
@Autowired
private UserDubboFeignService userDubboFeignService;
@RequestMapping("/list2")
public List<User> list2()
return userDubboFeignService.list();
@Autowired
private RestTemplate restTemplate;
@Bean
@LoadBalanced
@DubboTransported
public RestTemplate restTemplate()
return new RestTemplate();
@RequestMapping("/list3")
public List<User> list3()
String url = "http://spring-cloud-dubbo-provider-user-feign/user/list";
return restTemplate.getForObject(url, List.class);
以上是关于微服务SpringCloudAlibaba配置汇总的主要内容,如果未能解决你的问题,请参考以下文章
SpringCloudAlibaba微服务组件Nacos配置中心