SpringCloud服务集群@EnableEurekaClient //本服务启动后会自动注册进eureka服务中 @EnableDiscoveryClient //服务发现

ゞ浴缸里的玫瑰 2023-07-10 15:56 14阅读 0赞

# application.yml #

server:
      port: 8001
      
    mybatis:
      config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
      type-aliases-package: com.atguigu.springcloud.entities    # 所有Entity别名类所在包
      mapper-locations:
      - classpath:mybatis/mapper/**/*.xml                       # mapper映射文件
        
    spring:
       application:
        name: microservicecloud-dept 
       datasource:
        type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
        driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
        url: jdbc:mysql://localhost:3306/test              # 数据库名称
        username: root
        password: 123456
        dbcp2:
          min-idle: 5                                           # 数据库连接池的最小维持连接数
          initial-size: 5                                       # 初始化连接数
          max-total: 5                                          # 最大连接数
          max-wait-millis: 200                                  # 等待连接获取的最大超时时间
          
    eureka:
      client: #客户端注册进eureka服务列表内
        service-url: 
          #defaultZone: http://localhost:7001/eureka
           defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/      
      instance:
        instance-id: microservicecloud-dept8001
        prefer-ip-address: true     #访问路径可以显示IP地址     
     
    info: 
      app.name: atguigu-microservicecloud
      company.name: www.atguigu.com
      build.artifactId: $project.artifactId$
      build.version: $project.version$

# Controller的逻辑处理流程 #

package com.atguigu.springcloud.controller;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.cloud.client.ServiceInstance;
    import org.springframework.cloud.client.discovery.DiscoveryClient;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.atguigu.springcloud.entities.Dept;
    import com.atguigu.springcloud.service.DeptService;
    
    @RestController
    public class DeptController
    {
    	@Autowired
    	private DeptService service;
    	@Autowired
    	private DiscoveryClient client;
    
    	@RequestMapping(value = "/dept/add", method = RequestMethod.POST)
    	public boolean add(@RequestBody Dept dept)
    	{
    		return service.add(dept);
    	}
    
    	@RequestMapping(value = "/dept/get/{id}", method = RequestMethod.GET)
    	public Dept get(@PathVariable("id") Long id)
    	{
    		return service.get(id);
    	}
    
    	@RequestMapping(value = "/dept/list", method = RequestMethod.GET)
    	public List<Dept> list()
    	{
    		return service.list();
    	}
    
    	
    //	@Autowired
    //	private DiscoveryClient client;
    	@RequestMapping(value = "/dept/discovery", method = RequestMethod.GET)
    	public Object discovery()
    	{
    		List<String> list = client.getServices();
    		System.out.println("**********" + list);
    
    		List<ServiceInstance> srvList = client.getInstances("MICROSERVICECLOUD-DEPT");
    		for (ServiceInstance element : srvList) {
    			System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t"
    					+ element.getUri());
    		}
    		return this.client;
    	}
    
    }

# DeptMapper.xml #

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    
    <mapper namespace="com.atguigu.springcloud.dao.DeptDao">
    
    	<select id="findById" resultType="Dept" parameterType="Long">
    		select deptno,dname,db_source from dept where deptno=#{deptno};
    	</select>
    	<select id="findAll" resultType="Dept">
    		select deptno,dname,db_source from dept;
    	</select>
    	<insert id="addDept" parameterType="Dept">
    		INSERT INTO dept(dname,db_source) VALUES(#{dname},DATABASE());
    	</insert>
    
    </mapper>

# mybatis.cfg.xml #

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE configuration
      PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
      "http://mybatis.org/dtd/mybatis-3-config.dtd">
    
    <configuration>
    
    	<settings>
    		<setting name="cacheEnabled" value="true" />
    	</settings>
    
    </configuration>

运行主类L

@SpringBootApplication
    @EnableEurekaClient //本服务启动后会自动注册进eureka服务中
    @EnableDiscoveryClient //服务发现
    @EnableCircuitBreaker//对hystrixR熔断机制的支持
    @EnableHystrixDashboard
    @EnableFeignClients
    @EnableHystrix
    public class DeptProvider8001_Hystrix_App
    {
    	public static void main(String[] args)
    	{
    		SpringApplication.run(DeptProvider8001_Hystrix_App.class, args);
    	}
    //	@Bean
    //	public ServletRegistrationBean getServlet() {
    //		HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
    //		ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
    //		registrationBean.setLoadOnStartup(1);
    //		registrationBean.addUrlMappings("/hystrix.stream");
    //		registrationBean.setName("HystrixMetricsStreamServlet");
    //		return registrationBean;
    //	}
    }