来了铁子,看完别说不会了哦,SpringBoot【完结篇】!

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
检索分析服务 Elasticsearch 版,2核4GB开发者规格 1个月
云数据库 Tair(兼容Redis),内存型 2GB
简介: 本文主要介绍 SprinBoot

一、 缓存


1)JSR107


Java Caching定义了5个核心接口,分别是:


  • CachingProvider

定义了创建、配置、获取、管理和控制多个CacheManager。一个应用可以在运行期访问多个CachingProvider。


  • CacheManager

定义了创建、配置、获取、管理和控制多个唯一命名的Cache,这些Cache存在于CacheManager的上下文中。一个CacheManager仅被一个CachingProvider所拥有。


  • Cache

是一个类似Map的数据结构并临时存储以Key为索引的值。一个Cache仅被一个CacheManager所拥有。


  • Entry

是一个存储在Cache中的key-value对。


  • Expiry

每一个存储在Cache中的条目有一个定义的有效期。一旦超过这个时间,条目为过期的状态。一旦过期,条目将不可访问、更新和删除。缓存有效期可以通过ExpiryPolicy设置。



2)Spring缓存抽象


Spring从3.1开始定义了org.springframework.cache.Cacheorg.springframework.cache.CacheManager接口来统一不同的缓存技术,并支持使用JCache(JSR-107)注解简化我们开发。


  • Cache接口为缓存的组件规范定义,包含缓存的各种操作集合


  • Cache接口下Spring提供了各种xxxCache的实现;如RedisCacheEhCacheCache ,ConcurrentMapCache


  • 每次调用需要缓存功能的方法时,Spring会检查指定参数的指定的目标方法是否已经被调用过,如果有就直接从缓存中获取方法调用后的结果,如果没有就调用方法并缓存结果后返回给用户。下次调用直接从缓存中获取。


  • 使用Spring缓存抽象时我们需要关注以下两点:


  1. 确定方法需要被缓存以及他们的缓存策略


  1. 从缓存中读取之前缓存存储的数据


3)几个重要缓存注解





4)缓存使用


  • 引入spring-boot-starter-cache模块


<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-cache</artifactId>
</dependency>


  • 利用@EnableCaching开启缓存


@MapperScan("cbuc.life.cache.mapper")
@SpringBootApplication
@EnableCaching
public class Springboot01CacheApplication {
    public static void main(String[] args) {
        SpringApplication.run(Springboot01CacheApplication.class, args);
    }
}


  • 注解使用


  1. @Cacheable


  1. @CacheEvict


  1. @CachePut


将数据保存在ConcurrentMap


开发中使用缓存中间件:redismemcachedehcache


5)几大属性


  1. cacheNames/value: 指定缓存组件的名字,将方法的返回结果放在哪个缓存中,是数组的方式,可以指定多个缓存


  1. key: 缓存数据使用的key,可以用它来指定。默认是使用方法参数的值


  1. keyGenerator: key的生成器,可以自己指定key的生成器的组件id


  1. cacheManager:指定缓存管理器,或者 cacheResolver 指定获取解析器


  1. condition:指定符合条件的情况下才缓存


  1. unless:否定缓存,当 unless 指定的条件为true,方法的返回值就不会被缓存


  1. sync:是否使用异步模式


  • 示例

1)


注: 我们可以自定义keyGenerator


@Configuration
public class MyCacheConfig {
@Bean("myKeyGenerator")  
public KeyGenerator keyGenerator(){
    return new KeyGenerator(){
        @Override
        public Object generate(Object target, Method method, Object... params) {
            return method.getName()+"["+ Arrays.asList(params).toString()+"]";
        }
    };
}
}


2)



3)



4)



6)整合redis


  1. 引入spring-boot-starter-data-redis


<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>


  1. application.yml配置 redis 连接地址


spring.redis.host=118.24.44.169


  1. 使用ReditTemplate操作redis

常用方法:


redisTemplate.opsForValue();    //操作字符串
redisTemplate.opsForHash();        //操作hash
redisTemplate.opsForList();        //操作list
redisTemplate.opsForSet();        //操作set
redisTemplate.opsForZSet();        //操作有序set


  1. 配置缓存


  1. 自定义redisTemplate


  1. 将自定义的redisTemplate注册进RedisCacheManager


