234390216
- 浏览: 10193144 次
- 性别:
- 来自: 深圳
-
博客专栏
-
-
Oracle基础
浏览量：460799
-
-
springMVC介绍
浏览量：1771778
-
-
Mybatis简介
浏览量：1395406
-
-
Spring整合JMS
浏览量：393879
-
-
Ehcache简介
浏览量：678208
-
-
Cas简介
浏览量：529286
-
-
Spring Securi...
浏览量：1178711
-
-
Spring基础知识
浏览量：461848
-
-
Spring Aop介绍
浏览量：150116
-
-
JAXB简介
浏览量：66833
最新评论
-
18335864773：
推荐用pageoffice 生成 word。POI处理Offi ...
POI生成Web版Word文件 -
234390216：
skran 写道大兄弟文章写的不错，排版有点问题，代码长了既没 ...
Spring Boot（05）——SpringApplication介绍 -
skran：
大兄弟文章写的不错，排版有点问题，代码长了既没换行也没滚动条
Spring Boot（05）——SpringApplication介绍 -
Caelebs：
Ehcache（04）——设置缓存的大小 -
234390216：
thaIm 写道不知道RestTemplate 默认的链接数、 ...
Spring（30）——RestTemplate介绍
文章列表
消息的群集消费和广播消费
RocketMQ的消费者进行消息消费时有两种消费方式，群集消费和广播消费。默认是群集消费。
群集消费
Consumer都有一个Group，当两个Consumer实例属于同一个Group时，它们会共享消息队列中的消息消费位移，即同一条消息只会由一个消费者实例消费。实际上一个队列只会分配给一个消费者实例，那么属于该队列中的消息就只能被一个消费者实例消费了。当一个消费者实例挂了后，会重新为消费者实例分配队列，这样原本分配给挂了的那个实例的队列中又会分配给其它消费者进行消费。RocketMQ限制了同一个JVM中不允许有相同Group名称的Consumer实例存在，所以 ...
发送顺序消息
如果你的业务上对消息的发送和消费顺序有较高的需求，那么在发送消息的时候你需要把它们放到同一个消息队列中，因为只有同一个队列的消息才能确保消费的顺序性。下面代码我们在发送消息的时候，调用的是需要传递MessageQueueSelector的send()，该方法还可以传递一个额外的参数，其对应MessageQueueSelector的select()的最后一个参数。下面代码中我们一共发送了10条消息，从1开始算顺序为奇数的都放到第一个队列中，顺序为偶数的都放第二个队列中。所以最终第一个队列放了顺序号为1/3/5/7/9的消息，第二个队列中放了顺序号为2/4/6/8/10的消息。
...
通过Tag对消息分类
RocketMQ建议一个业务系统只使用一个Topic，不同类型的消息通过tag来区分。tag可以在构造Message的时候指定，下面代码就指定了发送的消息的tag都为tag0。
@Test
public void sendWithTag() throws Exception {
DefaultMQProducer producer = new DefaultMQProducer("group1");
producer.setNamesrvAddr(nameServer);
producer.start();
for ( ...
发送消息的三种方式
同步发送
Producer在进行消息发送时可以是阻塞的，也可以是非阻塞的。具体对应到发送方式一共有三种，分别是同步、异步和单向的（ONEWAY）。之前介绍的调用send()返回SendResult的方法是阻塞的，它一定要等到Broker进行了响应后才会返回，才能继续往下执行。对于下面的代码就是只有第一条消息发送完了后，才能发送第二条消息，接着是第三条。这种阻塞发送的方式也叫同步发送，它的整个响应时间还包括可能的重试时间。其内部会默认进行两次重试，可以通过setRetryTimesWhenSendFailed()指定同步发送时内部最大的重试次数。
@Test
...
RocketMQ简介
笔者使用的是Apache RocketMQ，官网是http://rocketmq.apache.org/。RocketMQ是Alibaba开源的一个分布式消息队列，可以通过http://rocketmq.apache.org/dowloading/releases/下载当前最新的版本。下载后解压缩，然后通过bin/mqnamesrv启动一个Name ...
Spring Cloud Gateway
Spring Cloud Gateway是Spring提供的API网关层，可以通过它代理请求，然后转发到真正的目标地址上。使用Spring Cloud Gateway需要加上spring-cloud-starter-gateway和spring-boot-starter-webflux依赖。
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway ...
使用Zookeeper进行服务注册与发现
服务注册（ServiceRegistry）与发现（DiscoveryClient）在Spring Cloud中都进行了抽象。除了之前介绍的Eureka外，Spring Cloud也支持使用Zookeeper作为服务的注册中心。基于Zookeeper的服务注册由org.springframework.cloud.zookeeper.serviceregistry.ZookeeperServiceRegistry实现，服务发现由org.springframework.cloud.zookeeper.discovery.ZookeeperDiscovery ...
追踪工具Sleuth
Spring Cloud Sleuth可以用来追踪微服务请求中的整个请求，通过它可以记录各个请求之间的耗时、异常等情况。使用Spring Cloud Sleuth时一般会跟Zipkin一起使用。Spring Cloud Sleuth收集到的一些跟踪信息可以发送给Zipkin，Zipkin提供了图形化界面方便查看服务之间的调用关系和调用耗时等情况。我们先来看几个Spring Cloud Sleuth里面的基本概念。
service: 服务名，它默认就取spring.application.name。
span : 直接翻译就是跨度，比如service1调用servi ...
Spring Cloud Config
Spring Cloud Config提供分布式配置功能，它包含Server和Client两部分。Server负责提供统一的配置信息，Client负责从Server获取相应的配置信息。Server端的配置信息支持git存储、本地文件存储、数据库等多种存储方式，默认使用git存储。
iteye提示有敏感字，完整内容请查看https://elim168.blog.csdn.net/article/details/102472123
Spring Cloud Function
Spring Cloud Function专注于提供一些与业务无关的函数功能。它允许用户把java.util.function.Function、java.util.function.Consumer和java.util.function.Supplier类型的bean直接对外发布。
通过Http对外发布
Function、Consumer、Supplier可以直接以Http的方式对外发布，这需要我们添加spring-cloud-starter-function-web依赖。
<dependency>
<gr ...
服务注册与发现工具-Consul
Spring Cloud也可以使用Consul作为服务注册与发现工具。Consul和Eureka一样，也有服务端和客户端的概念，它们都需要基于Consul Agent运行，即Agent有Server模式和Client模式，开发环境可以直接通过consul agent -dev启动一个Agent，它默认会listen8500端口。
由于iteye提示包含敏感字，而我没找到包含的敏感字导致发布失败，更多信息请参考csdn的博文。
https://blog.csdn.net/elim168/article/details/101569784
...
基于Apache Kafka的Stream实现
如果你的应用使用了Apache Kafka，你需要把它和Spring Cloud进行整合。需要在应用中添加如下依赖。
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-stream-kafka</artifactId>
</dependency>
然后就是Spring Cloud Stream的标准配置了。需要 ...
基于RocketMQ的Stream实现
Spring Cloud Stream是一个消息收发的框架，它提供了一套标准，应用程序只需要按照它的标准进行消息的收发，而不用关注具体的实现机制。具体的实现可以基于不同的消息中间件进行不同的实现，比如Kafka的实现、RabbitMQ的实现、RocketMQ的实现等。官方已经提供了Kafka和RabbitMQ的实现，RocketMQ的实现由Alibaba负责。本文将基于RocketMQ的实现进行讲解。
Binder和Binding
org.springframework.cloud.stream.binder.Binder是Spring Cl ...
声明式的Rest客户端
Feign是一个声明式的Rest客户端，它可以跟SpringMVC的相关注解一起使用，也可以使用Spring Web的HttpMessageConverter进行请求或响应内容的编解码。其底层使用的Ribbon和Eureka，从而拥有客户端负载均衡的功能。使用它需要在pom.xml中加入spring-cloud-starter-openfeign依赖。
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>sp ...
服务端负载工具Zuul
Zuul是Netflix公司提供的服务端负载工具，Spring Cloud基于它做了一些整合。试想一下微服务场景下服务端有服务A、服务B、服务C等，每个服务对应不同的地址，作为服务提供者，你不想直接对外暴露服务A、服务B、服务C的地址，而且每种服务又有N台机器提供服务。使用Zuul后，可以同时聚合服务A、服务B、服务C，又可实现服务的负载均衡，即同时聚合多个服务A的提供者。Zuul是作用于服务端的，同时它在提供负载均衡时是基于Ribbon实现的。其实也很好理解，Zuul对于真正的服务提供者来说它又是作为客户端的，所以它使用了客户端负载工具Ribbon。Zuul会把每个 ...