概念说明 通常一个消息队列需要掌握的知识点有Topic（主体）、Producer（生产者）、Consumer（消费者）、Queue（队列）、Delivery Semantics（消息传递范式） 蛋疼的是不同的消息队列关于这些名词叫法不一样，含义也不是很精确。所以阿里起了一个项目OpenMessagi ...
分类：
其他好文 时间：
2020-05-29 10:38:16
阅读次数：
55
Kafka最初考虑的问题是，customer应该从brokes拉取消息还是brokers将消息推送到consumer，也就是pull还push。在这方面，Kafka遵循了一种大部分消息系统共同的传统的设计：producer将消息推送到broker，consumer从broker拉取消息。 一些消息系 ...
分类：
其他好文 时间：
2020-05-27 09:22:10
阅读次数：
405
Kafka快速入门（四）——Kafka高级功能一、Kafka无消息丢失配置1、Kafka消息丢失简介Kafka只针对已提交消息（committedmessage）做有限度的持久化保证。当Kafka的若干个Broker成功地接收到一条消息并写入到日志文件后，会通知生产者程序相应消息已成功提交。多少个Broker成功保存消息算是已提交，可以由Producer参数或Broker端参数指定。有限度的持久化
分类：
其他好文 时间：
2020-05-24 10:09:30
阅读次数：
56
先贴几篇有意思的讨论 https://www.qt.io/blog/2010/06/17/youre-doing-it-wrong#commento-login-box-container https://www.qt.io/blog/2006/12/04/threading-without-the ...
分类：
编程语言 时间：
2020-05-22 09:22:06
阅读次数：
77
RabbitMQ介绍 生产者与消费者模型在编码的过程中,和生活中都较为常见,我可以把它比作一个缓冲的仓库, 如果再一次秒杀活动中,抢购的人太多,而后台订单处理的服务器明显不够, 订单过量就会导致宕机的风险,最简单的办法获取就是加服务器,可是秒杀结束了你要把它卸掉吗? 消息队列（MQ）是一种应用程序对 ...
分类：
其他好文 时间：
2020-05-19 09:11:15
阅读次数：
71
docker安装部署kafka 1.下载镜像 docker pull wurstmeister/zookeeper docker pull wurstmeister/kafka 2.启动zookeeper容器 docker run -d --name zookeeper -p 2181:2181 - ...
分类：
其他好文 时间：
2020-05-18 16:45:31
阅读次数：
49
Producer异步发送演示在上文中介绍了AdminClientAPI的使用，现在我们已经知道如何在应用中通过API去管理Kafka了。但在大多应用开发中，我们最常面临的场景就是发送消息到Kafka，或者从Kafka中消费消息，也就是典型的生产/消费模式。而本文将要演示的就是如何使用ProducerAPI将消息发送至Kafka中，使应用成为一个生产者。ProducerAPI具有以下几种发送模式：异
参考：https://kafka.js.org/docs 1.封装kafkaUtil类const { Kafka, logLevel } = require('kafkajs') //const cache = require('../conn/redis.js'); const kafka = n ...
分类：
Web程序 时间：
2020-05-16 09:12:34
阅读次数：
156
结构图 依赖 package com.activemq.activemqdemo.p2p; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class JMSProducer { pub ...
分类：
其他好文 时间：
2020-05-08 18:35:33
阅读次数：
58
1.消费者用--bootstrap-server方式启动，消费的偏移量offset保存在broker的一个主题_consumer_offsets里，此主题默认50个分区。 2.zk中的version-2文件夹存储了关于kafka的一些数据。 3.server.properties里的log.dir项 ...
分类：
其他好文 时间：
2020-05-02 23:17:21
阅读次数：
117
