上一篇讲述了consul的安装及简单配置，这一次来说一下springcloud中如何使用consul对服务进行管理
生产者：boot版本是2.0.3
pom文件引入consul依赖
<!-- consul -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>
在application文件引入consul支持
spring.cloud.consul.host=localhost 本机，推荐每个机器都部署一个consul监测发现服务
spring.cloud.consul.port=8500 consul端口
spring.cloud.consul.enabled=true 是否启用consul服务
spring.cloud.consul.discovery.enabled=true 是否可以被发现
spring.cloud.consul.discovery.serviceName=KafkaService 注册的服务名
spring.cloud.consul.discovery.prefer-ip-address=true 是否允许IP显示
spring.cloud.consul.discovery.heartbeat.enabled=true 是否允许心跳检测
spring.cloud.consul.discovery.instance-id=KafkaService-${random.value} 给应用附上唯一标识，consul集群时推荐
在主程序中加入服务发现支持
//cloud支持
@EnableDiscoveryClient
//事务支持
@EnableTransactionManagement
@ComponentScan("com.kafka.KafkaBase")
@SpringBootApplication
public class KafkaBaseApplication extends WebMvcConfigurerAdapter{
public static void main(String[] args) {
SpringApplication.run(KafkaBaseApplication.class, args);
}
@Bean
public FilterRegistrationBean httpFilter(){
FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
filterRegistrationBean.setFilter(new HttpFilter());
return filterRegistrationBean;
}
@Override
public void addInterceptors(InterceptorRegistry registry) {
// TODO Auto-generated method stub
registry.addInterceptor(new HttpInterceptor()).addPathPatterns("/**");
}
}
在Controller写入测试接口
@RequestMapping(value = "/param",method = RequestMethod.GET)
public String param(HttpServletRequest request, HttpServletResponse response){
String param = request.getParameter("param");
return "服务端-测试参数"+param;
}
消费者：
消费者这里我们引入了feign组件，他可以进行负载均衡，帮助用户把请求平均的分发到各个生产者那里。
pom文件引入consul依赖及feign组件
<!-- consul -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>
<!-- feign -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
在application文件引入consul支持
spring.cloud.consul.host=localhost
spring.cloud.consul.port=8500
spring.cloud.consul.enabled=true
spring.cloud.consul.discovery.enabled=true
spring.cloud.consul.discovery.serviceName=ConsulConsumer
spring.cloud.consul.discovery.prefer-ip-address=true
spring.cloud.consul.discovery.heartbeat.enabled=true
spring.cloud.consul.discovery.register=false
在主程序中加入服务发现支持
//cloud支持
@EnableDiscoveryClient
//事务支持
@EnableTransactionManagement
@SpringBootApplication
@EnableFeignClients
public class KafkaBaseApplication extends WebMvcConfigurerAdapter{
public static void main(String[] args) {
SpringApplication.run(KafkaBaseApplication.class, args);
}
@Bean
public FilterRegistrationBean httpFilter(){
FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
filterRegistrationBean.setFilter(new HttpFilter());;
return filterRegistrationBean;
}
@Override
public void addInterceptors(InterceptorRegistry registry) {
// TODO Auto-generated method stub
registry.addInterceptor(new HttpInterceptor()).addPathPatterns("/**");
}
}
在Controller写入测试接口
@ResponseBody
@RequestMapping(value = "/clientParam", method = RequestMethod.GET)
public String paramname(@RequestParam(value = "param") Integer param) {
return loadBalancer.choose("KafkaService").getUri().toString()+feinClient.paramname(param);
}
至此，一个简单的基于consul的服务发现及调用的例子就写完了。
