spring-cloud-hoxton: A Java repository from Sugariscool

Spring Cloud (H版) 项目搭建模板

搭建微服务项目，用于个人的环境搭建提供代码示例，粘贴即可用。

1. 项目结构

cloud-api-commons: 公共模块，封装一些通用的类和工具
cloud-consumer-order80: 服务消费者（模拟订单模块）端口:80
cloud-consumer-order80-zk: 服务消费者（模拟订单模块）,zookeeper作为服务注册中心端口:80
cloud-consumer-order80-consul: 服务消费者（模拟订单模块）,consul作为服务注册中心端口:80
cloud-consumer-order80-openfeign: 服务消费者（模拟订单模块）,使用OpenFeign调用服务端口:80
cloud-provider-payment8001: 服务提供者（模拟支付模块）端口:8001
cloud-provider-payment8002: 服务提供者（模拟支付模块）端口:8002
cloud-provider-payment8003-zk: 服务提供者（模拟支付模块）,zookeeper作为服务注册中心端口:8003
cloud-provider-payment8004-consul: 服务提供者（模拟支付模块）,consul 服务注册中心端口:8004
cloud-eureka-server7001: 服务注册中心（eureka）端口: 7001
cloud-eureka-server7002: 服务注册中心（eureka）端口: 7002
cloud-eureka-server7003: 服务注册中心（eureka）端口: 7003

2. 搭建教程

1. 使用Eureka作为注册中心

1. 服务端

引入依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

application.yml 配置

eureka:
  instance:
    hostname: localhost
  client:
    register-with-eureka: false
    fetch-registry: false
    service-url:
      defaultZone: http://${server.port}:${server.port}/eureka/

启动类添加注解

@SpringBootApplication
@EnableEurekaServer
public class Eureka7001Application {
    public static void main(String[] args) {
        SpringApplication.run(Eureka7001Application.class,args);
    }
}

2. 客户端

引入依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

application.yml配置

eureka:
  instance:
    instance-id: cloud-payment-service-8001 # 修改实例的别名
    prefer-ip-address: true # 显示IP
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka #注册服务到eureka服务器

启动类添加注解

@SpringBootApplication
@EnableEurekaClient
@MapperScan(basePackages = {"com.coderman.payment.mapper"})
public class Payment8001Application {
    public static void main(String[] args) {
        SpringApplication.run(Payment8001Application.class,args);
    }
}

2. 使用Eureka集群

1. 配置host文件

# 配置eureka集群
127.0.0.1 server1.com
127.0.0.1 server2.com
127.0.0.1 server3.com

2. 服务端

修改application.yml

server:
  port: 7001
eureka:
  instance:
    hostname: server1.com
  client:
    register-with-eureka: false
    fetch-registry: false
    service-url:
      defaultZone: http://server2.com:7002/eureka/,http://server3.com:7003/eureka/

3. 客户端

修改application.yml

#eureka客户端的配置
eureka:
  instance:
    instance-id: cloud-payment-service-8001 # 修改实例的别名
    prefer-ip-address: true # 显示IP
  client:
    service-url:
      defaultZone: http://server1.com:7001/eureka/,http://server2.com:7002/eureka/,http://server3.com:7003/eureka/ #注册服务到eureka服务器

3. 使用Ribbon实现负载均衡

因为引入的eureka客户端依赖里包含了Ribbon的依赖，因此不需要到入任何的依赖,使用起来也非常简单只需要两步即可。

修改Rest服务调用的地址,对应Eureka服务列表的服务名称。

private final String REST_URL = "http://CLOUD-PAYMENT-SERVICE";

开启RestTemplate负载均衡功能

 @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
}

如何替换Ribbon的负载均衡规则

1.全局替换：向IOC容器中注入一个指定的规则，此后无论调用哪个服务，都使用这套规则。

@Bean
public IRule rule(){
    return new RandomRule();
}

2.局部替换：配置调用指定的服务，使用指定的负载均衡规则。第一，我们需要向IOC容器中注入规则（注意该配置）一定要放在启动类外面的包结构，而后在进行规则配置。