二、消息


*大多应用中,可通过消息服务中间件来提升系统异步通信、扩展解耦能力 *


消息服务中两个重要概念:


  • 消息代理(message broker)


  • 目的地(destination)


当消息发送者发送消息以后,将由消息代理接管,消息代理保证消息传递到指定目的地。


消息队列主要有两种形式的目的地


  • 队列(queue):点对点消息通信(point-to-point)


  • 主题(topic):发布(publish)/订阅(subscribe)消息通信


点对点式


  • 消息发送者发送消息,消息代理将其放入一个队列中,消息接收者从队列中获取消息内容,消息读取后被移出队列


  • 消息只有唯一的发送者和接受者,但并不是说只能有一个接收者


发布订阅式


  • 发送者(发布者)发送消息到主题,多个接收者(订阅者)监听(订阅)这个主题,那么就会在消息到达时同时收到消息


JMS(Java Message Service)JAVA消息服务


  • 基于JVM消息代理的规范。ActiveMQ、HornetMQ是JMS实现


AMQP(Advanced Message Queuing Protocol)


  • 高级消息队列协议,也是一个消息代理的规范,兼容JMS


  • RabbitMQ是AMQP的实现



Spring支持


  • spring-jms提供了对JMS的支持


  • spring-rabbit提供了对AMQP的支持


  • 需要ConnectionFactory的实现来连接消息代理


  • 提供JmsTemplateRabbitTemplate来发送消息


  • @JmsListener(JMS)@RabbitListener(AMQP)注解在方法上监听消息代理发布的消息


  • @EnableJms@EnableRabbit开启支持


Spring Boot自动配置


  • JmsAutoConfiguration


  • RabbitAutoConfiguration


RabbitMQ


简介:


RabbitMQ是一个由erlang开发的AMQP(Advanved Message Queue Protocol)的开源实现。


核心概念:



  • Message:

消息,消息是不具名的,它由消息头和消息体组成。消息体是不透明的,而消息头则由一系列的可选属性组成,这些属性包括routing-key(路由键)、priority(相对于其他消息的优先权)、delivery-mode(指出该消息可能需要持久性存储)等。


  • Publisher:

消息的生产者,也是一个向交换器发布消息的客户端应用程序。


  • Consumer:

消息的消费者,表示一个从消息队列中取得消息的客户端应用程序。


  • Exchange:

交换器,用来接收生产者发送的消息并将这些消息路由给服务器中的队列。


不同类型的Exchange转发消息的策略有所区别


  • direct(默认)


  • fanout


  • topic


  • headers


  • Queue:


消息队列,用来保存消息直到发送给消费者。它是消息的容器,也是消息的终点。一个消息可投入一个或多个队列。消息一直在队列里面,等待消费者连接到这个队列将其取走。


  • Binding:


绑定,用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则,所以可以将交换器理解成一个由绑定构成的路由表。
Exchange 和Queue的绑定可以是多对多的关系。


  • Connection:


网络连接,比如一个TCP连接。


  • Channel:


信道,多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内的虚拟连接,AMQP 命令都是通过信道发出去的,不管是发布消息、订阅队列还是接收消息,这些动作都是通过信道完成。因为对于操作系统来说建立和销毁 TCP 都是非常昂贵的开销,所以引入了信道的概念,以复用一条 TCP 连接。


  • Virtual Host:


虚拟主机,表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器,拥有自己的队列、交换器、绑定和权限机制。vhost 是 AMQP 概念的基础,必须在连接时指定,RabbitMQ 默认的 vhost 是 / 。


  • Broker:


表示消息队列服务器实体


运行机制:


  • AMQP 中的消息路由


AMQP 中消息的路由过程和 Java 开发者熟悉的 JMS 存在一些差别,AMQP 中增加了 ExchangeBinding 的角色。生产者把消息发布到 Exchange 上,消息最终到达队列并被消费者接收,而 Binding 决定交换器的消息应该发送到那个队列。



  • Exchange 类型


Exchange分发消息时根据类型的不同分发策略有区别,目前共四种类型:directfanouttopicheaders 。headers 匹配 AMQP 消息的* header 而不是路由键*, *headers 交换器和 direct 交换器完全一致*,但性能差很多,目前几乎用不到了,所以直接看另外三种类型:


  1. direct



