springcloud 简单demo

客官°小女子只卖身不卖艺 2021-09-23 05:40 356阅读 0赞

1 创建eureka（注册中心）  
1.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>com.jorian</groupId>
      <artifactId>sc_eureka-server</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      
      
      	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>1.5.4.RELEASE</version>
    		<relativePath />
    	</parent>
    	
    	
      
     	 <properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<java.version>1.8</java.version>
    	</properties>
      
      	
      	<dependencies>
      		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-eureka-server</artifactId>
    		</dependency>
    		
    		
    		
    		
    		
    		<dependency>
    		    <groupId>javax.xml.bind</groupId>
    		    <artifactId>jaxb-api</artifactId>
    		    <version>2.2.11</version>
    		</dependency>
    		<dependency>
    		    <groupId>com.sun.xml.bind</groupId>
    		    <artifactId>jaxb-core</artifactId>
    		    <version>2.2.11</version>
    		</dependency>
    		<dependency>
    		    <groupId>com.sun.xml.bind</groupId>
    		    <artifactId>jaxb-impl</artifactId>
    		    <version>2.2.11</version>
    		</dependency>
    		<dependency>
    		    <groupId>javax.activation</groupId>
    		    <artifactId>activation</artifactId>
    		    <version>1.1.1</version>
    		</dependency>
    	
    	</dependencies>
    	
    
    	
    	
      <dependencyManagement>
    		<dependencies>
    			<dependency>
    				<groupId>org.springframework.cloud</groupId>
    				<artifactId>spring-cloud-dependencies</artifactId>
    				<version>Dalston.SR1</version>
    				<type>pom</type>
    				<scope>import</scope>
    			</dependency>
    		</dependencies>
    	</dependencyManagement>
      
      
      
    </project>

1.2 在src/main/resources 下新建application.yml

security:
      basic:
        enabled: true
      user:
        name: user
        password: password123
    server:
      port: 8761
    eureka:
      client:
        register-with-eureka: false
        fetch-registry: false
        service-url:
          defaultZone: http://user:password123@localhost:8761/eureka
    logging:
      level:

1.3 新建EurekaServerRunApp启动类

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    /**
     * 注册中心/配置中心（server）
     * @author gyn
     *
     */
    @EnableEurekaServer//表示是一个eurekaserver
    @SpringBootApplication
    public class EurekaServerRunApp {
     
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		SpringApplication.run(EurekaServerRunApp.class, args);
    	}
     
    }

1.4 启动EurekaServerRunApp

打开 http://localhost:8761/  
能正常访问 就是配置成功  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1OTU4NDk3_size_16_color_FFFFFF_t_70]

2新建生产者provider  
2.1pom配置

2.2在src/main/resources 下新建application.yml

server:
      port: 7901
    spring:
      application:
        name: provider-user
    eureka:
      client:
        serviceUrl:
          defaultZone: http://user:password123@localhost:8761/eureka
    logging:
      level:
        root: INFO

2.3新建ProviderRunApp启动类

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    /**
     * 生产者
     * @author gyn
     *
     */
    @EnableEurekaClient//表示是一个eurekaserver
    @SpringBootApplication
    public class ProviderRunApp {
     
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		SpringApplication.run(ProviderRunApp.class, args);
    	}
     
    }

2.4新建生产者 Controller 以供消费者调用此方法

import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
     
    @RestController
    public class provider_Controller {
    	@RequestMapping("/hello")
    	public String sayhello(String name){
    		return "provider1 "+name;
    	}
    }

2.5 启动ProviderRunApp

打开 http://localhost:8761/ 就能看见我们配置服务名称 ip 端口 运行状态  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1OTU4NDk3_size_16_color_FFFFFF_t_70 1]

2.6 重点 要配置多个生产者provider  
只需修改application.yml port即可  
name: provider-user 这个不要修改，同样的服务名称必须相同

3创建消费者consumer  
3.1pom配置

3.2在src/main/resources 下新建application.yml

server:
      port: 7902
    spring:
      application:
        name: consumer-hello
    eureka:
      client:
        serviceUrl:
          defaultZone: http://user:password123@localhost:8761/eureka
    logging:
      level:
        root: INFO

3.3新建ConsumerRunApp启动类

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;
    /**
     * 消费者
     * @author gyn
     *
     */
    @SpringBootApplication
    @EnableEurekaClient
    /**
     * @author gyn
     *
     */
    
    public class ConsumerRunApp {
     
    	@Bean
    	@LoadBalanced	//Ribbon负载均衡
    	public RestTemplate restTemplate(){
    		return new RestTemplate();
    	}
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		SpringApplication.run(ConsumerRunApp.class, args);
    	}
     
    }

3.4 创建消费者controller 以供外界访问

mport org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
     
    @RestController
    public class HelloController {
    	@Autowired
    	private RestTemplate resttemplate;
    	@RequestMapping("/hello")
    	public String hello(String name){
    		String url="http://provider-user/hello?name="+name;
    		
    		//返回值类型要一致
    		return resttemplate.getForObject(url, String.class);
    	
    	}
    	
    }

3.5启动ConsumerRunApp  
打开注册中心 http://localhost:8761/ 就能看见我们配置服务名称 ip 端口 运行状态  
打开 http://localhost:7902/hello

成功 就能返回 provider1\*\*\*\*  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1OTU4NDk3_size_16_color_FFFFFF_t_70 2]  
如不成功 就根据问题 去解决吧

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1OTU4NDk3_size_16_color_FFFFFF_t_70]: /images/20210923/5edbff3732274e03b8c4e64d93315ec5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1OTU4NDk3_size_16_color_FFFFFF_t_70 1]: /images/20210923/7c1230b007ed4766a8d79c88343daa66.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI1OTU4NDk3_size_16_color_FFFFFF_t_70 2]: /images/20210923/4553a850aba84010935c3f7bb73acd19.png