标签:amqp

Java

SpringAMQP 消息转换器 – MessageConverter

17

尖兵 发布于 2019-02-17

MessageConverter 即消息转换器 我们在进行发送消息的时候,正常情况下消息体为二进制的数据方式进行传输,如果希望内部帮我们进行转换,或者指定自定义的转换器,就需要用到 MessageConverter 了。 自定义常用转换器: MessageConverter, 一...

阅读(17)评论(0)赞 (0)

Spring

SpringAMQP 消息容器 – SimpleMessageListenerContainer

1

songhua.gao 发布于 2019-02-09

这个类非常的强大,我们可以对他进行很多的设置,用对于消费者的配置项,这个类都可以满足。它有监听单个或多个队列、自动启动、自动声明功能。 它可以设置事务特性、事务管理器、事务属性、事务并发、是否开启事务、回滚消息等。但是我们在实际生产中,很少使用事务,基本都是采用补偿机制。 它可以...

阅读(40)评论(0)赞 (0)

Spring

Spring Cloud实战系列(六) – 分布式配置中心Spring Cloud Config

1

changyuan.xu 发布于 2019-02-03

在 分布式系统 中,由于服务数量巨多,为了方便 服务配置文件 的 统一管理 和 实时更新 ,所以需要 分布式配置中心 组件。 Spring Cloud 提供的 分布式配置中心 组件是 Spring Cloud Config ,它支持将 配置服务 放在配置服务的 内存 中(即 本地...

阅读(31)评论(0)赞 (0)

Spring

springboot整合各种消息队列(二):rabbitmq消息队列

5

songhua.gao 发布于 2019-01-25

本篇博客将介绍使用rabbitmq消息中间件和springboot的整合使用; 安装配置rabbitmq 请参考笔者另一篇博客,有详细介绍: https://jsbintask.cn/2019/01/25/middleware/docker-rabbitmq-install/#m...

阅读(41)评论(0)赞 (0)

Java

高性能消息中间件——NATS

11

xiaoli.he 发布于 2019-01-16

前 言 这段时间我的主要工作内容是将公司系统中使用的RabbitMQ替换成NATS,而此之前我对Nats一无所知。经过一段时间紧张的学习和开发之后我顺利的完成了任务,并对消息中间件有了更深的了解。在此感谢同事钟亮在此过程中对我的帮助。NATS属于比较小众的一款中间件产品,中文资料...

阅读(46)评论(0)赞 (0)

Spring

Spring Boot 1.5.19 发布,依赖项更新版本

puefu.he 发布于 2019-01-12

Spring 应用开发框架 Spring Boot 1.5.19 发布。 此次更新主要是依赖项的更新,包括: Upgrade to Jedis 2.9.1 #15683 Upgrade to Git Commit Id Plugin 2.2.6 #15682 Upgrade to...

阅读(37)评论(0)赞 (0)

Spring

使用Spring Cloud Stream和RabbitMQ实现事件驱动的微服务

xubiao.zhuang 发布于 2019-01-10

让我们展示如何使用 Spring Cloud Stream 来设计 事件驱动的微服务 。首先,Spring Cloud Stream首先有什么好处?因为 Spring AMPQ 提供了访问AMPQ工件所需的一切。如果您不熟悉Spring AMPQ,请查看此 repo ,其中包含许...

阅读(40)评论(0)赞 (0)

Java

SpringBoot整合RabbitMQ(一)快速入门

4

songhua.gao 发布于 2019-01-08

MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表,一端往消息队列中不断写入消息,而另一端则可以读取队列中的消息。消息中间件最主要的作用是解耦,中间件最标准的用法是生产者生产消息传送到队列,消费者从队...

阅读(59)评论(0)赞 (0)

Java

Spring Boot集成Java DSL

likai 发布于 2019-01-08

Spring Integration Java DSL已经融合到 Spring Integration Core 5.0 ,这是一个聪明而明显的举动,因为: 基于Java Config启动新Spring项目的每个人都使用它 SI Java DSL使您可以使用Lambdas等新的强...

阅读(63)评论(0)赞 (0)

Spring

Spring Cloud Stream 使用延迟消息实现定时任务(RabbitMQ)

2

puefu.he 发布于 2019-01-03

我们在使用一些开源调度系统(比如:elastic-job等)的时候,对于任务的执行时间通常都是有规律性的,可能是每隔半小时执行一次,或者每天凌晨一点执行一次。然而实际业务中还存在另外一种定时任务,它可能需要一些触发条件才开始定时,比如:编写博文时候,设置2小时之后发送。对于这些开...

阅读(57)评论(0)赞 (0)

编程技术

微服务消息传递协议简介

2

darida 发布于 2018-12-29

当公司将基于各种服务的应用程序集合在一起时,您可以预期它们正在运行微服务架构结构。微服务主要用于实现,提供复杂应用程序的模式,协议和部署。从根本上说,这种架构风格颠覆了与整体扩展,速度,语言障碍和组织相关的许多问题。 虽然由于这些原因大规模采用微服务技术,但我们应该置身于微服务架...

阅读(60)评论(0)赞 (0)

Spring

Spring中实现消息的发送和消费

3

hellas 发布于 2018-12-29

编辑推荐: 本文来自于taobao,本文介绍了在Spring中关于消息的两个主要的框架,rocktmq-spring-boot的设计实现等相关内容。 本文将对rocktmq-spring-boot的设计实现做一个简单的介绍,读者可以通过本文了解将RocketMQ Client端集...

阅读(51)评论(0)赞 (0)

Java

微服务架构下的轻量级定时任务解决方案

2

xubiao.zhuang 发布于 2018-12-27

微服务的概念可以说给程序设计打开了一个新世界,带来了众多的优点,但是也将一些以往容易处理的问题变得复杂,例如:缓存、事务、定时任务等。缓存可以用中间件例如redis、memcached等,事务有诸多分布式事务框架解决,定时任务也有分布式的解决方案,例如quartz、elastic...

阅读(61)评论(0)赞 (0)

Spring

Config统一配置中心

2

yanxinchi 发布于 2018-12-25

方便维护:微服务可能成百个,如果一个个配置都是在项目中配置的话,会给运维造成不必要的麻烦 安全:配置统一是由运维来操作,如果涉及到数据库的账户和密码,肯定是不能让开发知道的 服务端 添加依赖: <!-- config server的依赖 --> <depende...

阅读(74)评论(0)赞 (0)

Java

新手也能看懂,消息队列其实很简单

5

邓龙华 发布于 2018-12-17

“RabbitMQ?”“Kafka?”“RocketMQ?”…在日常学习与开发过程中,我们常常听到消息队列这个关键词。我也在我的多篇文章中提到了这个概念。可能你是熟练使用消息队列的老手,又或者你是不懂消息队列的新手,不论你了不了解消息队列,本文都将带你搞懂消息队列的一...

阅读(44)评论(0)赞 (0)

Spring

Spring Cloud Stream消费失败后的处理策略(四):重新入队(RabbitMQ)

hanze 发布于 2018-12-16

之前我们已经通过 《Spring Cloud Stream消费失败后的处理策略(一):自动重试》 一文介绍了Spring Cloud Stream默认的消息重试功能。本文将介绍RabbitMQ的binder提供的另外一种重试功能:重新入队。 动手试试 准备一个会消费失败的例子,可...

阅读(39)评论(0)赞 (0)