消息中的路由键(routing key)如果和 Binding 中的 binding key 一致, 交换器就将消息发到对应的队列中。路由键与队列名完全匹配,如果一个队列绑定到交换机要求路由键为“dog”,则只转发 routing key 标记为“dog”的消息,不会转发“dog.puppy”,也不会转发“dog.guard”等等。它是完全匹配、单播的模式。


  1. fanout



每个发到 fanout 类型交换器的消息都会分到所有绑定的队列上去。fanout 交换器不处理路由键,只是简单的将队列绑定到交换器上,每个发送到交换器的消息都会被转发到与该交换器绑定的所有队列上。很像子网广播,每台子网内的主机都获得了一份复制的消息。fanout 类型转发消息是最快的。


  1. topic



topic 交换器通过模式匹配分配消息的路由键属性,将路由键和某个模式进行匹配,此时队列需要绑定到一个模式上。它将路由键和绑定键的字符串切分成单词,这些单词之间用点隔开。它同样也会识别两个通配符:符号“#”和符号“*”。#匹配0个或多个单词,*匹配一个单词。


整合RabbitMQ


  • 引入 spring-boot-starter-amqp


<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>


  • application.yml配置


spring.rabbitmq.host=118.24.44.169
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest


  • 启动类



示例:


  • 自定义消息转换器,以Jackson的形式转换


@Configuration
public class MyAMQPConfig {
    @Bean
    public MessageConverter messageConverter(){
        return new Jackson2JsonMessageConverter();
    }
}


  • 注入Bean


/**
  * 注入我们需要的两个bean
  */
@Autowired
RabbitTemplate rabbitTemplate;
@Autowired
AmqpAdmin amqpAdmin;


  • 不同模式发送



  • Service 中接收消息示例


注意要在启动类中开启基于注解的RabbitMQ模式 :@EnableRabbit



三、检索


我们的应用经常需要添加检索功能,开源的 ElasticSearch是目前全文搜索引擎的首选。他可以快速的存储、搜索和分析海量数据。Spring Boot通过整合Spring Data ElasticSearch为我们提供了非常便捷的检索功能支持;


Elasticsearch是一个分布式搜索服务,提供Restful API,底层基于Lucene,采用多shard(分片)的方式保证数据安全,并且提供自动resharding的功能,github等大型的站点也是采用了ElasticSearch作为其搜索服务


概念


以 员工文档 的形式存储为例:一个文档代表一个员工数据。存储数据到 ElasticSearch 的行为叫做索引,但在索引一个文档之前,需要确定将文档存储在哪里。


一个 ElasticSearch 集群可以 包含多个 索引,相应的每个索引可以包含多个 类型 。 这些不同的类型存储着多个 文档 ,每个文档又有 多个 属性 。


类似关系:


  • 索引   ====   数据库


  • 类型   ====   表


  • 文档   ====   表中的记录


  • 属性   ====   列



整合ElasticSearch


SpringBoot 默认支持两种技术来和 ES 交互


  • Jest(默认不生效)


导入jest的工具包


<dependency>
    <groupId>io.searchbox</groupId>
    <artifactId>jest</artifactId>
    <version>5.3.3</version>
</dependency>


  • SpringData ElasticSearch


  1. 版本适配问题


  • 升级SpringBoot版本
  • 安装对应版本的ES


  1. 导入工具包


<!--SpringBoot默认使用SpringData ElasticSearch模块进行操作-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>


  1. 安装Spring Data 对应版本的ElasticSearch


  1. application.properties配置


spring.data.elasticsearch.cluster-name=elasticsearch
spring.data.elasticsearch.cluster-nodes=118.24.44.169:9301


  1. 测试


  • 注入Bean:


@Document(indexName = "cbuc",type = "book")
public class Book {
    private Integer id;
    private String bookName;
    private String author;
    //省略 get/set方法
}
public class Article {
    @JestId
    private Integer id;
    private String author;
    private String title;
    private String content;
    //省略 get/set 方法
}


  • 编写 ElasticsearchRepository:


