01、JMS规范介绍

2024-05-07 08:36
文章标签 介绍 01 规范 jms

本文主要是介绍01、JMS规范介绍，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

01、JMS规范介绍

在我们正式学习Kafka之前，先来了解下JMS，因为这可以在一定程度上帮助你更加深入的理解和学习Kafka。

1、 JMS简介

JMS，全称Java Mesage Service，即Java消息服务应用程序接口，是一个Java平台中关于面向消息中间件的AP!，用于在两个应用程序之间、或者分布式系统中发送消息，进行异步通信。

JMS是一种与厂商无关的API，用来访问消息、收发系统消息，它类似于JDBC。

JMS可以自己使用Java代码或者别的代码来编写，开源的实现有Active MQ、阿里的Rocket MQ(已贡献给Apache)、Kafka等。

JMS（Java Message Service）是Java平台中关于面向消息中间件（MOM）的一个API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。JMS API定义了一组规范，允许应用程序组件通过消息传递进行通信，从而实现松耦合的消费者和生产者。JMS支持两种消息发送和接收模型：点对点（P2P）模型和发布/订阅模型。

在点对点模型中，消息生产者发送消息到队列，消息消费者从队列中接收消息，每个消息只有一个消费者。而在发布/订阅模型中，消息生产者向主题发布消息，而消息消费者订阅主题以接收消息，允许一个消息被多个消费者消费。

我们为什么要使用消息队列呢?

有些网站会在某些时间段的访间量暴增，何如各电商购物平台的秒杀活动、12306枪票等场最，而在访问量暴增的时候，对服务器就是一个非常大的孝验!服务器能够处理的访问最是有眼的，例如某公司的服务器能够同时处理50W连接消求，但是在活动的期间，访问最到达了70W，那么此时婴么会有20W的访问被丢弃，婴么干能服务器崔爽，无论是哪一种结果，对于用户都是非常不友好的!那么，如何去处理这样的场最的?此时犹借要消息队列了!

面对比较大的流量冲击，在网站系统中一般都会有一个消息存储/缓存系统，网站就可以按照自己的负载能力来消费这些消息，这就是一个消息队列，或者叫消息中间件。

image-20240506105117832

2、 JMS 核心组件

JMS定义了几种核心概念，包括：

  1. JMS Provider：实现JMS接口和规范的消息中间件，也就是MQ服务器（如ActiveMQ, RabbitMQ, Kafka等）。
  2. JMS Producer（消息生产者）：创建和发送JMS消息的客户端应用。
  3. JMS Consumer（消息消费者）：接收和处理JMS消息的客户端。
  4. JMS Message：JMS中用于传递的数据对象，由消息头、消息属性和消息体组成。
  5. Destination（目的地）：消息发送的目标位置，可以是队列（Queue）或主题（Topic）。
  6. Connection Factory：用于创建与JMS提供者之间的连接的工厂对象。
  7. Connection：代表客户端与JMS提供者之间的通信链路。
  8. Session：提供创建、发送和接收消息的操作环境，可以是点对点或发布订阅。
  9. Message Listener：消息监听器，用于异步接收消息。

JMS消息由三部分组成：消息头、消息属性和消息体。消息头包含了如JMSDestination、JMSDeliveryMode、JMSExpiration、JMSPriority、JMSMessageID等属性，这些属性提供了关于消息如何发送和接收的重要信息。

JMS提供可靠性、灵活性和可扩展性，支持事务处理、持久化消息、异步消息处理等特性。它还可以与其他企业级技术集成，如企业服务总线（ESB）、业务流程管理（BPM）系统和云计算平台。

JMS广泛应用于分布式系统的通信中，特别是在需要解耦、异步处理、高可靠性和可扩展性的场景中。通过使用JMS，开发者可以构建出强大且灵活的消息驱动应用程序。

image-20240506105755513

3、 JMS 消息传输模型

JMS（Java Message Service）支持两种主要的消息传输模型：

  1. 点对点（Point-to-Point，P2P）模型：

    • 在这个模型中，消息生产者发送消息到队列（Queue），消息消费者从队列中接收消息。
    • 每个消息只能被一个消费者接收，一旦消息被消费，它就会从队列中移除，确保消息不会重复处理。
    • 这种模型适用于需要确保消息只被处理一次的场景，例如订单处理、用户请求处理等。

    image-20240506110617134

  2. 发布/订阅（Publish/Subscribe，Pub/Sub）模型：

    • 在发布/订阅模型中，消息生产者（发布者）将消息发送到主题（Topic），而消息消费者（订阅者）订阅感兴趣的主题。
    • 一个发布者发送的消息可以被多个订阅者接收，这使得发布/订阅模型非常适合需要一对多通信的场景。
    • 订阅者可以设置过滤条件，只接收满足特定条件的消息，这增加了消息传输的灵活性。

    image-20240506110631387

