服务远程调用
/**
* 创建RestTemplate并注入Spring容器
* @return
*/
@Bean
public RestTemplate restTemplate(){
return new RestTemplate();
}
@Autowired
private RestTemplate restTemplate;
public Order queryOrderById(Long orderId) {
// 1.查询订单
Order order = orderMapper.findById(orderId);
// 2.利用RestTemplate发起HTTP请求，查询用户
// 2.1.url路径
String url="http://localhost:8081/user/"+order.getUserId();
// 2.2.发送HTTP请求，实现远程调用
User user = restTemplate.getForObject(url, User.class);
// 3.封装user到order对象
order.setUser(user);
// 4.返回
return order;
}
搭建eureka服务
第一步：注入依赖
第二步：使用@EnableEurekaServer @EnableEurekaServer @SpringBootApplication public class EurekaApplication { public static void main(String[] args) { SpringApplication.run(EurekaApplication.class,args); } } 第三步：application.yml文件 server: port: 10086 # 服务端口 spring: application: name: eurekaserver # eureka的服务名称 eureka: client: service-url: # eureka的地址信息 defaultZone: http://127.0.0.1:10086/eureka 解释说明： eureka-server自己也是个微服务，也需要服务名称，而且还需要配置eureka的地址（疑问：我自己就是eureka，为什么还要配置地址信息）刚才说了eureka-server自己就是微服务，所以eureka-server在启动的时候自己也注册到eureka上（这是为了将来eureka集群之间通信去用的，比方说我启动2个或3个eureka，将来3个eureka之间会互相做注册，那么这样他们就可以做数据交流）上面defaultZone配置的是eureka集群的地址，有多个的话用逗号隔开，因为这里是单机，所以配置的只有自己（重点来了：这里的服务名称和地址信息都是做服务的注册） 服务注册 第一步：项目user-service引入依赖 第二步：配置application.yml文件 spring: application: name: userservice # eureka的服务名称 eureka: client: service-url: # eureka的地址信息 defaultZone: http://127.0.0.1:10086/eureka idea创建多个实例，可以在UserApplication右击出现copy Configuration弹出窗口，环境配置端口点击应用就行了 服务发现（服务注册基础上添加额外2个步骤） 第一步：在RestTemplate上添加@LoadBalanced注解 /** * 创建RestTemplate并注入Spring容器 * @return */ @LoadBalanced @Bean public RestTemplate restTemplate(){ return new RestTemplate(); } 第二步：使用服务名称来代替原来的ip和端口 @Autowired private OrderMapper orderMapper; @Autowired private RestTemplate restTemplate; public Order queryOrderById(Long orderId) { // 1.查询订单 Order order = orderMapper.findById(orderId); // 2.利用RestTemplate发起HTTP请求，查询用户 // 2.1.url路径 // String url="http://localhost:8081/user/"+order.getUserId(); String url="http://userservice/user/"+order.getUserId(); // 2.2.发送HTTP请求，实现远程调用 User user = restTemplate.getForObject(url, User.class); // 3.封装user到order对象 order.setUser(user); // 4.返回 return order; } 负载均衡 一：代码方式：在order-service中的OrderApplication类中，定义一个新的IRule（全局生效） @Bean public IRule randomRule(){ return new RandomRule(); } 二：配置文件方式（局部生效） userservice: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule # 负载均衡规则 饥饿加载 Ribbon默认采用懒加载，即第一次访问时才会去创建LoadBalanceClient，请求时间会很长，而饥饿加载则会在项目启动时创建，降低第一次访问的耗时，通过下面配置饥饿加载 ribbon: eager-load: enabled: true # 开启饥饿加载 clients: # 指定饥饿加载的服务名称 这是一个集合 - userservice Nacos启动命令 -m参数含义是模式model standalone含义是单机启动 startup.cmd -m standalone 服务注册到Nacos 第一步：在cloud-demo父工程中添加spring-cloud-alibaba的管理依赖 第二步：注释掉order-service和user-service中pom.xml文件原有的eureka依赖 第三步：添加nacos的客户端依赖 第四步：修改user-service和order-service中的application.yml文件，注释eureka地址，添加nacos地址 spring: cloud: nacos: server-addr: localhost:8848 # nacos 服务端地址 第五步：启动OrderApplication、UserApplication1、UserApplication2并测试 nacos服务分级存储模型 服务跨集群调用问题 服务调用尽可能选择本地集群的服务，跨集群调用延迟较高，本地集群不可访问时，再去访问其它集群 服务集群属性 修改application.yml，添加以下内容 spring: cloud: nacos: server-addr: localhost:8848 # nacos 服务端地址 discovery: cluster-name: HZ # 配置集群名称，也就是机房位置 HZ杭州 SH上海 一旦停掉本地集群的服务，就会发生跨集群调用，出现警告信息，方便运维人员知道 A cross-cluster call occurs，name = userservice, clusterName = HZ, instance = [Instance{instanceId='192.168.31.69#8083#SH#DEFAULT_GROUP@@userservice', ip='192.168.31.69', port=8083, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='SH', serviceName='DEFAULT_GROUP@@userservice', metadata={preserved.register.source=SPRING_CLOUD}}] 根据权重负载均衡 编辑修改权重 环境隔离 新建命名空间 新增成功会生成一个UUID，需要去idea配置application.yml spring: cloud: nacos: server-addr: localhost:8848 # nacos 服务端地址 discovery: cluster-name: HZ # 配置集群名称，也就是机房位置 HZ杭州 SH上海 namespace: a0c14ea6-b75e-4a73-beb5-94e5f496a744 # dev 开发环境 参考阅读
发表评论