SpringCloud(一)消费者服务提供者的构造

Java架构师编程 2019-05-21

170

背景介绍：以Spring boot 2.0.5， Spring cloud Finchley.RC2 版本为基础，构建笔记，全套系列已基本完成，示例代码，根据过程走完，是可执行的，计划每天更新一条，欢迎大家持续关注。

学习过程，参考周立大神的《Spring Cloud 与Docker 微服务架构实战》一书。本系列博文内容开源，但转载请注明出处.

1.构造一个 maven 父工程 microservice-demo，删除src等，仅保留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">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.microservice</groupId>
    <artifactId>microservice-demo</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>

</project>

2.在 microservice-demo 下，新建module ：microservice-common，用于存放公共实体，工具类等。 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">
    <modelVersion>4.0.0</modelVersion>
    <version>0.0.1-SNAPSHOT</version>
    <groupId>com.microservice.common</groupId>
    <artifactId>microservice-common</artifactId>
    <packaging>jar</packaging>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.22</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>
</project>

新建一个User bean

package com.common.entity;

import java.math.BigDecimal;

import lombok.Getter;
import lombok.Setter;

/**
 * Created on 2019-04-23
 * @author fenghongyu
 */
@Setter
@Getter
public class User {
    private Long userId;
    private String userName;
    private String name;
    private Integer age;
    private BigDecimal balance;

    public User(){}

    public User(Long userId, String userName, String name, Integer age, BigDecimal balance){
        this.userId = userId;
        this.userName = userName;
        this.name = name;
        this.age = age;
        this.balance = balance;
    }
}

2.在 microservice-demo 下，新建Spring boot 的module ：microservice-provider-user

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">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.5.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>
	<groupId>com.provider.user</groupId>
	<artifactId>microservice-provider-user</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<name>microservice-provider-user</name>
	<description>Demo project for Spring Boot</description>

	<properties>
		<java.version>1.8</java.version>
		<spring-cloud.version>Finchley.RC2</spring-cloud.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-actuator</artifactId>
		</dependency>

		<!-- microservice-demo dependency begin-->
		<!-- 自建的公共module，用于存放实体等通用对象 -->
		<dependency>
			<groupId>com.microservice.common</groupId>
			<artifactId>microservice-common</artifactId>
			<version>0.0.1-SNAPSHOT</version>
		</dependency>
		<!-- microservice-demo dependency end-->

        <!-- 用于代码简写，可自行百度了解用法。 与Spring Cloud 无关-->
		<dependency>
			<groupId>org.projectlombok</groupId>
			<artifactId>lombok</artifactId>
			<optional>true</optional>
		</dependency>

	</dependencies>

	<dependencyManagement>
		<dependencies>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>${spring-cloud.version}</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
		</dependencies>
	</dependencyManagement>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
	</build>

</project>

构建一个UserController

package com.provider.user.controller;

import java.math.BigDecimal;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.common.entity.User;

/**
 * Created on 2019-04-23
 * @author fenghongyu
 */
@RestController
@RequestMapping("/user")
public class UserController {

    @GetMapping("/{userId}")
    public User findById(@PathVariable Long userId) {
        return getUser(userId);
    }

    private User getUser(Long userId) {
        if(userId == 1) {
            return new User(1L, "tangyuan", "feng", 26, new BigDecimal(100));
        } else if(userId == 2) {
            return new User(2L, "xiao", "wang", 16, new BigDecimal(80));
        } else {
            return new User(3L, "test", "de", 6, new BigDecimal(60));
        }
    }
}

Spring boot 启动main 方法为：

package com.provider.user;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class MicroserviceProviderUserApplication {

	public static void main(String[] args) {
		SpringApplication.run(MicroserviceProviderUserApplication.class, args);
	}
}

在application.properties 中，设置服务端口号

server.port=8000

在 MicroserviceProviderUserApplication 启动main 方法，即可启动服务，访问

http://127.0.0.1:8000/user/1

可得到结果：

{"userId":1,"userName":"tangyuan","name":"feng","age":26,"balance":100}

同理，构建服务消费者：microservice-consumer-movie 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">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.0.5.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>
	<groupId>com.consumer.movie</groupId>
	<artifactId>microservice-consumer-movie</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<name>microservice-consumer-movie</name>
	<description>microservice-consumer-movie</description>

	<properties>
		<java.version>1.8</java.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>org.projectlombok</groupId>
			<artifactId>lombok</artifactId>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>

		<!-- microservice-demo dependency begin-->
		<dependency>
			<groupId>com.microservice.common</groupId>
			<artifactId>microservice-common</artifactId>
			<version>0.0.1-SNAPSHOT</version>
		</dependency>
		<!-- microservice-demo dependency end-->

		<!-- HttpClient -->
		<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpclient</artifactId>
		</dependency>

	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
	</build>

</project>

构建 RestTemplate 配置新建类 Config，注入RestTemplate，用于发送请求

package com.consumer.movie.microserviceconsumermovie.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.client.ClientHttpRequestFactory;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;

/**
 * Created on 2019-04-26
 * @author fenghongyu
 */
@Configuration
public class Config {

    /**
     * 返回RestTemplate
     * @param factory
     * @return
     */
    @Bean
    public RestTemplate restTemplate(ClientHttpRequestFactory factory){
        return new RestTemplate(factory);
    }

    /**
     * ClientHttpRequestFactory接口的第一种实现方式，即：
     * SimpleClientHttpRequestFactory：底层使用java.net包提供的方式创建Http连接请求
     * @return
     */
    @Bean
    public SimpleClientHttpRequestFactory simpleClientHttpRequestFactory(){
        SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
        requestFactory.setReadTimeout(5000);
        requestFactory.setConnectTimeout(5000);
        return requestFactory;
    }
}

构造MovieController

package com.consumer.movie.microserviceconsumermovie.controller;


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.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import com.common.entity.User;

/**
 * Created on 2019-04-23
 * @author fenghongyu
 */
@RestController
@RequestMapping("/movie")
public class MovieController {

    @Autowired
    private RestTemplate restTemplate;

    @ResponseBody
    @GetMapping("/user/{userId}")
    public User queryUser(@PathVariable Long userId){
        String url = "http://127.0.0.1:8000/user/" + userId;
        //这里通过restTemplate 直连 url。
        return restTemplate.getForObject(url, User.class);
    }
}

在 application.properties 中，设置服务的端口号

server.port=8010

在 MicroserviceConsumerMovieApplication 中，启动main 方法，即可服务。

package com.consumer.movie.microserviceconsumermovie;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class MicroserviceConsumerMovieApplication {

	public static void main(String[] args) {
		SpringApplication.run(MicroserviceConsumerMovieApplication.class, args);
	}
}

访问地址

http://127.0.0.1:8010/movie/user/1

会得到

{"userId":1,"userName":"tangyuan","name":"feng","age":26,"balance":100}

这里，数据是来自 MicroserviceProviderUserApplication 的服务地址。

数据库

文章转载自Java架构师编程，如果涉嫌侵权，请发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。

SpringCloud(一)消费者 服务提供者 的构造

评论

SpringCloud(一)消费者服务提供者的构造