Spring Cloud与微服务之订单微服务

小灰灰 2022-04-05 15:18 350阅读 0赞

### 文章目录 ###

*  订单微服务
 *  springcloud-goods-order
 *   *  springcloud-goods-order项目结构
     *  springcloud-goods-order源码
 *  结果分析
 *   *  访问springcloud-goods-order

# 订单微服务 #

订单微服务的主要作用是从商品微服务中获取与订单相关的商品条目信息，进而完成对于订单数据的请求操作。

由于这里采用的是分布式的微服务架构，因而订单微服务中的商品条目信息是从两个商品微服务中以某种规则进行访问的，而这里，我们采用的是使用订单微服务以随机的方式访问不同的商品微服务。

# springcloud-goods-order #

## springcloud-goods-order项目结构 ##

![在这里插入图片描述][20181213093058111.png]

## springcloud-goods-order源码 ##

OrderController源码：

package com.lyc.controller;
    
    import com.lyc.order.entity.Order;
    import com.lyc.service.OrderService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class OrderController { 
    
        @Autowired
        private OrderService orderService;
    
        @GetMapping("order/{orderId}")
        public Order queryOrderById(@PathVariable("orderId") String orderId){ 
            return this.orderService.queryOrderById(orderId);
        }
    
    }

ItemFeignClient源码：

package com.lyc.feign;
    
    import com.lyc.item.entity.Item;
    import org.springframework.cloud.netflix.feign.FeignClient;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    
    @FeignClient(value = "springcloud-goods-item")    //声明这是一个Feign的客户端
    public interface ItemFeignClient { 
    
        @GetMapping("/item/{id}")
        public Item queryItemById(@PathVariable("id") Long id);
    
    }

OrderProperties源码：

package com.lyc.properties;
    
    import com.lyc.order.entity.ItemProperties;
    import lombok.*;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.stereotype.Component;
    
    @Getter
    @Setter
    @Builder
    @ToString
    @NoArgsConstructor
    @AllArgsConstructor
    @Component
    @ConfigurationProperties(prefix = "springcloud-goods")   //以springcloud-goods开头的配置被匹配到
    public class OrderProperties { 
    
        private ItemProperties item = new ItemProperties();
    
    }

ItemService源码：

package com.lyc.service;
    
    import com.lyc.feign.ItemFeignClient;
    import com.lyc.item.entity.Item;
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    @Service
    public class ItemService { 
    
        @Autowired
        private ItemFeignClient itemFeignClient;
    
        /** * 调用商品的务提供的接口进行查询数据 * @param id * @return */
        @HystrixCommand(fallbackMethod = "queryItemByIdFallbackMethod")  //进行容错处理
        public Item queryItemById(Long id){ 
            return this.itemFeignClient.queryItemById(id);
        }
    
        public Item queryItemByIdFallbackMethod(Long id){     //请求失败执行的方法
            return new Item(id,"查询商品信息出错！",null,null,null);
        }
    
    }

OrderService源码：

package com.lyc.service;
    
    import com.lyc.item.entity.Item;
    import com.lyc.order.dao.OrderDao;
    import com.lyc.order.entity.Order;
    import com.lyc.order.entity.OrderDetail;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import java.util.*;
    
    @Service
    public class OrderService { 
    
        @Autowired
        private ItemService itemService;
        @Autowired
        private OrderDao orderDao;
    
        public Order queryOrderById(String orderId){ 
            Order order  = orderDao.queryOrderById(orderId);
            if(null == order){ 
                return null;
            }
            List<OrderDetail> orderDetails = order.getOrderDetails();
            for(OrderDetail orderDetail : orderDetails){ 
                //通过商品微服务查询商品数据
                Item item = this.itemService.queryItemById(orderDetail.getItem().getId());
                if(null == item){ 
                    continue;
                }
                orderDetail.setItem(item);
            }
            return order;
        }
    }

OrderApplication源码：

package com.lyc;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    import org.springframework.cloud.netflix.feign.EnableFeignClients;
    import org.springframework.cloud.netflix.hystrix.EnableHystrix;
    import org.springframework.context.annotation.Bean;
    import org.springframework.http.client.OkHttp3ClientHttpRequestFactory;
    import org.springframework.web.client.RestTemplate;
    
    @EnableHystrix
    @EnableFeignClients
    @EnableEurekaServer   //申明这是一个Eureka服务
    @SpringBootApplication
    public class OrderApplication { 
    
        @Bean   //向Spring微服务中定义RestTemplate对象
        @LoadBalanced    //开启负载均衡
        public RestTemplate restTemplate(){ 
            return new RestTemplate(new OkHttp3ClientHttpRequestFactory());
        }
    
        public static void main(String[] args){ 
            SpringApplication.run(OrderApplication.class,args);
        }
    
    }

application.yml源码：

server:
      port: 8082  #订单端口
    
    spring:
      application:
        name: springcloud-goods-order  #指定服务名
    
    springcloud-goods:
      item:
        url: http://127.0.0.1:8081/item/
    
    eureka:
      client:
        registerWithEureka: false #是否将自己注册到Eureka服务中，默认为true
        fetchRegistry: true #是否从Eureka中获取注册信息，默认为true
        serviceUrl: #Eureka客户端与Eureka服务端进行交互的地址
          defaultZone: http://root:root123@127.0.0.1:6868/eureka/
    
    springcloud-goods-item:   # 设置成随机访问
      ribbon:
        NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

