3 NPException

尚未进行身份认证

学无止境

等级
TA的排名 3k+

9.介绍Spring Cloud Stream与RabbitMQ集成

介绍Spring Cloud Stream与RabbitMQ集成前言Spring Cloud Stream是一个建立在Spring Boot和Spring Integration之上的框架,有助于创建事件驱动或消息驱动的微服务。在本文中,我们将通过一些简单的例子来介绍Spring Cloud Stream的概念和构造。Bindings — 声明输入和输出通道的接口集合。Binder — ...

2020-02-13 14:07:48

8.RabbitMQ实现集群高可用

RabbitMQ实现集群高可用前言为什么搭建rabbitmq集群?rabbitmq集群有那些模式?如何搭建Rabbitmq集群?rabbitmq镜像高可用策略有那些?RabbitMQ这款产品本身的优点众多,大家最看好的便是他的异步化提高系统抗峰值能力,然后便是系统及功能结构解耦,既然它如此重要,那么我们就需要考虑它的高可用性。rabbitmq有3种模式:单一模式:即单机情况不做...

2020-02-13 14:04:46

7.springboot2.x集成RabbitMQ实现消息发送确认与消息接收确认实现消息保障100%的投递

springboot2.x集成RabbitMQ实现消息发送确认与消息接收确认实现消息保障100%的投递前言消息如何保障100%的投递成功?幂等性概念详解在海量订单产生的业务高峰期,如何避免消息的重复消费的问题?Confirm确认消息、Return返回消息消息如何保障100%的投递成功?1.1 什么是生产端的可靠性投递?保障消息的成功发出保障MQ节点的成功接收发送端收到MQ...

2020-02-13 13:57:32

6.Springboot2.x集成RabbitMQ实现消费者限流,手动ack确认

Springboot2.x集成RabbitMQ实现消费者限流,手动ack确认前言我们在实际项目中,可能在mq中积累了成千上万的消息,如果我们不进行限流,当我们打开消费者的时候一下子成千上万的消息一下子冲击过来,可能会造成服务器宕机,或者业务出现严重漏洞,所以我们需要进行消费者限流。首先我的springboot版本,springBootVersion = ‘2.2.1.RELEASE’。其他版本...

2020-02-13 13:50:36

5.Springboot2.x集成Rabbitmq实现延时消费

Springboot2.x集成Rabbitmq实现延时消费前言比如我们在使用mq的时候并不希望立即收到消息,比如实现3分钟后再查询订单,这时候我们就需要使用延迟消息发送了。RabbitMQ如何实现迟队列?AMQP协议和RabbitMQ队列本身没有直接支持延迟队列功能。但是我们可以通过RabbitMQ的两个特性来曲线实现延迟队列:特性1、Time To Live(TTL)1.Rabbit...

2020-02-13 13:49:41

4.Springboot2.x集成 RabbitMQ的几种常见用法

Spring Boot 集成 RabbitMQ的几种常见用法前言Spring Boot 集成 RabbitMQ 非常简单,如果只是简单的使用配置非常少,Spring Boot 提供了spring-boot-starter-amqp 项目对消息各种支持。引入依赖compile group: 'org.springframework.boot', name: 'spring-boot-star...

2020-01-15 20:04:50

3.RabbitMQ的简单介绍

RabbitMQ的简单介绍前言RabbitMQ是实现AMQP(高级消息队列协议)的消息中间件的一种,最初起源于金融系统,用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。RabbitMQ主要是为了实现系统之间的双向解耦而实现的。当生产者大量产生数据时,消费者无法快速消费,那么需要一个中间层保存这个数据。AMQP,即Advanced Message Queuing Pr...

2020-01-15 20:04:20

2.各大主流消息中间件综合对比介绍

各大主流消息中间件综合对比介绍前言消息队列已经逐渐成为企业系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能,成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件,如老牌的ActiveMQ、RabbitMQ,炙手可热的Kafka,阿里巴巴自主开发RocketMQ等。今天主要来介绍了下几大主流消息中间件的区别与联系。主流消息中间件——ActiveM...

2020-01-15 20:03:55

1.RabbitMQ的环境搭建

RabbitMQ在Linux下安装前言由于RabbitMQ是建立在Erlang OTP平台上的,所以我们需要安装Erlang和RabbitMQ。我们可以使用yum方式安装,rpm方式安装,源码安装。这里我们采用rpm方式安装。RabbitMQ是Erlang语言编写,所以Erang环境必须要有,注:Erlang环境一定要与RabbitMQ版本匹配:https://www.rabbitmq.co...

2020-01-15 20:02:02

CSDN博客个人主页左侧栏添加微信二维码

栏目内容支持HTML格式,不支持JS,最多添加1个自定义栏目,VIP、博客专家、企业博客才可在个人详情页显示第一步:我们去公众号后台下载个人二维码保存在本地。第二步:发布一篇文章并贴上自己的二维码,然后把图片上传到csdn服务器,这时候我们就拿到图片路径了第三步:在个人博客主页选择顶部的“管理博客”,进到管理博客界面后,选择“博客模块设置”,编辑自定义栏目。第四步...

2019-12-11 17:59:59

图床工具的使用---PicGo

前言所谓图床工具,就是自动把本地图片转换成链接的一款工具,网络上有很多图床工具,就目前使用种类而言,PicGo 算得上一款比较优秀的图床工具。它是一款用 Electron-vue 开发的软件,可以支持微博,七牛云,腾讯云COS,又拍云,GitHub,阿里云OSS,SM.MS,imgur 等8种常用图床,功能强大,简单易用下载地址:https://github.com/Molunerfinn...