public interface BookRepository extends ElasticsearchRepository<Book,Integer> {
    //参照 https://docs.spring.io/spring-data/elasticsearch/docs/3.0.6.RELEASE/reference/html/
   public List<Book> findByBookNameLike(String bookName);
}


  • 引入所需要的Bean:


@Autowired
JestClient jestClient;
@Autowired
BookRepository bookRepository;


法1:


存入index:


Book book = new Book();
book.setId(1);
book.setBookName("西游记");
book.setAuthor("吴承恩");
bookRepository.index(book);


取:


for (Book book : bookRepository.findByBookNameLike("游")) {
    System.out.println(book);
}


法2:


//给Es中索引(保存)一个文档:
Article article = new Article();
article.setId(1);
article.setTitle("测试");
article.setAuthor("cbuc");
article.setContent("测试检索");
//构建一个索引功能
Index index = new Index.Builder(article).index("cbuc").type("news").build();
//执行
jestClient.execute(index);


测试搜索:


//查询表达式
@Test
public void search(){
    //查询表达式
    String json ="{\n" +
            "    \"query\" : {\n" +
            "        \"match\" : {\n" +
            "            \"content\" : \"hello\"\n" +
            "        }\n" +
            "    }\n" +
            "}";
    //更多操作: https://github.com/searchbox-io/Jest/tree/master/jest
    //构建搜索功能
    Search search = new Search.Builder(json).addIndex("cbuc").addType("news").build();
    //执行
    try {
        SearchResult result = jestClient.execute(search);
        System.out.println(result.getJsonString());
    } catch (IOException e) {
        e.printStackTrace();
    }
}


四、任务


异步任务


在Java应用中,绝大多数情况下都是通过同步的方式来实现交互处理的。但是在处理与第三方系统交互的时候,容易造成响应迟缓的情况,之前大部分都是使用多线程来完成此类任务,其实,在Spring 3.x之后,就已经内置了@Async来完美解决这个问题。


两个注解:


  • @EnableAysnc
  • @Aysnc

使用:


  1. 启动类开启异步注解功能


@EnableAsync  //开启异步注解功能
@SpringBootApplication
public class Springboot04TaskApplication {
    public static void main(String[] args) {
        SpringApplication.run(Springboot04TaskApplication.class, args);
    }
}


  1. Service:


@Service
public class AsyncService {
    //告诉Spring这是一个异步方法
    @Async
    public void test(){
        try {
            //当前线程睡眠 3 秒页面也能及时响应
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("处理数据中...");
    }
}


  1. Controller:


@RestController
public class AsyncController {
    @Autowired
    AsyncService asyncService;
    @GetMapping("/hello")
    public String hello(){
        asyncService.test();
        return "success";
    }
}


定时任务


项目开发中经常需要执行一些定时任务,比如需要在每天凌晨时候,分析一次前一天的日志信息。Spring为我们提供了异步执行任务调度的方式,提供TaskExecutorTaskScheduler接口。


两个注解:


  • @EnableScheduling
  • @Scheduled

cron表达式:




使用:


  1. 启动类开启基于注解的定时任务:


@EnableScheduling //开启基于注解的定时任务
@SpringBootApplication
public class Springboot04TaskApplication {
    public static void main(String[] args) {
        SpringApplication.run(Springboot04TaskApplication.class, args);
    }
}


  1. Service:



邮件任务


使用:


  1. 邮件发送需要引入spring-boot-starter-mail


<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-mail</artifactId>
</dependency>


  1. 定义MailProperties内容,配置在application.properties中


spring.mail.username=(发送人qq账号)
spring.mail.password=(发送人qq密码)
spring.mail.host=smtp.qq.com
spring.mail.properties.mail.smtp.ssl.enable=true