@Configuration
public class MyRule {
    @Bean
    public IRule rule(){
        return new RandomRule();
    }
}

@Configuration
//对于CLOUD-PAYMENT-SERVICE，使用复制均衡的规则为: MyRule
@RibbonClient(name = "CLOUD-PAYMENT-SERVICE",configuration = {MyRule.class})
public class RestConfig {
}

3.基于配置的替换: 在application.yml文件中进行配置。

CLOUD-PAYMENT-SERVICE:
              ribbon:
               NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

4. 使用Zookeeper作为注册中心

安装zookeeper服务端,启动本地的zookeeper服务器即可。

1. 客户端

引入依赖

 <!--SpringBoot整合Zookeeper客户端-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
    <!--先排除自带的zookeeper3.5.3-->
   <exclusions>
       <exclusion>
           <groupId>org.apache.zookeeper</groupId>
           <artifactId>zookeeper</artifactId>
       </exclusion>
   </exclusions>
</dependency>
<!--添加zookeeper3.4.10版本-->
<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.4.10</version>
    <exclusions>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
        </exclusion>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
        <exclusion>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
        </exclusion>
    </exclusions>
</dependency>

配置application.yml

spring:
   cloud:
    zookeeper:
      # 默认localhost:2181
      connect-string: localhost:2181

配置启动类

@SpringBootApplication
@EnableDiscoveryClient
@MapperScan(basePackages = {"com.coderman.payment.mapper"})
public class Payment8003Application {
    public static void main(String[] args) {
        SpringApplication.run(Payment8003Application.class,args);
    }
}

5. 使用Consul作为注册中心

安装consul服务端,启动本地的consul服务器即可。

1. 客户端

引入依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>

配置application.yml

 #配置consul客户端
spring:   
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        service-name: ${spring.application.name}
        heartbeat:
          enabled: true

配置启动类

@SpringBootApplication
@EnableDiscoveryClient
@MapperScan(basePackages = {"com.coderman.payment.mapper"})
public class Payment8004ConsulApplication {
    public static void main(String[] args) {
        SpringApplication.run(Payment8004ConsulApplication.class,args);
    }
}

6. 使用OpenFeign调用服务。

OpenFeign的声明式方式定义Web服务客户端；其次还更进一步，通过集成Ribbon或Eureka实现负载均衡的HTTP客户端。

1. 服务的调用

引入依赖

 <!--openfeign-->
<dependency>
    <groupId>com.coderman</groupId>
    <artifactId>cloud-api-commons</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>

配置启动类

@EnableEurekaClient
@EnableFeignClients //开启Feign
@SpringBootApplication
@MapperScan(basePackages = {"com.coderman.order.mapper"})
public class Order80FeignApplication {

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

编写对应接口的服务调用类

@Component
@FeignClient(value = "CLOUD-PAYMENT-SERVICE")
public interface PaymentFeignService {

    @GetMapping(value = "/provider/payment/create/{orderId}/{money}")
    JsonData create(@PathVariable(value = "orderId") String orderId, @PathVariable(value = "money") BigDecimal money);
}

修改调用时的超时时间

#配置feign客户端调用微服务的超时时间(OpenFeign默认支持Ribbon)
feign:
  client:
    config:
      default:
        #建立连接所用的时间，适用于网络状况正常的情况下，两端连接所需要的时间
        ConnectTimeOut: 6000
        #指建立连接后从服务端读取到可用资源所用的时间
        ReadTimeOut: 6000

Sugariscool/spring-cloud-hoxton

Spring Cloud (H版) 项目搭建模板

1. 项目结构

2. 搭建教程

1. 使用Eureka作为注册中心

1. 服务端

2. 客户端

2. 使用Eureka集群

1. 配置host文件

2. 服务端

3. 客户端

3. 使用Ribbon实现负载均衡

4. 使用Zookeeper作为注册中心

1. 客户端

5. 使用Consul作为注册中心

1. 客户端

6. 使用OpenFeign调用服务。

1. 服务的调用