delphi网站开发,网站维护做啥的,网站蜘蛛记录器 v1.2,游戏网站开发过程目录前言#xff1a;1、Kafka是什么2、JMS是什么3、Kafka核心组件#xff08;重点#xff09;总结#xff1a; 目录
前言#xff1a;
作为流式计算中的一个组件#xff0c;对于它的组成以及运行的原理#xff0c;学习者也需要相关的了解。以下主要简单介绍了kafka是什…目录前言1、Kafka是什么2、JMS是什么3、Kafka核心组件重点总结 目录
前言
作为流式计算中的一个组件对于它的组成以及运行的原理学习者也需要相关的了解。以下主要简单介绍了kafka是什么以及对应的组件有哪些除此之外重点介绍了JMS毕竟JMS也算是Kafka的核心还是有必要了解一下。
1、Kafka是什么
在流式计算中Kafka一般用来缓存数据Storm通过消费Kafka的数据进行计算。
Apache Kafka是一个开源消息系统由Scala写成。是由Apache软件基金会开发的一个开源消息系统项目。Kafka最初是由LinkedIn开发并于2011年初开源。2012年10月从Apache Incubator毕业。该项目的目标是为处理实时数据提供一个统一、高通量、低等待的平台。Kafka是一个分布式消息队列生产者、消费者的功能。它提供了类似于JMS的特性但是在设计实现上完全不同此外它并不是JMS规范的实现。 Kafka对消息保存时根据Topic进行归类发送消息者称为Producer,消息接受者称为Consumer,此外kafka集群有多个kafka实例组成每个实例(server)成为broker。无论是kafka集群还是producer和consumer都依赖于zookeeper集群保存一些meta信息来保证系统可用性。
2、JMS是什么
2.1、JMS的基础 JMS是什么JMS是Java提供的一套技术规范 JMS干什么用用来异构系统 集成通信缓解系统瓶颈提高系统的伸缩性增强系统用户体验使得系统模块化和组件化变得可行并更加灵活 总结为什么需要消息队列重要 消息系统的核心作用就是三点解耦异步和并行 通过什么方式生产消费者模式生产者、服务器、消费者
2.2、JMS消息传输模型
点对点模式一对一消费者主动拉取数据消息收到后消息清除 点对点模型通常是一个基于拉取或者轮询的消息传送模型这种模型从队列中请求信息而不是将消息推送到客户端。这个模型的特点是发送到队列的消息被一个且只有一个接收者接收处理即使有多个消息监听者也是如此。发布/订阅模式一对多数据生产后推送给所有订阅者 发布订阅模型则是一个基于推送的消息传送模型。发布订阅模型可以有多种不同的订阅者临时订阅者只在主动监听主题时才接收消息而持久订阅者则监听主题的所有消息即时当前订阅者不可用处于离线状态。
2.3、JMS核心组件 Destination消息发送的目的地也就是前面说的Queue和Topic。 Message 从字面上就可以看出是被发送的消息。 Producer 消息的生产者要发送一个消息必须通过这个生产者来发送。 MessageConsumer 与生产者相对应这是消息的消费者或接收者通过它来接收一个消息。 Message StreamMessageJava 数据流消息用标准流操作来顺序的填充和读取。 MapMessage一个Map类型的消息名称为 string 类型而值为 Java 的基本类型。 TextMessage普通字符串消息包含一个String。 ObjectMessage对象消息包含一个可序列化的Java 对象 BytesMessage二进制数组消息包含一个byte[]。 XMLMessage: 一个XML类型的消息。 最常用的是TextMessage和ObjectMessage。 通过与ConnectionFactory可以获得一个connection 通过connection可以获得一个session会话。
3、Kafka核心组件重点
Topic 消息根据Topic进行归类Producer发送消息者Consumer消息接受者broker每个kafka实例(server)Zookeeper依赖集群保存meta信息。
总结
本篇文章只是对Kafka做了一个简单的介绍。通过本篇文章你只要能知道Kafka的核心组件有哪些以及Kafka是什么就OK当然能了解JMS更好。下面的文章中会对Kafka做一个深入的介绍。