  1. 自动装配JavaMailSender



五、分布式系统


单一应用架构


当网站流量很小时,只需一个应用,将所有功能都部署在一起,以减少部署节点和成本。此时,用于简化增删改查工作量的数据访问框架(ORM)是关键。


垂直应用架构


当访问量逐渐增大,单一应用增加机器带来的加速度越来越小,将应用拆成互不相干的几个应用,以提升效率。此时,用于加速前端页面开发的Web框架(MVC)是关键。


流动计算架构


当服务越来越多,容量的评估,小服务资源的浪费等问题逐渐显现,此时需增加一个调度中心基于访问压力实时管理集群容量,提高集群利用率。此时,用于提高机器利用率的资源调度和治理中心(SOA)是关键


分布式服务架构


当垂直应用越来越多,应用之间交互不可避免,将核心业务抽取出来,作为独立的服务,逐渐形成稳定的服务中心,使前端应用能更快速的响应多变的市场需求。此时,用于提高业务复用及整合的分布式服务框架(RPC)是关键。


Zookeeper和Dubbo


ZooKeeper:


是一个分布式的,开放源码的分布式应用程序协调服务。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。


Dubbo:


是Alibaba开源的分布式服务框架,它最大的特点是按照分层的方式来架构,使用这种方式可以使各个层之间解耦合(或者最大限度地松耦合)。从服务模型的角度来看,Dubbo采用的是一种非常简单的模型,要么是提供方提供服务,要么是消费方消费服务,所以基于这一点可以抽象出服务提供方(Provider)和服务消费方(Consumer)两个角色。



使用:


  • 安装zookeeper作为注册中心
  • 编写服务提供者


引入dubbo和zkclient相关依赖


<dependency>
      <groupId>com.alibaba.boot</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>0.1.0</version>
</dependency>
<!--引入zookeeper的客户端工具-->
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
</dependency>


配置dubbo的扫描包和注册中心地址


dubbo.application.name=provider-ticket
  dubbo.registry.address=zookeeper://118.24.44.169:2181
  dubbo.scan.base-packages=cbuc.life.ticket.service


使用@Service发布服务


@Component
  @Service //将服务发布出去  注意注解 Service是dubbo包下的
  public class TicketServiceImpl implements TicketService {
      @Override
      public String getTicket() {
          return "《我和我的祖国》";
      }
  }


  • 编写服务消费者


引入dubbo和zkclient相关依赖


<dependency>
      <groupId>com.alibaba.boot</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>0.1.0</version>
  </dependency>
  <!--引入zookeeper的客户端工具-->
  <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
  <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
  </dependency>


引用服务


@Service
  public class UserService{
      @Reference    // 使用 Reference 引入服务
      TicketService ticketService;
      public void hello(){
          String ticket = ticketService.getTicket();
          System.out.println("调用买票服务:"+ticket);
      }
  }


Spring Boot和Spring Cloud


Spring Cloud是一个分布式的整体解决方案。Spring Cloud 为开发者提供了在分布式系统(配置管理,服务发现,熔断,路由,微代理,控制总线,一次性token,全局琐,leader选举,分布式session,集群状态)中快速构建的工具,使用Spring Cloud的开发者可以快速的启动服务或构建应用、同时能够快速和云平台资源进行对接。


SpringCloud分布式开发五大常用组件:


  • 服务发现  ——  Netflix Eureka


  • 客服端负载均衡  ——  Netflix Ribbon


  • 断路器  ——  Netflix Hystrix


  • 服务网关  ——  Netflix Zuul


  • 分布式配置  ——  Spring Cloud Config


使用:


  • 引入Eureka注册中心


<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Edgware.SR3</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>


  • 配置application


server:
  port: 8761
eureka:
  instance:
    hostname: eureka-server  # eureka实例的主机名
  client:
    register-with-eureka: false #不把自己注册到eureka上
    fetch-registry: false #不从eureka上来获取服务的注册信息
    service-url:
      defaultZone: http://localhost:8761/eureka/


  • 启动类:


@EnableEurekaServer    
@SpringBootApplication
public class EurekaServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class, args);
    }
}


  • 创建provider


引入依赖


<dependencyManagement>
  <dependencies>  &lt;dependency&gt;
      &lt;groupId&gt;org.springframework.cloud&lt;/groupId&gt;
      &lt;artifactId&gt;spring-cloud-starter-eureka-server&lt;/artifactId&gt;
  &lt;/dependency&gt;
  &lt;dependency&gt;
      &lt;groupId&gt;org.springframework.cloud&lt;/groupId&gt;
      &lt;artifactId&gt;spring-cloud-dependencies&lt;/artifactId&gt;
      &lt;version&gt;Edgware.SR3&lt;/version&gt;
      &lt;type&gt;pom&lt;/type&gt;
      &lt;scope&gt;import&lt;/scope&gt;
  &lt;/dependency&gt;
  </dependencies>