两种模型的特点对比：

  • 一对一 vs 一对多：
    • P2P模型是一对一的消息传输，每条消息只有一个消费者。
    • Pub/Sub模型是一对多的消息传输，一条消息可以被多个订阅者接收。
  • 队列 vs 主题：
    • 在P2P模型中，使用队列作为消息的容器，队列保证了消息的顺序性和独立性。
    • 在Pub/Sub模型中，使用主题作为消息的发布点，主题允许多个订阅者接收消息。
  • 消息确认：
    • 在P2P模型中，消费者通常需要显式确认消息，告知消息服务器消息已被成功处理。
    • 在Pub/Sub模型中，订阅者可能需要确认消息，也可能不需要，这取决于具体的实现和配置。
  • 消息持久性：
    • 在两种模型中，都可以配置消息的持久性，确保消息不会因为系统故障而丢失。

JMS的这两种消息传输模型为不同的应用场景提供了灵活的消息传递机制，允许开发者根据业务需求选择合适的模型来实现消息通信。

4、 JMS 消息接收

JMS（Java Message Service）支持多种消息接收方式，这些方式主要与JMS的两种消息传输模型（点对点和发布/订阅）相关。以下是一些常见的消息接收方式：

点对点（P2P）模型的消息接收方式：

  1. 同步接收：
    • 消费者使用receive()方法从队列中同步接收消息。这是一种阻塞调用，如果在队列中没有消息可用，调用将一直阻塞直到消息到达。
  2. 异步接收：
    • 消费者可以注册一个MessageListener接口的实现。当消息到达时，JMS提供者会自动调用MessageListener的onMessage()方法，这是一种非阻塞的接收方式。
  3. 消息选择：
    • 通过设置消息选择器（一个SQL92查询），消费者可以根据特定的消息属性过滤接收的消息。
  4. 事务性接收：
    • 在事务性会话中，消息的接收可以是事务的一部分。如果事务回滚，那么接收的消息也会回滚，确保数据的一致性。

发布/订阅（Pub/Sub）模型的消息接收方式：

  1. 持久订阅：
    • 订阅者可以创建一个持久订阅，即使订阅者当前不处于活动状态，消息服务器也会为订阅者保留消息。
  2. 非持久订阅：
    • 订阅者创建的是非持久订阅，如果订阅者当前不处于活动状态，那么它将错过发布的消息。
  3. 同步/异步接收：
    • 类似于P2P模型，订阅者可以使用receive()方法进行同步接收，或者注册MessageListener进行异步接收。
  4. 消息选择：
    • 订阅者也可以使用消息选择器来过滤接收到的消息。
  5. 分布式订阅：
    • 在分布式系统中，订阅者可能分布在不同的节点上，每个节点上的订阅者都可以接收到发布的消息。
  6. 事务性订阅：
    • 与P2P模型类似，发布/订阅模型也可以在事务性会话中进行消息接收。

其他考虑因素：

  • 消息确认：
    • 消费者在处理完消息后，需要确认消息，以防止消息重复处理。在自动确认模式下，消息服务器会自动确认。在手动确认模式下，消费者需要显式地确认消息。
  • 消息优先级：
    • JMS允许消息具有不同的优先级，高优先级的消息会优先被消费者接收。
  • 消息持久性：
    • 可以根据消息的重要性设置消息的持久性，持久化消息在系统故障时更不容易丢失。

JMS的灵活性允许开发者根据具体的场景和需求选择最合适的消息接收方式。

5、 JMS 消息结构

JMS（Java Message Service）定义了一种标准的消息结构，以确保不同JMS提供者（如ActiveMQ, RabbitMQ, Kafka等）之间的互操作性。一个JMS消息由以下几个主要部分组成：

  1. 消息头（Message Header）：
    • 消息头是消息的元数据，包含了用于识别消息和为消息寻找路由的操作设置。
    • 消息头的属性是固定的，由JMS规范定义，包括：
      • JMSDestination：消息的目标目的地（队列或主题）。
      • JMSDeliveryMode：消息的持久性，可以是持久（PERSISTENT）或非持久（NON_PERSISTENT）。
      • JMSExpiration：消息的过期时间，超过这个时间消息将不再被传递。
      • JMSPriority：消息的优先级，取值范围是0-9，数字越大优先级越高。
      • JMSMessageID：消息的唯一标识，通常由JMS提供者自动生成。
  2. 消息属性（Message Properties）：
    • 消息属性是一组可选的属性，用于提供额外的信息或用于消息过滤。
    • 可以包含客户端自定义的属性和内容，支持通过消息选择器进行过滤。
  3. 消息体（Message Body）：
    • 消息体是消息中实际承载数据的部分，JMS定义了几种不同的消息体类型，用于不同的数据传输需求：
      • TextMessage：用于存储字符串信息。
      • MapMessage：一个键值对的集合，键和值都是String类型。
      • BytesMessage：用于二进制数据的传输。
      • StreamMessage：用于存储原始字节流，类似于Java的序列化机制。
      • ObjectMessage：用于存储一个Java对象，该对象需要实现Serializable接口。

