- 业务介绍: 用户模块,订单模块,库存模块,
- 流程如下:
用户付款,需要给用户增加购物积分,
需要客户订单
需要减少库存
也就是说,用户模块接收到信息反馈后,自身进行相应的操作,需要通知订单和库存两个模块也进行相应的操作。
3.Eureka 微服务注册中心的使用
有了注册中心,也知道各个服务在那台机器哪个端口,就需要一个可以替我们向其他服务发送请求的一个工具,而不是我们自己编写代码发送http请求了。这就是Feign.
/**** *@Description:订单实体类 */ @Data @NoArgsConstructor public class Order { private String userId; private Integer count; private String descrpition; } ** * @Description:订单服务 * @Author:wb */ @RestController @RequestMapping("orderService") public class OrderService { @Value("${server.port}") private String port; @RequestMapping(value = "unifiedOrder", method = RequestMethod.POST) public Order unifiedOrder(@RequestBody Order order){ order.setDescrpition("success!this is orderService,my port is " + port); return order; } } /** * @Description:库存服务 * @Author:wb */ @RestController @RequestMapping("stockService") public class StockService { @Value("${server.port}") private String port; @RequestMapping(value = "reduceStock", method = RequestMethod.GET) public String reduceStock(@RequestParam Integer count){ return "this is stockService,my port is " + port + ",count is " + count; } } 创建FeognClient 客户端调用接口 @Component @FeignClient(name = "service-client-stock") public interface OrderAndStockFeignClient { @RequestMapping(value = "stockService/reduceStock", method = RequestMethod.GET) String invokeStock(@RequestParam(value = "count") Integer count); } /** * @Description:用户服务 * @Author:wb */ @RestController @RequestMapping("userService") public class UserService { @Autowired private OrderAndStockFeignClient orderAndStockFeignClient; @RequestMapping(value = "pay", method = RequestMethod.GET) public String unifiedOrder(Integer count){ String invokeStock = orderAndStockFeignClient.invokeStock(count); return invokeStock; } }
@FeignClient(name = "service-client-stock") name 是哪个服务器,value 是uri ,
负载均衡Ribbon的使用。
下面问题来了,如果库服务器部署5在五台机器中,这时候就要用到轮询的机制了,默认的算法是Round Ribbon轮询算法,就是相同application机器一次轮询,不会出现随机现象。
Ribbon有助于控制HTTP,和TCP 的客户端的行为。自动的帮助服务消费去请求。
在Springcloud中Ribbon和Eureka配合使用,Ribbon可以自动从Eureka Server中获取服务地址列表,并基于负载均衡算法,如图展示了Ribbion和Eureka的使用框架
1. LoadBalanced注解:在主程序中RestTemplate添加注解即可实现负载均衡
Bean @LoadBalanced public RestTemplate restTemplate() { RestTemplate restTemplate = new RestTemplate(); return restTemplate;
控制器
return this.restTemplate.getForObject("http://生产者yml的applicationname+接口名", 接受的类型.class);
配置config类
@RibbonClient(value = "指定微服务名",configuration = 指定配置文件.class) config类: @Configuration public class RibbonConfig { @Bean public IRule iRule() { return new RandomRule();//创建一个随机的规则,用于负载均衡时的随机算法 } }
或yml
微服务名: ribbon: NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #默认规则类 WeightedResponseTimeRule
原文链接:https://blog.csdn.net/zajiayouzai/java/article/details/80612729;https://blog.csdn.net/chengqiuming/article/details/80711168l;https://blog.csdn.net/yinzitun7947/article/details/86485163