</dependencyManagement>


  • 配置application


server:
port: 8002
spring:
application:
  name: provider-ticket
eureka:
instance:
  prefer-ip-address: true # 注册服务的时候使用服务的ip地址
client:
  service-url:
    defaultZone: http://localhost:8761/eureka/


  • 启动类


@SpringBootApplication
public class ProviderTicketApplication {
  public static void main(String[] args) {
      SpringApplication.run(ProviderTicketApplication.class, args);
  }
}


  • service


@Service
public class TicketService {
  public String getTicket(){
      return "《我和我的祖国》";
  }
}


  • controller


@RestController
public class TicketController {
  @Autowired
  TicketService ticketService;
  @GetMapping("/ticket")
  public String getTicket(){
      return ticketService.getTicket();
  }
}


  • 创建consumer


引入依赖


<dependencyManagement>
  <dependencies>  &lt;dependency&gt;
      &lt;groupId&gt;org.springframework.cloud&lt;/groupId&gt;
      &lt;artifactId&gt;spring-cloud-dependencies&lt;/artifactId&gt;
      &lt;version&gt;Edgware.SR3&lt;/version&gt;
      &lt;type&gt;pom&lt;/type&gt;
      &lt;scope&gt;import&lt;/scope&gt;
  &lt;/dependency&gt;
  &lt;dependency&gt;
      &lt;groupId&gt;org.springframework.cloud&lt;/groupId&gt;
      &lt;artifactId&gt;spring-cloud-starter-eureka-server&lt;/artifactId&gt;
  &lt;/dependency&gt;
  </dependencies>
</dependencyManagement>


  • 配置application


spring:
application:
  name: consumer-user
server:
port: 8200
eureka:
instance:
  prefer-ip-address: true # 注册服务的时候使用服务的ip地址
client:
  service-url:
    defaultZone: http://localhost:8761/eureka/


  • 启动类


@EnableDiscoveryClient //开启发现服务功能
@SpringBootApplication
public class ConsumerUserApplication {
  public static void main(String[] args) {
      SpringApplication.run(ConsumerUserApplication.class, args);
  }
  @LoadBalanced //使用负载均衡机制
  @Bean
  public RestTemplate restTemplate(){
      return new RestTemplate();
  }
}


  • controller (通过使用RestTemplate调用服务)


@RestController
public class UserController {
  @Autowired
  RestTemplate restTemplate;
  @GetMapping("/buy")
  public String buyTicket(String name){
      String s = restTemplate.getForObject("http://PROVIDER-TICKET/ticket", String.class);
      return name+"购买了"+s;
  }
}