JMS消息的结构设计允许它在不同的应用程序之间高效地传递复杂的数据结构，同时保持了消息传递的可靠性和灵活性。

这篇关于01、JMS规范介绍的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/966847。

相关文章

性能测试介绍

性能测试介绍

性能测试是一种测试方法，旨在评估系统、应用程序或组件在现实场景中的性能表现和可靠性。它通常用于衡量系统在不同负载条件下的响应时间、吞吐量、资源利用率、稳定性和可扩展性等关键指标。 为什么要进行性能测试 通过性能测试，可以确定系统是否能够满足预期的性能要求，找出性能瓶颈和潜在的问题，并进行优化和调整。 发现性能瓶颈：性能测试可以帮助发现系统的性能瓶颈，即系统在高负载或高并发情况下可能出现的问题
阅读更多...
水位雨量在线监测系统概述及应用介绍

水位雨量在线监测系统概述及应用介绍

在当今社会，随着科技的飞速发展，各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中，水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术，其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成，形成了一个完整的闭环系统。 数据采集单元：这是系统的“眼睛”，
阅读更多...
Hadoop数据压缩使用介绍

Hadoop数据压缩使用介绍

一、压缩原则 （1）运算密集型的Job，少用压缩 （2）IO密集型的Job，多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1）为了支持多种压缩/解压缩算法，Hadoop引入了编码/解码器 2）要在Hadoop中启用压缩，可以配置如下参数
阅读更多...
hdu 2602 and poj 3624(01背包)

hdu 2602 and poj 3624(01背包)

01背包的模板题。 hdu2602代码： #include<stdio.h>#include<string.h>const int MaxN = 1001;int max(int a, int b){return a > b ? a : b;}int w[MaxN];int v[MaxN];int dp[MaxN];int main(){int T;int N, V;s
阅读更多...
MySQL高性能优化规范

MySQL高性能优化规范

前言：      笔者最近上班途中突然想丰富下自己的数据库优化技能。于是在查阅了多篇文章后，总结出了这篇！ 数据库命令规范 所有数据库对象名称必须使用小写字母并用下划线分割 所有数据库对象名称禁止使用mysql保留关键字（如果表名中包含关键字查询时，需要将其用单引号括起来） 数据库对象的命名要能做到见名识意，并且最后不要超过32个字符 临时库表必须以tmp_为前缀并以日期为后缀，备份
阅读更多...
图神经网络模型介绍（1）

图神经网络模型介绍（1）

我们将图神经网络分为基于谱域的模型和基于空域的模型，并按照发展顺序详解每个类别中的重要模型。 1.1基于谱域的图神经网络         谱域上的图卷积在图学习迈向深度学习的发展历程中起到了关键的作用。本节主要介绍三个具有代表性的谱域图神经网络：谱图卷积网络、切比雪夫网络和图卷积网络。 （1）谱图卷积网络 卷积定理：函数卷积的傅里叶变换是函数傅里叶变换的乘积，即F{f*g}
阅读更多...
C++——stack、queue的实现及deque的介绍

C++——stack、queue的实现及deque的介绍

目录 1.stack与queue的实现 1.1stack的实现  1.2 queue的实现 2.重温vector、list、stack、queue的介绍 2.1 STL标准库中stack和queue的底层结构  3.deque的简单介绍 3.1为什么选择deque作为stack和queue的底层默认容器  3.2 STL中对stack与queue的模拟实现 ①stack模拟实现
阅读更多...
Mysql BLOB类型介绍

Mysql BLOB类型介绍

BLOB类型的字段用于存储二进制数据 在MySQL中，BLOB类型，包括：TinyBlob、Blob、MediumBlob、LongBlob，这几个类型之间的唯一区别是在存储的大小不同。 TinyBlob 最大 255 Blob 最大 65K MediumBlob 最大 16M LongBlob 最大 4G
阅读更多...
集中式版本控制与分布式版本控制——Git 学习笔记01

集中式版本控制与分布式版本控制——Git 学习笔记01

什么是版本控制 如果你用 Microsoft Word 写过东西，那你八成会有这样的经历： 想删除一段文字，又怕将来这段文字有用，怎么办呢？有一个办法，先把当前文件“另存为”一个文件，然后继续改，改到某个程度，再“另存为”一个文件。就这样改着、存着……最后你的 Word 文档变成了这样： 过了几天，你想找回被删除的文字，但是已经记不清保存在哪个文件了，只能挨个去找。真麻烦，眼睛都花了。看
阅读更多...
FreeRTOS-基本介绍和移植STM32

FreeRTOS-基本介绍和移植STM32

FreeRTOS-基本介绍和STM32移植 一、裸机开发和操作系统开发介绍二、任务调度和任务状态介绍2.1 任务调度2.1.1 抢占式调度2.1.2 时间片调度 2.2 任务状态 三、FreeRTOS源码和移植STM323.1 FreeRTOS源码3.2 FreeRTOS移植STM323.2.1 代码移植3.2.2 时钟中断配置 一、裸机开发和操作系统开发介绍 裸机：前后台系
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2