Spring Cloud使用Consul作为注册中心示例（spring cloud consul）

　　本篇文章为你整理了Spring Cloud使用Consul作为注册中心示例（spring cloud consul）的详细内容，包含有spring cloud常用注册中心 spring cloud consul spring cloud如何实现服务的注册和发现 springcloud注册中心的作用 Spring Cloud使用Consul作为注册中心示例，希望能帮助你了解 Spring Cloud使用Consul作为注册中心示例。

　　最近在极客时间上面学习丁雪丰老师的《玩转 Spring 全家桶》，学到了服务注册中心这块，动手实践了一下，老师的视频录制是3年前，现在也有了些变化，自己也动手解决了一下，只有自己写一写才理解的更加细致一些，不然光看一遍视频，有点走马观花。现将主要过程记录如下

　　首先在本地docker上面安装Consul

docker pull consul

　　docker run --name my_consul -d -p 8500:8500 -p 8600:8600/udp consul

　　在8500端口上面启动了consul，在浏览器上输入http://localhost:8500/ 就可以看到打开如下图的一个界面。

　　编写两个服务

　　我们这里简单的做两个服务，一个bookshop-service，它提供读写表的服务；另外一个是book-customer-service，它调用bookshop-service在控制台输出读取到的数据。

　　父POM文件定义

 properties

　　 java.version 19 /java.version

　　 spring-cloud.version 2022.0.0 /spring-cloud.version

　　 spring-boot.version 3.0.0 /spring-boot.version

　　 /properties

　　 dependencyManagement

　　 dependencies

　　 dependency

　　 groupId org.springframework.boot /groupId

　　 artifactId spring-boot-dependencies /artifactId

　　 version ${spring-boot.version} /version

　　 type pom /type

　　 scope import /scope

　　 /dependency

　　 dependency

　　 groupId org.springframework.cloud /groupId

　　 artifactId spring-cloud-dependencies /artifactId

　　 version ${spring-cloud.version} /version

　　 type pom /type

　　 scope import /scope

　　 /dependency

　　 /dependencies

　　 /dependencyManagement

　　在dependencyManagement中引入spring-boot-dependencies和spring-cloud-dependencies

　　编写bookshop-service服务

　　首先在POM中引入需要用到的包

 dependencies

　　 dependency

　　 groupId org.springframework.boot /groupId

　　 artifactId spring-boot-starter /artifactId

　　 /dependency

　　 dependency

　　 groupId org.springframework.boot /groupId

　　 artifactId spring-boot-starter-actuator /artifactId

　　 /dependency

　　 dependency

　　 groupId org.springframework.cloud /groupId

　　 artifactId spring-cloud-starter-consul-discovery /artifactId

　　 /dependency

　　 dependency

　　 groupId org.springframework.boot /groupId

　　 artifactId spring-boot-starter-data-jpa /artifactId

　　 /dependency

　　 dependency

　　 groupId org.projectlombok /groupId

　　 artifactId lombok /artifactId

　　 optional true /optional

　　 /dependency

　　 dependency

　　 groupId com.h2database /groupId

　　 artifactId h2 /artifactId

　　 scope runtime /scope

　　 /dependency

　　 /dependencies

　　spring-cloud-starter-consul-discovery就是用来和consul通信的包

　　spring-boot-starter-data-jpa 和 h2是我们访问数据库的包，我们使用内存数据库h2

　　定义一个model

@Entity

　　@Table(name = "T_BOOK")

　　@Data

　　@Builder

　　@NoArgsConstructor

　　@AllArgsConstructor

