订单微服务-goods-order-goods-item项目结构-源码：源码

微商网专注微商品牌宣传推广，提供微商最新资讯：

文章目录

订购微服务

订单微服务的主要功能是从商品微服务中获取与订单相关的商品信息，然后完成对订单数据的请求操作。

由于这里采用的是分布式微服务架构，因此订单微服务中的商品入口信息是从两个商品微服务中按照一定的规则来访问的商微价格商微价格青鸾传媒推广，而这里，我们使用订单微服务以不同的方式随机访问不同的商品微服务。

-货物订单 -货物订单项目结构

-货物订单源代码

源代码：

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);
    }
}

源代码：

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);
}

源代码：

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();
}

源代码：

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);
    }
}

源代码：

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;
    }
}

源代码：

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);
    }
}

.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

源代码：

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"?>

    
        springcloud-parent
        com.lyc
        1.0-RELEASE
    
    4.0.0
    springcloud-goods-order
    jar
    SpringCloud微服务：：商品订单服务
    http://www.example.com
    
        UTF-8
    
    
    
        
            
                org.springframework.cloud
                spring-cloud-dependencies
                Dalston.SR3
                pom
                import
            
        
    
    
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            com.squareup.okhttp3
            okhttp
        
        
        
            org.springframework.cloud
            spring-cloud-starter-eureka-server
        
        
        
            org.springframework.boot
            spring-boot-starter-test
        
        
            org.springframework.cloud
            spring-cloud-starter-feign
        
        
            org.springframework.cloud
            spring-cloud-starter-hystrix
        
        
            com.lyc
            springcloud-goods-db
        
    
    
        ${project.artifactId}
    

结果分析 存取-货物-订单

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

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
            }
        }
    ]
}

当我们反复刷新上述访问地址时，可以看到商品-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] 

同时，我们在商品微服务-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中的方法----------

这表明订单微服务 -goods-order 正在以随机方式访问商品微服务 -goods-item 和商品微服务 -goods-item2。

免责声明 ① 本网所刊登文章均来自网络转载;文章观点不代表本网立场,其真实性由作者或稿源方负责 ② 如果您对稿件和图片等有版权及其他争议,请及时与我们联系,我们将核实情况后进行相关删除 ③ 联系邮箱:215858170@qq.com