2019-12-05 09:59:28

RabbitMQ安装

RabbitMQ在Linux下安装前言由于RabbitMQ是建立在Erlang OTP平台上的,所以我们需要安装Erlang和RabbitMQ。我们可以使用yum方式安装,rpm方式安装,源码安装。这里我们采用rpm方式安装。RabbitMQ是Erlang语言编写,所以Erang环境必须要有,注:Erlang环境一定要与RabbitMQ版本匹配:https://www.rabbitmq.co...

2019-12-04 15:10:50

java中的PO、BO、VO、QO、POJO、DTO、DAO分别代表什么意思

PO:persistantobject持久对象BO:businessobject业务对象VO:valueobject值对象,ViewObject表现层对象QO:查询对象POJO:plainordinaryjavaobject简单java对象DTO:DataTransferObject数据传输对象DAO:dataaccesso...

2019-12-03 10:24:33

springboot2.x集成RabbitMQ实现消息发送确认 与 消息接收确认(ACK)

前言首先看回调机制:消息不管是否投递到交换机都进行ConfirmCallback回调,投递成功ack=true,否则为false 交换机匹配到队列成功则不进行ReturnCallback回调,否则先进行ReturnCallback回调再进行ConfirmCallback回调 如果消息成功投递到交换机,但没匹配到队列,则ConfirmCallback回调ack仍为true我的spri...

2019-11-28 16:43:11

Springboot2.x集成Rabbitmq实现消费者限流,手动ack确认

前言我们在实际项目中,可能在mq中积累了成千上万的消息,如果我们不进行限流,当我们打开消费者的时候一下子成千上万的消息一下子冲击过来,可能会造成服务器宕机,或者业务出现严重漏洞,所以我们需要进行消费者限流。首先我的springboot版本,springBootVersion = '2.2.1.RELEASE'。其他版本配置差别都不大。首先看一下配置,这里只用到了没有注释的配置:s...

2019-11-28 10:32:07

Springboot2.x集成Rabbitmq实现延时消费

前言比如我们在使用mq的时候并不希望立即收到消息,比如实现3分钟后再查询订单,这时候我们就需要使用延迟消息发送了。RabbitMQ如何实现迟队列?AMQP协议和RabbitMQ队列本身没有直接支持延迟队列功能。但是我们可以通过RabbitMQ的两个特性来曲线实现延迟队列:特性1、Time To Live(TTL)1.RabbitMQ可以针对Queue设置x-expires ...

2019-11-27 17:51:41

springboot2.x集成RabbitMQ实现延迟队列报错unknown exchange type 'x-delayed-message'

报错如下:ShutdownSignalException: connection error; protocol method:#method<connection.close>(reply-code=503, reply-text=COMMAND_INVALID - unknown exchange type 'x-delayed-message', class-id=40, ...

2019-11-27 17:15:39

新版Notepad++64位的Json格式化插件

1.下载:首先给出下载地址:64位下载地址:Jsonviewer2 32位下载地址:JSONViewer Notepad++ plugin2.安装 :1、下载插件压缩包并解压出dll:Jsonviewer2.dll(64位)或NPPJSONViewer.dll(32位);2.、拷贝对应dll到Notepad++安装目录下的plugins目录,并建一个文件夹,文件夹名字一定要和文件名J...

2019-11-26 16:35:34

idea构建编译spring5.1.x源码环境

前言我们平时天天写项目,一直用的spring,个人觉得,每天都在面对spring,确从来没有编译过spring源码,有点不太合适,所以今天我们就来编译一下源码环境,顺便做一个笔记。这里给出我的配置:JDK1.8.0_172,IntelliJ IDEA 2019.1 (Ultimate Edition),gradle-5.4。注意:gradle版本需要4.2以上第一步:保证我们环境已...

2019-11-26 11:30:16

springboot连接elasticsearch 报错failed to load elasticsearch nodes。。。

具体报错如下:failed to load elasticsearch nodes : org.elasticsearch.client.transport.NoNodeAvailableException: None of the configured nodes are available: [{#transport#-1}{m-smEJI0TKOTPDV_eVS1hQ}{127.0....

2019-11-22 17:55:03

查看更多

勋章 我的勋章
  • GitHub
    GitHub
    绑定GitHub第三方账户获取
  • 签到达人
    签到达人
    累计签到获取,不积跬步,无以至千里,继续坚持!
  • 推荐红人
    推荐红人
    发布高质量Blink获得高赞和评论,进入推荐栏目即可获得
  • 阅读者勋章Lv1
    阅读者勋章Lv1
    授予在CSDN APP累计阅读博文达到3天的你,是你的坚持与努力,使你超越了昨天的自己。
  • 持之以恒
    持之以恒
    授予每个自然月内发布4篇或4篇以上原创或翻译IT博文的用户。不积跬步无以至千里,不积小流无以成江海,程序人生的精彩需要坚持不懈地积累!
  • 1024勋章
    1024勋章
    #1024程序员节#活动勋章,当日发布原创博客即可获得
  • 勤写标兵Lv4
    勤写标兵Lv4
    授予每个自然周发布9篇以上(包括9篇)原创IT博文的用户。本勋章将于次周周三上午根据用户上周的博文发布情况由系统自动颁发。