相关实践学习
使用阿里云Elasticsearch体验信息检索加速
通过创建登录阿里云Elasticsearch集群,使用DataWorks将MySQL数据同步至Elasticsearch,体验多条件检索效果,简单展示数据同步和信息检索加速的过程和操作。
ElasticSearch 入门精讲
ElasticSearch是一个开源的、基于Lucene的、分布式、高扩展、高实时的搜索与数据分析引擎。根据DB-Engines的排名显示,Elasticsearch是最受欢迎的企业搜索引擎,其次是Apache Solr(也是基于Lucene)。 ElasticSearch的实现原理主要分为以下几个步骤: 用户将数据提交到Elastic Search 数据库中 通过分词控制器去将对应的语句分词,将其权重和分词结果一并存入数据 当用户搜索数据时候,再根据权重将结果排名、打分 将返回结果呈现给用户 Elasticsearch可以用于搜索各种文档。它提供可扩展的搜索,具有接近实时的搜索,并支持多租户。
目录
相关文章
|
3月前
|
自然语言处理 Java 关系型数据库
ElasticSearch 实现分词全文检索 - SpringBoot 完整实现 Demo 附源码【完结篇】
ElasticSearch 实现分词全文检索 - SpringBoot 完整实现 Demo 附源码【完结篇】
51 0
|
XML SQL 缓存
Spring Boot + vue-element 开发个人博客项目实战教程(二十六、前端首页统计完善及完结)
Spring Boot + vue-element 开发个人博客项目实战教程(二十六、前端首页统计完善及完结)
129 1
|
JSON NoSQL 前端开发
SpringBoot定义优雅全局统一Restful API 响应框架完结撒花篇封装starter组件
SpringBoot定义优雅全局统一Restful API 响应框架完结撒花篇封装starter组件
SpringBoot定义优雅全局统一Restful API 响应框架完结撒花篇封装starter组件
|
XML SQL JavaScript
SpringBoot日记本系统全程直播09:项目一期完结
大家好,我是兔哥呀。我又来啦,这个SpringBoot日记本系统已经接近尾声了,目前已经完成的模块有日记本的增删改查,类型的增删改查,头像上传,还有个人中心。 最后一节呢,我们来做一个收尾工作哈。
179 0
|
1月前
|
JavaScript 安全 Java
如何使用 Spring Boot 和 Ant Design Pro Vue 实现动态路由和菜单功能,快速搭建前后端分离的应用框架
本文介绍了如何使用 Spring Boot 和 Ant Design Pro Vue 实现动态路由和菜单功能,快速搭建前后端分离的应用框架。首先,确保开发环境已安装必要的工具,然后创建并配置 Spring Boot 项目,包括添加依赖和配置 Spring Security。接着,创建后端 API 和前端项目,配置动态路由和菜单。最后,运行项目并分享实践心得,包括版本兼容性、安全性、性能调优等方面。
143 1
|
2月前
|
前端开发 JavaScript Java
基于Java+Springboot+Vue开发的服装商城管理系统
基于Java+Springboot+Vue开发的服装商城管理系统(前后端分离),这是一项为大学生课程设计作业而开发的项目。该系统旨在帮助大学生学习并掌握Java编程技能,同时锻炼他们的项目设计与开发能力。通过学习基于Java的服装商城管理系统项目,大学生可以在实践中学习和提升自己的能力,为以后的职业发展打下坚实基础。
148 2
基于Java+Springboot+Vue开发的服装商城管理系统
|
18天前
|
JavaScript 安全 Java
如何使用 Spring Boot 和 Ant Design Pro Vue 构建一个具有动态路由和菜单功能的前后端分离应用。
本文介绍了如何使用 Spring Boot 和 Ant Design Pro Vue 构建一个具有动态路由和菜单功能的前后端分离应用。首先,创建并配置 Spring Boot 项目,实现后端 API;然后,使用 Ant Design Pro Vue 创建前端项目,配置动态路由和菜单。通过具体案例,展示了如何快速搭建高效、易维护的项目框架。
95 62
|
16天前
|
JavaScript 安全 Java
如何使用 Spring Boot 和 Ant Design Pro Vue 构建一个前后端分离的应用框架,实现动态路由和菜单功能
本文介绍了如何使用 Spring Boot 和 Ant Design Pro Vue 构建一个前后端分离的应用框架,实现动态路由和菜单功能。首先,确保开发环境已安装必要的工具,然后创建并配置 Spring Boot 项目,包括添加依赖和配置 Spring Security。接着,创建后端 API 和前端项目,配置动态路由和菜单。最后,运行项目并分享实践心得,帮助开发者提高开发效率和应用的可维护性。
34 2
|
18天前
|
JavaScript Java 项目管理
Java毕设学习 基于SpringBoot + Vue 的医院管理系统 持续给大家寻找Java毕设学习项目(附源码)
基于SpringBoot + Vue的医院管理系统,涵盖医院、患者、挂号、药物、检查、病床、排班管理和数据分析等功能。开发工具为IDEA和HBuilder X,环境需配置jdk8、Node.js14、MySQL8。文末提供源码下载链接。
|
2月前
|
前端开发 JavaScript Java
基于Java+Springboot+Vue开发的大学竞赛报名管理系统
基于Java+Springboot+Vue开发的大学竞赛报名管理系统(前后端分离),这是一项为大学生课程设计作业而开发的项目。该系统旨在帮助大学生学习并掌握Java编程技能,同时锻炼他们的项目设计与开发能力。通过学习基于Java的大学竞赛报名管理系统项目,大学生可以在实践中学习和提升自己的能力,为以后的职业发展打下坚实基础。
218 3
基于Java+Springboot+Vue开发的大学竞赛报名管理系统