博客首页 → 消息队列

最新文章列表

RocketMQ 常用消息类型

关注我 文章首发于公众号《程序员果果》 地址 : https://mp.weixin.qq.com/s/dYqGd9zi2mNelsNNLIribg   消息发送示例 导入依赖： <dependency> <grou ...
RocketMQJava消息队列 
u010562966 评论(0) 有324人浏览 2021-02-02 14:42

RocketMQ 简介

关注我 文章首发于公众号《程序员果果》 地址 : https://mp.weixin.qq.com/s/qSsHBNDghZAlkUVBYM6LDA   简介 RocketMQ是由阿里捐赠给Apache的一款低延迟、高并发、高可用、高可靠的分布式消息中间件。经历了淘宝双十一的洗礼。RocketMQ既可为分布式应用系统提供异步解耦和削峰填谷的能力，同时也具备互联网应用所需的 ...
rocketmq消息中间件消息队列 
u010562966 评论(0) 有381人浏览 2021-01-19 09:13

RocketMQ（02）——发送消息的三种方式

发送消息的三种方式   同步发送 Producer在进行消息发送时可以是阻塞的，也可以是非阻塞的。具体对应到发送方式一共有三种，分别是同步、异步和单向的（ONEWAY）。之前介绍的调用send()返回SendResult的方法是阻塞的，它一定要等到Broker进行了响应后才会返回，才能继续往下执行。对于下面的代码就是只有第一条消息发送完了后，才能发送第二条消息，接着是第三条。这种阻塞发送的方 ...
RocketMQ消息队列发送同步异步
234390216 评论(0) 有2072人浏览 2019-12-27 23:37

RocketMQ（01）——简介

RocketMQ简介 笔者使用的是Apache RocketMQ，官网是http://rocketmq.apache.org/。RocketMQ是Alibaba开源的一个分布式消息队列，可以通过http://rocketmq.apache.org/dowloading/re ...
ApacheRocketMQ简介消息队列
234390216 评论(0) 有2276人浏览 2019-12-07 23:51

Spring Cloud（12）——基于Apache Kafka的Stream实现

基于Apache Kafka的Stream实现 如果你的应用使用了Apache Kafka，你需要把它和Spring Cloud进行整合。需要在应用中添加如下依赖。 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cl ...
SpringCloudStreamKafka消息队列
234390216 评论(0) 有2929人浏览 2019-09-23 23:17

Spring Cloud（11）——基于RocketMQ的Stream实现

基于RocketMQ的Stream实现 Spring Cloud Stream是一个消息收发的框架，它提供了一套标准，应用程序只需要按照它的标准进行消息的收发，而不用关注具体的实现机制。具体的实现可以基于不同的消息中间件进行不同的实现，比如Kafka的实现、RabbitMQ的实现、RocketMQ的实现等。官方已经提供了Kafka和RabbitMQ的实现，RocketMQ的实现由Alibaba负 ...
Spring CloudStreamRocketMQ消息队列MQ
234390216 评论(0) 有4504人浏览 2019-09-20 23:29

项目中使用消息队列的原因

为什么要使用消息队列              做过互联网企业级应用开发的同学们，不管是在大厂的还是在小厂的，都会知道或熟悉消息队列。那么，在做企业级应用开发的过程中，为啥需要用消息队列呢？下面是小弟在日常工作中整理出来的心得，希望能帮助有需要的同学。       在正常的项目中使用消息队列，主要是为了以下三种场景：解耦，异步，削峰。下面分别针对这三种场景，做下简单的描述。       1 ...
架构MQ消息队列 
zh-workhard-Java 评论(0) 有499人浏览 2019-09-03 18:13

Kafka源码分析 Producer客户端

Kafka的Producer新客户端API实现(JAVA) 导读 本节从新的Producer API示例开始， Producer 生产者线程：异步发送消息，提供一个Callback；同步发送消息，则调用Future.get()会Block住直到结果返回。 1 2 3
大数据kafka消息队列源码 
yuqingshui 评论(0) 有440人浏览 2019-07-04 21:57

【消息队列】什么是消息队列

https://juejin.im/post/5cb025fb5188251b0351ef48 什么是消息队列？ 前言 只有光头才能变强。 文本已收录至我的GitHub仓库，欢迎Star：github.com/ZhongFuChen… 公司用到的很多技术，自己之前都没学过(尬)，于是只能慢慢补了。这次给大家写写我学习消息队列的笔记，希望对大家有帮助。 一、什么是消息队列？ 消息队列不知道大家 ...
消息队列 
omyyal 评论(0) 有492人浏览 2019-06-23 16:03

springboot 整合 rabbitmq

    这篇文章，我们使用springboot来简单整合一下RabbitMQ，由于sprinboot的 “约定优于配置“，使得我们整合起来非常方便。参考文档   实现功能：  自动申明队列、交换器和绑定  使用自定义的MessageConvert如何进行配置  如何传递 JavaBean 消息和普通消息  如何手动签收消息 实现要点：     ** 自定申明队列、交换器和绑定 ...
springbootrabbitmqspringboot整合rabbitmqrabbitmq整合sprinboot消息队列 
huan1993 评论(0) 有2246人浏览 2018-10-24 20:34

