Eureka注册中心与服务端集群

「爱情、让人受尽委屈。」 2022-05-13 05:42 237阅读 0赞

一、注册中心

1、pom文件

<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>org.crazyit.cloud</groupId>
    	<artifactId>first-server</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    
    	<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.cloud</groupId>
    			<artifactId>spring-cloud-starter-config</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-eureka-server</artifactId>
    		</dependency>
    	</dependencies>
    
    
    </project>

2、启动类

package org.crazyit.cloud;
    
    import java.util.Scanner;
    
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.builder.SpringApplicationBuilder;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    @SpringBootApplication
    @EnableEurekaServer
    public class ServerApp {
    
    	public static void main(String[] args) {
    		new SpringApplicationBuilder(ServerApp.class).web(true).run(args);
    	}
    
    }

3、配置文件(启动一个 注释掉另一个 再切换)

#
    #eureka:
    #  client:
    #    service-url:
    #       #注册中心的地址
    #       defaultZone: http://localhost:8762/eureka/
    #    #不注册到自身
    #    register-with-eureka: false
    #    fetch-registry: false
    #  #关闭保护模式
    #  server:
    #    enable-self-preservation: false
    #spring:
    #  application:
    #    #名称
    #    name: eureka
    #server:
    #  port: 8761
    
    eureka:
      client:
        service-url:
           #注册中心的地址
           defaultZone: http://localhost:8762/eureka/
        #不注册到自身
        register-with-eureka: false
        fetch-registry: false
      #关闭保护模式
      server:
        enable-self-preservation: false
    spring:
      application:
        #名称
        name: eureka
    
    server:
      port: 8762

![70][]

![70 1][]

![70 2][]

4、测试(启动两个实例)

![70 3][]

![70 4][]

[http://localhost:8761/][http_localhost_8761]

[http://localhost:8762/][http_localhost_8762]

## 二、服务提供者 ##

1、pom文件

<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>org.crazyit.cloud</groupId>
    	<artifactId>first-police</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    
    	<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.cloud</groupId>
    			<artifactId>spring-cloud-starter-config</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-eureka</artifactId>
    		</dependency>
    	</dependencies>
    
    </project>

2、启动类

package org.crazyit.cloud;
    
    import java.util.Scanner;
    
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.builder.SpringApplicationBuilder;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class PoliceServer {
    	public static void main(String[] args) {
    		new SpringApplicationBuilder(PoliceServer.class).web(true).run(args);
    	}
    
    }

3、配置文件

![70 5][]

![70 6][]

![70 7][]

4、提供服务

package org.crazyit.cloud;
    
    public class Police {
    
    	private Integer id;
    	private String name;
    	private String message;
    	
    	public Integer getId() {
    		return id;
    	}
    	public void setId(Integer id) {
    		this.id = id;
    	}
    	public String getName() {
    		return name;
    	}
    	public void setName(String name) {
    		this.name = name;
    	}
    	public String getMessage() {
    		return message;
    	}
    	public void setMessage(String message) {
    		this.message = message;
    	}
    	
    }

package org.crazyit.cloud;
    
    import javax.servlet.http.HttpServletRequest;
    
    import org.springframework.http.MediaType;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class PoliceController {
    
    	@RequestMapping(value = "/call/{id}", method = RequestMethod.GET, 
    			produces = MediaType.APPLICATION_JSON_VALUE)
    	public Police call(@PathVariable Integer id, HttpServletRequest request) {
    		Police p = new Police();
    		p.setId(id);
    		p.setName("angus");
    		p.setMessage(request.getRequestURL().toString());
    		return p;
    	}
    }

5、运行

![70 8][]

![70 9][]

## 三、服务消费者 ##

1、pom文件

<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>org.crazyit.cloud</groupId>
    	<artifactId>first-person</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	
    	<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.cloud</groupId>
    			<artifactId>spring-cloud-starter-config</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-eureka</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-ribbon</artifactId>
    		</dependency>
    	</dependencies>
    	
    </project>

2、启动类

package org.crazyit.cloud;
    
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.builder.SpringApplicationBuilder;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class PersonServer {
    
    	public static void main(String[] args) {
    		new SpringApplicationBuilder(PersonServer.class).web(true).run(args);
    	}
    
    }

3、配置文件

server:
      port: 9000
    spring:
      application:
        name: cloud-person
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/, http://localhost:8762/eureka/

4、发布服务(也消费了)

package org.crazyit.cloud;
    
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    import org.springframework.web.client.RestTemplate;
    
    @Controller
    @Configuration
    public class TestController {
    	
    	@Bean
    	@LoadBalanced
    	public RestTemplate getRestTemplate() {
    		return new RestTemplate();
    	}
    
    	@GetMapping("/router")
    	@ResponseBody
    	public String router() {
    		RestTemplate tpl = getRestTemplate();
    		String json = tpl.getForObject("http://cloud-police/call/1", String.class);
    		return json;
    	}
    
    }

5、测试

![70 10][]

四、多次调用

package org.crazyit.cloud;
    
    import org.apache.http.HttpResponse;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.util.EntityUtils;
    
    public class TestClient {
    
    	public static void main(String[] args) throws Exception {
    		// 创建默认的HttpClient
    		CloseableHttpClient httpclient = HttpClients.createDefault();
    		// 调用6次服务并输出结果
    		for(int i = 0; i < 6; i++) {
    			// 调用 GET 方法请求服务
    			HttpGet httpget = new HttpGet("http://localhost:9000/router");
    			// 获取响应
    			HttpResponse response = httpclient.execute(httpget);
    			// 根据 响应解析出字符串
    			System.out.println(EntityUtils.toString(response.getEntity()));
    		}
    	}
    
    }

结果

![70 11][]

再看看注册中心

![70 12][]

![70 13][]

[70]: /images/20220513/150fda61748443c0ae15b06c4a7c45c1.png
[70 1]: /images/20220513/f8cafadb5707424fb71c74d0cd838201.png
[70 2]: /images/20220513/046242c781ff411599cb0fc73c612bd2.png
[70 3]: /images/20220513/ccfe6f16c67f4127a834ff2532ed780b.png
[70 4]: /images/20220513/1a0a23c0a1a548c3b6e9f36a98e27c3d.png
[http_localhost_8761]: http://localhost:8761/
[http_localhost_8762]: http://localhost:8762/
[70 5]: /images/20220513/72573ac13dcd4099b82ac5845017816b.png
[70 6]: /images/20220513/1be30fb2231d48b9975b86f84fea8769.png
[70 7]: /images/20220513/46bcc829d07c4764b6dc8da79b0e15c8.png
[70 8]: /images/20220513/490b16af6b7645f78fe7224d51819b56.png
[70 9]: /images/20220513/a697d178edd9430abcd51312696f28e1.png
[70 10]: /images/20220513/6f359ff1fd03445396510640541e81e4.png
[70 11]: /images/20220513/506126b4ec244b52b61cd13a997effbe.png
[70 12]: /images/20220513/c7b6b2096a424d44867d6f76358581f9.png
[70 13]: /images/20220513/8b73b073c12049968b86610c8fe5d437.png