ItemServiceTest源码：

package com.lyc.service;
    
    import com.lyc.OrderApplication;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.cloud.client.ServiceInstance;
    import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
    import org.springframework.context.annotation.Import;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest
    @Import(OrderApplication.class)
    public class ItemServiceTest { 
    
        @Autowired
        private LoadBalancerClient loadBalancerClient;
    
        @Test
        public void test(){ 
            String serviceId = "springcloud-goods-item";
            for (int i = 0; i < 100; i++){ 
                ServiceInstance serviceInstance = this.loadBalancerClient.choose(serviceId);
                System.out.println("第" + (i + 1) + "次：" + serviceInstance.getHost() + ": " + serviceInstance.getPort());
            }
        }
    }

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>springcloud-parent</artifactId>
            <groupId>com.lyc</groupId>
            <version>1.0-RELEASE</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>springcloud-goods-order</artifactId>
        <packaging>jar</packaging>
        <name>SpringCloud微服务：：商品订单服务</name>
        <url>http://www.example.com</url>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        </properties>
    
        
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Dalston.SR3</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>com.squareup.okhttp3</groupId>
                <artifactId>okhttp</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka-server</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-feign</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-hystrix</artifactId>
            </dependency>
            <dependency>
                <groupId>com.lyc</groupId>
                <artifactId>springcloud-goods-db</artifactId>
            </dependency>
        </dependencies>
    
        <build>
            <finalName>${project.artifactId}</finalName>
        </build>
    
    </project>

# 结果分析 #

## 访问springcloud-goods-order ##

启动项目，在浏览器中输入下面的地址访问订单微服务：

http://127.0.0.1:8082/order/13135351635

其显示的结果如下：

{
        "orderId": "13135351635",
        "userId": 1,
        "createDate": 1544665690703,
        "updateDate": 1544665690703,
        "orderDetails": [
            {
                "orderId": "13135351635",
                "item": {
                    "id": 1,
                    "title": "商品标题1",
                    "pic": "http://图片1",
                    "desc": "商品描述1",
                    "price": 1000
                }
            },
            {
                "orderId": "13135351635",
                "item": {
                    "id": 2,
                    "title": "商品标题2",
                    "pic": "http://图片2",
                    "desc": "商品描述2",
                    "price": 2000
                }
            }
        ]
    }

当我们重复刷新上面的访问地址时，我们可以看到，在商品微服务springcloud-goods-item的控制台中输出下面的信息：

2018-12-13 09:48:31.826  INFO 7876 --- [nio-8081-exec-4] com.lyc.controller.ItemController        : ----------springcloud-goods-item中的方法----------
    2018-12-13 09:48:43.632  INFO 7876 --- [nio-8081-exec-5] com.lyc.controller.ItemController        : ----------springcloud-goods-item中的方法----------
    2018-12-13 09:48:45.164  INFO 7876 --- [nio-8081-exec-6] com.lyc.controller.ItemController        : ----------springcloud-goods-item中的方法----------
    2018-12-13 09:48:45.621  INFO 7876 --- [nio-8081-exec-7] com.lyc.controller.ItemController        : ----------springcloud-goods-item中的方法----------
    2018-12-13 09:48:45.626  INFO 7876 --- [nio-8081-exec-8] com.lyc.controller.ItemController        : ----------springcloud-goods-item中的方法----------
    2018-12-13 09:48:46.077  INFO 7876 --- [nio-8081-exec-9] com.lyc.controller.ItemController        : ----------springcloud-goods-item中的方法----------
    2018-12-13 09:48:47.390  INFO 7876 --- [a-EvictionTimer]

同时，我们在商品微服务springcloud-goods-item2的控制台中也可以看到类似的信息：

2018-12-13 09:48:43.747  INFO 25508 --- [nio-8083-exec-2] com.lyc.controller.ItemController        : ----------springcloud-goods-item2中的方法----------
    2018-12-13 09:48:44.527  INFO 25508 --- [nio-8083-exec-1] com.lyc.controller.ItemController        : ----------springcloud-goods-item2中的方法----------
    2018-12-13 09:48:44.534  INFO 25508 --- [nio-8083-exec-3] com.lyc.controller.ItemController        : ----------springcloud-goods-item2中的方法----------
    2018-12-13 09:48:45.157  INFO 25508 --- [nio-8083-exec-4] com.lyc.controller.ItemController        : ----------springcloud-goods-item2中的方法----------
    2018-12-13 09:48:46.072  INFO 25508 --- [nio-8083-exec-5] com.lyc.controller.ItemController        : ----------springcloud-goods-item2中的方法----------

这说明，订单微服务springcloud-goods-order是以随机的方式在访问商品微服务springcloud-goods-item与商品微服务springcloud-goods-item2的。

[20181213093058111.png]: /images/20220405/7ff32b482a0c463aad3cbaa0a67b56cb.png