原文地址：http://www.jianshu.com/p/f63820fe2638 当生产者投递消息到broker，rabbitmq把消息分发到消费者。 如果设置了autoAck=true 消费者会自动确认收到信息。这时broker会立即将消息删除，这种情况下如果消费者出现异常（连接中断）该消息就... ...
分类：
其他好文 时间：
2017-09-03 18:44:17
阅读次数：
155
Concurrency与Prefetch 在通常的使用中(Java项目)，我们一般会结合spring-amqp框架来使用RabbitMQ，spring-amqp底层调用RabbitMQ的java client来和Broker交互，比如我们会用如下配置来建立RabbitMQ的连接池、声明Queue以及... ...
分类：
其他好文 时间：
2017-09-03 17:56:44
阅读次数：
545
AMQPAMQP协议是一个高级抽象层消息通信协议，RabbitMQ是AMQP协议的实现。它主要包括以下组件： 1.Server(broker): 接受客户端连接，实现AMQP消息队列和路由功能的进程。 2.Virtual Host:其实是一个虚拟概念，类似于权限控制组，一个Virtual Host里 ...
分类：
其他好文 时间：
2017-09-02 14:10:03
阅读次数：
191
集群架构 搭建一套测试集群，共三个节点，每个节点上面都有procuder/broker/consumer角色。没有WebUI页面，架构如下： kafka架构 在系统架构中，将消息系统独立可起到架构解耦、易扩展、灵活性强、可恢复、数据冗余、异步通讯等优点。 kafka是分布式消息系统软件，实现了消息发 ...
分类：
其他好文 时间：
2017-09-01 17:54:27
阅读次数：
196
在oracle11g中配置dg的时候，我们需要配置log_archive_dest_1=xxxlog_archive_dest_2=xxx但是到12.1版本之后，不需要配置log_archive_dest_2,如果配置的话如下错误，清空此参数即可。ORA-16698:LOG_ARCHIVE_DEST_nparametersetforobjecttobeadded
Failed.ToclearLOG_ARCHIVE_D..
分类：
其他好文 时间：
2017-08-30 19:58:46
阅读次数：
103
一. Kafka Connect简介 Kafka是一个使用越来越广的消息系统，尤其是在大数据开发中（实时数据处理和分析）。为何集成其他系统和解耦应用，经常使用Producer来发送消息到Broker，并使用Consumer来消费Broker中的消息。Kafka Connect是到0.9版本才提供的并 ...
分类：
Web程序 时间：
2017-08-30 00:57:27
阅读次数：
339
1.python-kafka： api送上：https://kafka-python.readthedocs.io/en/latest/apidoc/KafkaConsumer.html 2.实现一个broker、topic可配置的生产者与消费者： 3.实现命令行输入topic和partition， ...
分类：
编程语言 时间：
2017-08-24 21:23:03
阅读次数：
528
从JMS到KafKa JMS （1）JMS概念 JMS（Java Message Service,java消息服务）API是一个消息服务的标准或者说是规范，允许应用程序组件基于JavaEE平台创建、发送、接收和读取消息。它使分布式通信耦合度更低，消息服务更加可靠以及异步性。 （2）消息模型 P2P： ...
分类：
其他好文 时间：
2017-08-21 09:48:07
阅读次数：
200
为了安装过程对一些参数的理解，我先在这里提一下kafka一些重点概念,topic,broker,producer,consumer,message,partition,依赖于zookeeper, kafka是一种消息队列,他的服务端是由若干个broker组成的，broker会向zookeeper，p ...
分类：
其他好文 时间：
2017-08-18 22:23:00
阅读次数：
168
之前写过kafka_2.9.2-0.8.2.2版本的安装，kafka在新的0.9版本以上改动比较大，配置和api都有很大更新，并且broker对应的partition支持多线程生产和消费，所以性能比之前好得多，比如老版本的kafka单机每秒可以推送100条数据，但是新版的可以每秒推送达到上千条数据， ...
分类：
其他好文 时间：
2017-08-17 12:39:47
阅读次数：
1267
