TongLINK/Q是和IBM MQ相近的消息中间件,其最主要的功能是保证消息的一致性,举一个例子,如果一个应用从socket中接收了银行A发来的数据,在处理数据过程中,应用程序崩溃,这时,银行A数据就会丢失,银行业务数据就核对不上,如果采用TongLINK/Q,以事务方式从TongLINK/Q中收消息,同样是应用程序崩溃,这时,TongLINK/Q事务回退,数据就不会丢失,应用程序重启后,可以接着从消息队列取出消息继续处理,如果设置了回退次数,超过一定的次数,消息进入死信队列。这样,不论应用程序写的是否正确,运行情况如何,消息不会丢。 TongLINK/Q保证在应用程序崩溃,进程被杀死(包括TongLINK/Q所有的核进程),IPC资源被误删除,机器重启,断网,网络丢包,内存耗尽,硬盘空间耗尽等各种异常情况下,TongLINK/Q都能保证事务的一致性,保证消息不丢不重复。由于以上特性,对于可靠性要求很高应用程序,底层可采用TongLINK/Q,这样,应用程序开发者就不用再考虑应用程序被杀死或崩溃时丢消息的问题。 TongLINK/Q的其它功能,如消息顺序保证、路由备份,路由选择,集群
2024-07-22 10:39:06 32.72MB 网络 MQ 消息中间件
1
基于Java通讯开发jms源代码 (jms通讯开发源码) java,net,socket,通讯开发,jms /* * @(#)Message.java 1.60 02/04/09 * * Copyright 1997-2002 Sun Microsystems, Inc. All Rights Reserved. * * SUN PROPRIETARY/CONFIDENTIAL. * This software is the proprietary information of Sun Microsystems, Inc. * Use is subject to license terms. * */ import java.util.Enumeration; public interface Message { String getJMSMessageID() throws JMSException; void setJMSMessageID(String id) throws JMSException; long getJMSTimestamp() throws JMSException; void setJMSTimestamp(long timestamp) throws JMSException; byte [] getJMSCorrelationIDAsBytes() throws JMSException; void setJMSCorrelationIDAsBytes(byte[] correlationID) throws JMSException; String getJMSCorrelationID() throws JMSException; Destination getJMSReplyTo() throws JMSException; void setJMSReplyTo(Destination replyTo) throws JMSException; Destination getJMSDestination() throws JMSException; void setJMSDestination(Destination destination) throws JMSException; int getJMSDeliveryMode() throws JMSException; void setJMSDeliveryMode(int deliveryMode) throws JMSException; boolean getJMSRedelivered() throws JMSException; void setJMSRedelivered(boolean redelivered) throws JMSException; String getJMSType() throws JMSException; void setJMSType(String type) throws JMSException; long getJMSExpiration() throws JMSException; void setJMSExpiration(long expiration) throws JMSException; int getJMSPriority() throws JMSException; void setJMSPriority(int priority) throws JMSException; void clearProperties() throws JMSException; boolean propertyExists(String name) throws JMSException; boolean getBooleanProperty(String name) throws JMSException; byte getByteProperty(String name) throws JMSException; short getShortProperty(String name) throws JMSException; int getIntProperty(String name) throws JMSException; long getLongProperty(String name) throws JMSException; float getFloatProperty(String name) throws JMSException; double getDoubleProperty(String name) throws JMSException; String getStringProperty(String name) throws JMSException; Object getObjectProperty(String name) throws JMSException; Enumeration getPropertyNames() throws JMSException; void setBooleanProperty(String name, boolean value) throws JMSException; void setByteProperty(String name, byte value) throws JMSException; void setShortProperty(String name, short value) throws JMSException; void setIntProperty(String name, int value) throws JMSException; void setLongProperty(String name, long value) throws JMSException; void setFloatProperty(String name, float value) throws JMSException; void setDoubleProperty(String name, double value) throws JMSException; void setStringProperty(String name, String value) throws JMSException; void setObjectProperty(String name, Object value) throws JMSException; void acknowledge() throws JMSException; void clearBody() throws JMSException; } 通讯开发必备源码资料!
2023-04-01 22:36:51 322KB java net socket 通讯开发 jms
1
深入探索jms,包含JMS深入探究十篇.doc、amq Maven工程、apache-activemq-5.8.0 JMS Provider。从浅到深讲解了JMS接口的用法,并以activemq为实例进行实现。
2023-04-01 22:27:58 44.78MB jms activemq 代码 详解
1
JMS578 update tool,可以升级、备份固件
2022-12-09 18:02:15 695KB jms578 usb转sata
1
ActiveMQ_in_Action.pdf 教程文档
2022-10-23 10:06:21 456KB MQ JMS
1
geoserver2.16.0集群搭建,通过拓展jms及消息队列实现geoserver的同步,通过配置实现数据目录的共享
2022-06-01 09:48:43 140.59MB geoserver jms cluster activeMQ
1
spring-boot-camel-jms 使用 Apache Camel 和 ActiveMQ 的 Spring Boot 应用程序
2022-05-19 15:30:11 9KB Java
1
ApacheCamel-JMS-ActiveMQ Apache Camel JMS ActiveMQ 使用样例 1.从本地读取信息推送到MQ中 2.从MQ中读取信息保存到本地
2022-05-18 13:58:59 62.06MB Camel-JMS
1
JMS 操作IBM MQ,实现订阅发布模式!包含完整的JAR包以及测试文件。
2022-05-10 10:45:35 6.89MB JMS IBM MQ 订阅发布
1
本人业余时间开发,目前实现了Tcp通信方式,预留了http接口,有兴趣的同学可以自己实现
2022-04-26 14:45:24 856KB java jms 消息队列 源码
1