　　public class Book implements Serializable {

　　 @GeneratedValue(strategy = GenerationType.IDENTITY)

　　 private Long id;

　　 private String name;

　　 private String author;

　　 @Column(updatable = false)

　　 @CreationTimestamp

　　 private Date createTime;

　　 @UpdateTimestamp

　　 private Date updateTime;

　　在resouces下面放入schema.sql用来建表和插入数据

drop table t_book if exists;

　　
insert into t_book (name, author, create_time, update_time) values (python, zhangsan, now(), now());

　　insert into t_book (name, author, create_time, update_time) values (hadoop, lisi, now(), now());

　　insert into t_book (name, author, create_time, update_time) values (java, wangwu, now(), now());

　　定义一个JpaRepository

@RepositoryRestResource(collectionResourceRel = "rest-books", path = "rest-books")

　　public interface BookRepository extends JpaRepository Book, Long {

　　 List Book findByName(@Param("name") String name);

　　我还加了一个hateoas的注解，可以对外提供restful服务，

　　定义一个controller提供服务

　　@RestController

　　@RequestMapping("/book")

　　@Slf4j

　　public class BookController {

　　 @Autowired

　　 private BookService bookService;

　　
public Optional Book getById(@PathVariable Long id) {

　　 Optional Book book = bookService.getBook(id);

　　 return book;

　　 @GetMapping(path = "/", params = "name")

　　 public Optional Book getByName(@RequestParam String name) {

　　 return bookService.getBook(name);

　　BookService就是调用BookRepository，这里代码省略

　　在application.properties中加入如下配置

spring.application.name=bookshop-service

　　server.port=0

　　spring.cloud.consul.host=localhost

　　spring.cloud.consul.port=8500

　　spring.cloud.consul.discovery.prefer-ip-address=true

　　
spring.jpa.properties.hibernate.show_sql=true

　　spring.jpa.properties.hibernate.format_sql=true

　　management.endpoints.web.exposure.include=*

　　management.endpoint.health.show-details=always

　　management.health.redis.enabled=false

　　到这里这个服务就编写好了，我们启动它

　　我们可以看到这个服务就已经上来了。

　　编写book-customer-service

　　它是一个控制台程序，我们为了演示它，也把它弄成了一个service

　　首先依然是pom文件

 dependencies

　　 dependency

　　 groupId org.springframework.boot /groupId

　　 artifactId spring-boot-starter-web /artifactId

　　 /dependency

　　 dependency

　　 groupId org.springframework.boot /groupId

　　 artifactId spring-boot-starter-actuator /artifactId

　　 /dependency

　　 dependency

　　 groupId org.springframework.boot /groupId

　　 artifactId spring-boot-starter-data-rest /artifactId

　　 /dependency

　　 dependency

　　 groupId org.springframework.cloud /groupId

　　 artifactId spring-cloud-starter-consul-discovery /artifactId

　　 /dependency

　　 dependency

　　 groupId org.projectlombok /groupId

　　 artifactId lombok /artifactId

　　 optional true /optional

　　 /dependency

　　 dependency

　　 groupId org.apache.httpcomponents /groupId

　　 artifactId httpclient /artifactId

　　 version 4.5.7 /version

　　 /dependency

　　 /dependencies

　　定义一个ApplicationRunner来取数据和打印数据

@Component

　　@Slf4j

　　public class BookCustomerRunner implements ApplicationRunner {

　　 @Autowired

　　 private RestTemplate restTemplate;

　　 @Autowired

　　 private DiscoveryClient discoveryClient;

　　 @Override

　　 public void run(ApplicationArguments args) throws Exception {

　　 showServiceInstances();

　　 readBooks();

　　 queryBook(1L);

　　 private void showServiceInstances() {

　　 log.info("DiscoveryClient: {}", discoveryClient.getClass().getName());

　　 discoveryClient.getInstances("bookshop-service").forEach(s - {

　　 log.info("Host: {}, Port: {}", s.getHost(), s.getPort());

　　 private void readBooks() {

　　 ParameterizedTypeReference List Book ptr =

　　 new ParameterizedTypeReference List Book () {};

　　 ResponseEntity List Book list = restTemplate

　　 .exchange("http://bookshop-service/book/getAll", HttpMethod.GET, null, ptr);

　　 list.getBody().forEach(c - log.info("Book: {}", c));

　　 private void queryBook(Long id){

　　 Book book = restTemplate

　　 .getForObject("http://bookshop-service/book/{id}", Book.class, id);

　　 log.info("Book: {}", book);

　　这里我们可以看到我们使用了“http://bookshop-service/book/getAll”，它就是我们注册到consul的服务，我们在浏览器输入是拿不到数据的，这里spring帮我们做了转换，我们的showServiceInstances，就是打印出真实的host和port。

　　在这个示例中我们的输出如下

　　它打印出来对应的Host和Post，然后打印出来了我们从数据库里读出来的几条数据。

　　我们来看一下现在consul是怎么显示的，可以看到book-customer-service也已经上来了。

　　代码我上传到了https://github.com/dengkun39/redisdemo

　　在学习的时候我还使用了zookeeper来作为服务注册中心，代码几乎不需要动，只是需要把spring-cloud-starter-consul-discovery 换成spring-cloud-starter-zookeeper-discovery，然后配置文件中加上spring.cloud.zookeeper.connect-string=localhost:2181。使用zookeeper遇到一段时间后再访问就出现”I/O error on GET request for "http://bookshop-service/book/getAll": Permission denied: no further information“ 应该是有些设置没有弄到位，刚开始学习，没有办法细究是怎么回事。

　　服务注册中心学完了，如果需要对外提供服务应该怎么弄呢？总不能像我这样明明是控制台也把它弄成一个服务吧。这个问题我暂时不知道答案，留在这里，后面学习了再来回答它。

　　以上就是Spring Cloud使用Consul作为注册中心示例（spring cloud consul）的详细内容，想要了解更多 Spring Cloud使用Consul作为注册中心示例的内容，请持续关注盛行IT软件开发工作室。

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。

相关文章阅读