RocketMQ与Kafka对比

      淘宝内部的交易系统使用了淘宝自主研发的Notify消息中间件，使用Mysql作为消息存储媒介，可完全水平扩容，为了进一步降低成本，我们认为存储部分可以进一步优化，2011年初，Linkin开源了Kafka这个优秀的消息中间件，淘宝中间件团队在对Kafka做过充分Review之后，Kafka无限消息堆积，高效的持久化速度吸引了我们，但是同时发现这个消息系统主要定位于日志传输，对于使用在淘 ...
MQ消息队列 
zl378837964 评论(0) 有3812人浏览 2018-05-03 00:55

activemq消息队列-使用监听器来接收消息（常用）

  //点对点-使用监听器接收消息public class ConsumerListener {       // tcp 地址 服务器器端地址    //public static final String BROKER_URL =ActiveMQConnection.DEFAULT_BROKER_URL;  // 其值为 "tcp://localhost:61616";  ...
消息队列 
zw7534313 评论(0) 有2002人浏览 2018-04-25 10:29

activemq消息队列-发布/订阅

    发布-订阅消息：一个消息多次消费（群发）     阻塞的方式接收消息      public class TopicProducter {        // 发送次数   public static final int SEND_NUM = 10;   // tcp 地址 服务器器端地址   //public static final String BROKER_URL =A ...
消息队列 
zw7534313 评论(0) 有495人浏览 2018-04-25 10:12

activemq消息队列-点对点通讯

    点对点通讯：消息发送-Queue-消息接收，消息发送到队列，消息接收者阻塞式接收消息。                        如果没有消息，接收消息方法receive()阻塞。     package mq.p2p; import java.util.concurrent.atomic.AtomicInteger; import javax.jms.Connection ...
消息队列 
zw7534313 评论(0) 有537人浏览 2018-04-24 21:03

XSI IPC通信之消息队列

    消息队列是消息的链接表，存储在内核中，由消息队列标识符（或称为队列ID）标识。     下表列出了影响消息队列的系统限制。其中“导出的”表示这种限制来源于其他限制。比如 Linux 系统中的最大消息数是根据最大队列数和队列中所允许的最大数据量来决定的，最大队列数又受 RAM 数量多少的影响，队列的最大字节数限制进一步限制了队列中将要存储的消息的最大长度。     每个队列都关联有一个 ms ...
进程间通信XSI IPC消息队列 
aisxyz 评论(0) 有492人浏览 2018-04-15 10:54

XSI IPC 相似特征介绍

    有 3 种称作 XSI IPC 的 IPC：消息队列、信号量以及共享存储器，本节先介绍它们相类似的特征，后面再分别说明它们各自的特殊功能（XSI IPC 没有使 ...
进程间通信IPC消息队列信号量共享存储 
aisxyz 评论(0) 有482人浏览 2018-02-08 23:48

转载 kafka原理解读

Kafka Kafka是最初由Linkedin公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于hadoop的批处理系统、低延迟的实时系统、storm/Spark流式处理引擎，web/nginx日志、访问日志，消息服务等等，用scala语言编写，L ...
消息队列 
renhanxiang 评论(0) 有578人浏览 2018-02-03 11:07

消息队列之 Kafka

本文引自我的博客：https://juejin.im/post/5a67f7e7f265da3e3c6c4f8b   Kafka 特点 Kafka 最早是由 LinkedIn 公司开发一种分布式的基于发布/订阅的消息系统，之后成 ...
KafkaMQ消息队列 
Tyrion 评论(0) 有3876人浏览 2018-01-20 15:54

理解队列、消息队列--用redis实现消息队列

理解队列和消息队列   队列（来自百度百科）：是一种特殊的线性表，特殊之处在于它只允许在表的前端（front）进行删除操作，而在表的后端（rear）进行插入操作，和栈一样，队列是一种操作受限制的线性表。进行插入操作的端称为队尾，进行删除操作的端称为队头。   消息队列（来自百度百科）：是在消息的传输过程中保存消息的容器。   从队列和消息队列的定义看来，看不出什么相似之处。但我理解它 ...
消息队列队列redis实现消息队列 
moon_walker 评论(0) 有16393人浏览 2017-11-30 22:01

[转载]PHP-AMQP实践应用

原文地址：PHP-AMQP实践应用作者：dream 优点：可以解决服务器处理的并发问题。高级消息队列协议（AMQP）是一个异步消息传递所使用的应用层协议规范。作为线路层协议，而不是API（例如JMS），AMQP 客户端能够无视消息的来源任意发送和接受信息。现在，已经有相当一部分不同平台的服务器和客户端可以投入使用。（一）基本概念 RabbitMQ 是流行的开源消息队列系统，用erlang语 ...
php队列AMQP消息队列 
18237103303 评论(0) 有712人浏览 2017-11-02 21:31

最近博客热门TAG

Java(141747) C(73651) C++(68608) SQL(64571) C#(59609) XML(59133) HTML(59043) JavaScript(54918) .net(54785) Web(54513) 工作(54116) Linux(50906) Oracle(49876) 应用服务器(43288) Spring(40812) 编程(39454) Windows(39381) JSP(37542) MySQL(37268) 数据结构(36423)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics