7.JavaEE

比眉伴天荒 2024-04-08 12:59 60阅读 0赞

## 总体框架 ##

>  *  `Java SE是Java平台标准版的简称(Java platform, standard edition)`，Java SE 以前称为 J2SE。适用于标准的应用开发，用于开发和部署桌面、服务器以及嵌入设备和实时环境中的Java应用程序。Java SE包括用于开发Java web服务的类库，同时，Java SE为Java EE提供了基础。
>  *  `JavaEE(Java Platform Enterprise Edition)`是一套使用java进行企业级开发的13个核心规范工业标准,在javase的基础上进一步提供了高级功能。
>  *  `Java ME 又称为J2ME（Java Platform，Micro Edition）`是为机顶盒、移动电话和PDA之类嵌入式消费电子设备提供的Java语言平台，包括虚拟机和一系列标准化的Java API。  
>     ![在这里插入图片描述][51051c2443f44e75a5b3e5051c54ca73.png_pic_center]

## JMS java消息通信服务 ##

> 定义了两个服务进行异步通信的统一API  
> ![在这里插入图片描述][97edf3fbce984389a8da585c0985cc5f.png]

> 四大组成
> 
>  *  JMS Provider 实现JMS规范的消息中间
>  *  JMS producer 消息生产者，创建和发送JMS消息
>  *  JMS consumer 消息消费者，接收和处理JMS消息
>  *  JMS message 消息本身

> JMS message的组成
> 
>  *  消息头
>  *  消息属性
>     
>      *  对消息头属性进行扩展，格式是KEY-value
>      *  对消息进行特殊标记
>  *  消息体

`消息头`

<table> 
 <thead> 
  <tr> 
   <td>序号</td> 
   <td>属性名称</td> 
   <td>说明</td> 
   <td>设置者</td> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td> <p>1</p> </td> 
   <td> <p>JMSDestination</p> </td> 
   <td>消息发送的目的地，是一个Topic或Queue</td> 
   <td>&nbsp;send</td> 
  </tr> 
  <tr> 
   <td> <p>2</p> </td> 
   <td> <p>JMSDeliveryMode</p> </td> 
   <td>消息的发送模式，分为NON_PERSISTENT和PERSISTENT，即持久化的和非持久化的</td> 
   <td>&nbsp;send</td> 
  </tr> 
  <tr> 
   <td> <p>3</p> </td> 
   <td> <p>JMSMessageID</p> </td> 
   <td>消息ID，需要以ID:开头　　&nbsp;</td> 
   <td>&nbsp;send</td> 
  </tr> 
  <tr> 
   <td> <p>4</p> </td> 
   <td> <p>JMSTimestamp&nbsp;</p> </td> 
   <td>&nbsp;消息发送时的时间，也可以理解为调用send()方法时的时间，而不是该消息发送完成的时间</td> 
   <td>&nbsp;send</td> 
  </tr> 
  <tr> 
   <td> <p>5</p> </td> 
   <td> <p>JMSCorrelationID</p> </td> 
   <td>&nbsp;关联的消息ID，这个通常用在需要回传消息的时候　　　　</td> 
   <td>&nbsp;<strong>client</strong></td> 
  </tr> 
  <tr> 
   <td> <p>6</p> </td> 
   <td> <p>JMSReplyTo</p> </td> 
   <td>&nbsp;消息回复的目的地，其值为一个Topic或Queue, 这个由发送者设置，但是接收者可以决定是否响应</td> 
   <td>&nbsp;<strong>client</strong></td> 
  </tr> 
  <tr> 
   <td> <p>7</p> </td> 
   <td> <p>JMSRedelivered&nbsp;</p> </td> 
   <td> <p>&nbsp;消息是否重复发送过，如果该消息之前发送过，那么这个属性的值需要被设置为true, 客户端可以根据这个属性的值来确认这个消息是否重复发送过，以避免重复处理。</p> </td> 
   <td>&nbsp;<strong>Provider</strong></td> 
  </tr> 
  <tr> 
   <td> <p>8</p> </td> 
   <td> <p>JMSType</p> </td> 
   <td> <p>&nbsp;由消息发送者设置的个消息类型，代表消息的结构，有的消息中间件可能会用到这个，但这个并不是是批消息的种类，比如TextMessage之类的</p> </td> 
   <td>&nbsp;<strong>client</strong></td> 
  </tr> 
  <tr> 
   <td> <p>9</p> </td> 
   <td> <p>JMSExpiration&nbsp;</p> </td> 
   <td> <p>&nbsp;消息的过期时间，以毫秒为单位，根据定义，它应该是timeToLive的值再加上发送时的GMT时间，也就是说这个指的是过期时间，而不是有效期</p> </td> 
   <td>send&nbsp;</td> 
  </tr> 
  <tr> 
   <td> <p>10</p> </td> 
   <td> <p>JMSPriority</p> </td> 
   <td>消息的优先级,0-4为普通的优化级，而5-9为高优先级，通常情况下，高优化级的消息需要优先发送</td> 
   <td>&nbsp;send</td> 
  </tr> 
 </tbody> 
</table>

`消息体`

<table> 
 <tbody> 
  <tr> 
   <td>序号</td> 
   <td>消息体类型</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td>TextMessage（文本消息）</td> 
   <td>编码字符串。对于外发消息，字符串在由目标对象给定的字符集中进行编码。缺省情况下使用 UTF8 编码（UTF8 编码从消息的第一个字符开始；开头处无长度字段）。但是，可以指定&nbsp;用于 JMS 的 IBM® MQ 类&nbsp;支持的任何其他字符集。此类字符集主要在将消息发送到非&nbsp;JMS&nbsp;应用程序时使用。 <p>如果字符集是双字节集（包括 UTF16），那么目标对象的整数编码规范可确定字节顺序。</p> <p>使用消息本身中指定的字符集及编码来解释入局消息。这些规范在最后一个&nbsp;IBM MQ&nbsp;头中，如果没有头，那么在 MQMD 中。对于&nbsp;JMS&nbsp;消息，最后一个头通常为 MQRFH2。</p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td>MapMessage（键值对消息）</td> 
   <td>消息体包含了一系列的名字-值对.名字是Strings,而值则是Java primitive 类型.消息体中的条目可以被enumerator按照顺序访问,也可以自由访问.条目的顺序没 有定义.</td> 
  </tr> 
  <tr> 
   <td>3</td> 
   <td>ObjectMessage（对象消息）</td> 
   <td>是&nbsp;Java™&nbsp;Runtime 以正常方式进行序列化的对象。</td> 
  </tr> 
  <tr> 
   <td>4</td> 
   <td>BytesMessage（bytes消息）</td> 
   <td>缺省情况下，BytesMessage 是&nbsp;JMS&nbsp;1.0.2 规范及关联&nbsp;Java&nbsp;文档所定义的一系列字节。 <p>对于由应用程序本身组合的外发消息，目标对象的编码属性可用于覆盖消息中所含的整数和浮点字段的编码。例如，可以请求以 S/390 格式而非 IEEE 格式存储浮点值。</p> <p>使用消息本身中指定的数字编码来解释入局消息。此规范在最后一个&nbsp;IBM MQ&nbsp;头中，如果没有头，那么在 MQMD 中。对于&nbsp;JMS&nbsp;消息，最后一个头通常为 MQRFH2。</p> <p>如果收到 BytesMessage，并且在不进行修改的情况下重新发送，那么消息主体将按照其接收的方式逐字节进行传输。目标对象的编码属性对主体无任何影响。可以在 BytesMessage 中明确发送的唯一的类似字符串的实体是 UTF8 字符串。它采用&nbsp;Java&nbsp;UTF8 格式编码，并以双字节长度字段开头。目标对象的字符集属性对外发 BytesMessage 编码无任何影响。入局&nbsp;IBM MQ&nbsp;消息中的字符集值对于将此消息解释为&nbsp;JMS&nbsp;BytesMessage 无任何影响。</p> <p>非&nbsp;Java&nbsp;应用程序不太可能能够识别&nbsp;Java&nbsp;UTF8 编码。因此，对于要发送包含文本数据的 BytesMessage 的&nbsp;JMS&nbsp;应用程序，应用程序本身必须将其字符串转换为字节数组，并将这些字节数组写入 BytesMessage。</p> </td> 
  </tr> 
  <tr> 
   <td>5</td> 
   <td>StreamMessage（流消息）</td> 
   <td>StreamMessage 与映射消息类似，但无元素名称： <pre><code></code>
     
     
      
     <ol>
       
      <li>
       
       
        
       <div>
        
        
         
        <div></div>
       
       
        
       </div>
       
       
        
       <div>
        
        
         
        <div>
         
         
          
         <span>&lt;<span>stream</span>&gt;</span>
        
        
         
        </div>
       
       
        
       </div></li>
       
      <li>
       
       
        
       <div>
        
        
         
        <div></div>
       
       
        
       </div>
       
       
        
       <div>
        
        
         
        <div> 
        
        
         
        </div>
       
       
        
       </div></li>
       
      <li>
       
       
        
       <div>
        
        
         
        <div></div>
       
       
        
       </div>
       
       
        
       <div>
        
        
         
        <div>
         
          
         
         &nbsp;
         
         
          
         <span>&lt;<span>elt</span> <span>dt</span>=<span>"datatype1"</span>&gt;</span>value1
         
         
          
         <span>&lt;/<span>elt</span>&gt;</span>
        
        
         
        </div>
       
       
        
       </div></li>
       
      <li>
       
       
        
       <div>
        
        
         
        <div></div>
       
       
        
       </div>
       
       
        
       <div>
        
        
         
        <div>
         
          
         
         &nbsp;
         
         
          
         <span>&lt;<span>elt</span> <span>dt</span>=<span>"datatype2"</span>&gt;</span>value2
         
         
          
         <span>&lt;/<span>elt</span>&gt;</span>
        
        
         
        </div>
       
       
        
       </div></li>
       
      <li>
       
       
        
       <div>
        
        
         
        <div></div>
       
       
        
       </div>
       
       
        
       <div>
        
        
         
        <div>
         
          
         
         &nbsp;...
        
        
         
        </div>
       
       
        
       </div></li>
       
      <li>
       
       
        
       <div>
        
        
         
        <div></div>
       
       
        
       </div>
       
       
        
       <div>
        
        
         
        <div> 
        
        
         
        </div>
       
       
        
       </div></li>
       
      <li>
       
       
        
       <div>
        
        
         
        <div></div>
       
       
        
       </div>
       
       
        
       <div>
        
        
         
        <div>
         
         
          
         <span>&lt;/<span>stream</span>&gt;</span>
        
        
         
        </div>
       
       
        
       </div></li>
      
     </ol>
     
     
      
     <div></div></pre> 其中&nbsp;datatype&nbsp;是<a href="https://www.ibm.com/support/knowledgecenter/zh/SSFKSJ_9.0.0/com.ibm.mq.dev.doc/q032000_.htm?view=kc#q032000___q032000_2" rel="nofollow">表 6</a>&nbsp;中列出的其中一个数据类型。缺省数据类型为&nbsp;string，因此会为字符串元素省略&nbsp;dt=string&nbsp;属性。 <p>用于编码或解释组成 StreamMessage 主体的 XML 字符串的字符集遵循适用于 TextMessage 的规则来确定。</p> </td> 
  </tr> 
 </tbody> 
</table>

### JMS支持的消息消费模式 ###

>  *  队列模式，一个队列多个消费者，高可用的情况保证不重复消费
>  *  主题模式——订阅发布模式，一个主题，多个订阅者，同时进行消费

### JMS的可靠性 ###

> 消息的持久性(`保证宕机后可以恢复`)
> 
>  *  队列模式宕机后，持久化能够恢复
>  *  默认的队列消息时持久化的
>  *  主题模式默认不是持久化的，需要特殊设置
>  *  持久化的主题和持久化的消费者可以持久化的消费
> 
> 消息的事务性（`保证消费失败可以回滚`）
> 
>  *  一个发布者可以连续发布多个消息
>  *  多个消息不使用事务的话就在send的时候逐条发送
>  *  如果使用事务，会在commit之后批量发送，保证消息在队列中是紧挨着的，`可以进行操作的回滚`。
>  *  如果使用事务，可以在消费者消费commit之后完成消费，消费失败可以回滚，没有commit会被重复消费
> 
> 消息的ACK应答签收
> 
>  *  `自动应答`，
>     
>      *  `默认事务提交后，就会自动签收,即时手动签收。`
>      *  `事务没有提交，自动签收是无效的`
>  *  手动应答，不应答就会重复消费。
>  *  可以重复消费应答，不用。

[51051c2443f44e75a5b3e5051c54ca73.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/08/90c4c322dda34a93afd9a5b4584021e0.png
[97edf3fbce984389a8da585c0985cc5f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/08/36a072f65f4c43af84f040e418583413.png