在Kafka中我们把产生消息的那一方称为生产者比如我们经常回去淘宝购物你打开淘宝的那一刻你的登陆信息登陆次数都会作为消息传输到Kafka后台当你浏览购物的时候你的浏览信息你的搜索指数你的购物爱好都会作为一个个消息传递给Kafka后台然后淘宝会根据你的爱好做智能推荐致使你的钱包从来都禁不住诱惑那么这些生产者产生的消息是怎么传到Kafka应用程序的呢发送过程是怎么样的呢尽管消息的产生非常简单但是消息的发送过程还是比较复杂的如图uploadfeebbfabddpng我们从创建一个ProducerRecord对象开始ProducerRecord是Kafka中的一个核心类它代表了一组Kafka需要发送的
2023-10-07 19:15 875 0 kafka
Kafka安装我在Kafka系列第一篇应该比较详细了详情见带你涨姿势的认识一下kafka这篇文章那我们还是主要来说一下Kafka中的重要参数配置吧这些参数对Kafka来说是非常重要的broker端配置brokerid每个kafkabroker都有一个唯一的标识来表示这个唯一的标识符即是brokerid它的默认值是这个值在kafka集群中必须是唯一的这个值可以任意设定port如果使用配置样本来启动kafka它会监听端口修改port配置参数可以把它设置成任意的端口要注意如果使用以下的端口需要使用root权限启动kakfazookeeperconnect用于保存broker元数据的Zookeeper
2023-10-05 18:46 1509 0 kafka
什么是KafkaKafka是由Linkedin公司开发的它是一个分布式的支持多分区多副本基于Zookeeper的分布式消息流平台它同时也是一款开源的基于发布订阅模式的消息引擎系统Kafka的基本术语消息Kafka中的数据单元被称为消息也被称为记录可以把它看作数据库表中某一行的记录批次为了提高效率消息会分批次写入Kafka批次就代指的是一组消息主题消息的种类称为主题Topic可以说一个主题代表了一类消息相当于是对消息进行分类主题就像是数据库中的表分区主题可以被分为若干个分区partition同一个主题中的分区可以不在一个机器上有可能会部署在多个机器上由此来实现kafka的伸缩性单一主题中的分区有
2023-10-02 18:41 998 0
RabbitMQ安装笔者是在CentOS环境下使用Docker安装RabbitMQ简单快捷查询镜像javadockersearchrabbitmqmanagementdockersearchrabbitmqmanagementNAMEDESCRIPTIONSTARSOFFICIALAUTOMATEDmacintoshplusrabbitmqmanagementBasedonrabbitmqmanagementwhitpythonandOKtransmitsmsrabbitmqshardedForkofrabbitmqmanagementwithshardedexcyunyanrabbitmqd
前言开头RabbitMQ是一款使用Erlang语言开发的实现AMQPAdvancedMessageQueuingProtocol的开源消息中间件它支持多种客户端如PythonRubyNETJavaJMSCPHPActionScriptXMPPSTOMP等支持AJAX持久化用于在分布式系统中存储转发消息在易用性扩展性高可用性等方面表现不俗所以笔者整理了这篇RabbitMQ入门的文章根据下方思维导图来一一介绍uploadabdbfadfbcfdfpng什么是消息中间件消息队列中间件是分布式系统中重要的组件它提供了一种异步可靠可伸缩的消息传递机制主要解决应用解耦异步消息流量削锋等问题实现高性能高可用
