SpringCloud

这两年可以说微服务是热词，也是新领域，学习的成本也较高，基础东西太多比如什么Dubbo，zookeeper，Springboot等等。Dubbo也是实现服务治理又是阿里出的一套开源RPC框架，但是SpringCloud出现后便立即热火朝天，当然阿里也加入了SpringCloud的孵化。

什么是微服务，分布式？

分布式：不同的模块部署在不同的服务器上，可以更好的解决网站高并发。

微服务：架构设计概念,各服务间隔离（分布式也是隔离）,自治（分布式依赖整体组合）其它特性(单一职责,边界,异步通信,独立部署)是分布式概念的跟严格执行 SOA到微服务架构的演进过程。简单的说把项目拆分成各各模块，用注册中心的方式把服务都链接在一起

服务提供者与消费关系

服务提供者：提供服务被人调用

消费者：调用服务

今天我们说下SpringCloud的Eureka注册中心

官方：

Eureka是Netflix开发的服务发现框架，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的。SpringCloud将它集成在其子项目spring-cloud-netflix中，以实现SpringCloud的服务发现功能。

Eureka包含两个组件：Eureka Server和Eureka Client。
Eureka Server提供服务注册服务，各个节点启动后，会在Eureka Server中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。
Eureka Client是一个java客户端，用于简化与Eureka Server的交互，客户端同时也就是一个内置的、使用轮询(round-robin)负载算法的负载均衡器。
在应用启动后，将会向Eureka Server发送心跳,默认周期为30秒，如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)。
Eureka Server之间通过复制的方式完成数据的同步，Eureka还提供了客户端缓存机制，即使所有的Eureka Server都挂掉，客户端依然可以利用缓存中的信息消费其他服务的API。综上，Eureka通过心跳检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性。
环境搭建:
本次环境用Gradle+IDEA
1.先搭建注册中心

2.主项目Gradle

group 'com.wang'
version '1.0-SNAPSHOT'

apply plugin: 'java'

sourceCompatibility = 1.8

buildscript {
ext {//定义一个变量，统一规定springboot的版本
springBootVersion = '1.5.10.RELEASE'
}
repositories {
maven { url 'http://maven.aliyun.com/nexus/content/groups/public/' }
jcenter()
mavenCentral()
//Spring repo
maven { url "http://repo.spring.io/snapshot" }
maven { url "http://repo.spring.io/milestone" }
maven { url "http://repo.spring.io/release" }
maven { url 'http://repo.spring.io/plugins-snapshot' }
}

dependencies {//用来打包
    classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
}

}
//设定当前所有的项目的配置
allprojects {
group 'com.ssx'
version '1.0-SNAPSHOT'

ext {
    springCloudVersion = 'Edgware.SR2'
}

repositories {
    maven { url 'http://maven.aliyun.com/nexus/content/groups/public/' }
    jcenter()
    mavenCentral()
    //Spring repo
    maven { url "http://repo.spring.io/snapshot" }
    maven { url "http://repo.spring.io/milestone" }
    maven { url "http://repo.spring.io/release" }
    maven { url 'http://repo.spring.io/plugins-snapshot' }
}

}
//设定当前模块项目中的配置
subprojects {
apply plugin: 'java'
apply plugin: 'idea'
apply plugin: 'spring-boot'

dependencies {
    //使用springboot-web组件，但是排除tomcat组件
    compile ('org.springframework.boot:spring-boot-starter-web'){
        exclude module:"spring-boot-starter-tomcat"
    }
    //使用undertow作为应用服务,作为servlet容器
    compile 'org.springframework.boot:spring-boot-starter-undertow'
    //使用健康检查组件
    compile 'org.springframework.boot:spring-boot-starter-actuator'
    testCompile(
            group: 'junit', name: 'junit', version: '4.12'
    )
}

dependencyManagement {
    imports {
        //加上此配置后，如果需要引用springcloud的组件，就不需要再提供版本信息
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
    }
}

}

3.注册中心启动类

package org.gw.reigster.conter;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

/**

@DATA 2019-02-27 19:56
@Author 张国伟 WeChat:17630376104
@Description TODO
*/

@EnableEurekaServer #这个是表示这个项目作为euraka注册中心
@SpringBootApplication
public class ReigsterConterProvider {
public static void main(String[] args) {
SpringApplication.run(ReigsterConterProvider.class,args);
}
}

4.注册中心yml

server:
port: 8888
spring:
application:
name: reigster-conter
eureka:
client:
register-with-eureka: false #启动时不注册本来就是注册中心表示自己是注册中心
fetch-registry: false #不向注册中心拉取数据
server:
enable-self-preservation: false #关闭自我保护测试环境用生产环境一般不用

5.启动注册中心访问8888

这个为Eureka的信息页面可以看到这个时候 Instances currently registered with Eureka里面是No instances available 也就是这个时候还没有服务注册进来，下面我们写注册方

这个模块为solr

package org.gw.solr;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

/**

@DATA 2019-02-27 20:38
@Author 张国伟 WeChat:17630376104
@Description TODO
*/

@EnableEurekaClient #这里为Eureka客户端也就是服务
@SpringBootApplication
public class ProjectSolrProvider {
public static void main(String[] args) {
SpringApplication.run(ProjectSolrProvider.class, args);
}
}

yml

server:
port: 10002
spring:
application:
name: project-solr
eureka:
client:
service-url:
defaultZone: http://localhost:8888/eureka/
instance:
prefer-ip-address: true

这时候我们启动这个服务

这个时候可以看到有个服务已经注册进来

这个就是实现了注册也发现，那我们紧接这如何实现服务与服务之间调用呢？我现在想project-shopping-mall模块的controller调用solr的controller如何实现呢

package org.gw.shopping.mall;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

/**

@DATA 2019-02-27 20:24
@Author 张国伟 WeChat:17630376104
@Description TODO
*/
@EnableEurekaClient
@SpringBootApplication
public class ShoppingMallProvider {
@LoadBalanced
@Bean
public RestTemplate resultTemplate() {
RestTemplate template = new RestTemplate();
return template;
}

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

RestTemplate表示网络请求在启动类里把他实例

package org.gw.shopping.mall.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

/**

@DATA 2019-02-27 20:45
@Author 张国伟 WeChat:17630376104
@Description TODO
*/
@Controller
public class ShopController {
@Autowired
private RestTemplate restTemplate;

@RequestMapping("/toIndex")
public String toIndex(Model model) {
String msg = restTemplate.getForEntity("http://PROJECT-SOLR/solrSearc", String.class).getBody();
model.addAttribute("msg", msg);
return "index";
}
}

这个为调用solr的controller根据名字调用

package org.gw.solr.controller;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**

@DATA 2019-02-27 20:40
@Author 张国伟 WeChat:17630376104
@Description TODO
*/
@RestController
public class SolrSearchController {

@RequestMapping("/solrSearc")
public String solrSearc(){
return "从solr查询到数据";
}
}

意思就是说我在shop里调用solr的controller他会返回一个从solr查询到数据

我们来尝试下

shop模块里有thymeleaf模板展示数据

<!DOCTYPE html>

<meta charset="UTF-8"/>
<title>Title</title>

欢迎进入商城从solr微服务中查到的数据::::

可以看到已经成功拿到数据

到这里，我们已经实现服务的注册与发现，下章说链路跟踪，有问题请及时评论。

源之站

dynamic

Linux 的文件类型

SpringCloud

dynamic

Linux 的文件类型

相关推荐