java activemq 断线_java - 防止ActiveMQ重新连接失败时自动退出 - SO中文参考 - www.soinside.com...
我有一个小型的spring-boot应用程序,该应用程序连接到ActiveMQ上的一个或多个主题,这些主题在启动时在应用程序的application.properties文件中设置-然后将这些消息发送到数据库。
这一切都很好,但是在尝试实施故障转移时遇到一些问题-基本上,应用程序将尝试重新连接,但是在重试一定次数后,应用程序进程将自动退出,从而防止重试(理想情况下,我希望该应用程序能够永久重试,直到被手动终止或ActiveMQ再次可用为止。我尝试将连接URL(使用application.properties中的maxReconnectAttempts)中的连接选项(例如url.options)显式设置为-1/0/99999,但这些都似乎不正确,因为行为是相同的每一次。通过查看有关Apache's own reference page的建议,我也希望该行为也可以作为默认行为。
[如果有人有任何建议强制不要退出该应用程序,我将非常感谢!我认为很重要的代码如下:@Configuration
public class AmqConfig {
private static final Logger LOG = LogManager.getLogger(AmqConfig.class);
private static final String LOG_PREFIX = "[AmqConfig] ";
private String clientId;
private static ArrayList amqUrls = new ArrayList<>();
private static String amqConnectionUrl;
private static Integer numSubs;
private static ArrayList destinations = new ArrayList<>();
@Autowired
DatabaseService databaseService;
public AmqConfig (@Value("${amq.urls}") String[] amqUrl,
@Value("${amq.options}") String amqOptions,
@Value("${tocCodes}") String[] tocCodes,
@Value("${amq.numSubscribers}") Integer numSubs,
@Value("${clientId}") String clientId) throws UnknownHostException {
Arrays.asList(amqUrl).forEach(url -> {
amqUrls.add("tcp://" + url);
});
String amqServerAddress = "failover:(" + String.join(",", amqUrls) + ")";
String options = Strings.isNullOrEmpty(amqOptions) ? "" : "?" + amqOptions;
this.amqConnectionUrl = amqServerAddress + options;
this.numSubs = Optional.ofNullable(numSubs).orElse(4);
this.clientId = Strings.isNullOrEmpty(clientId) ? InetAddress.getLocalHost().getHostName() : clientId;
String topic = "Consumer." + this.clientId + ".VirtualTopic.Feed";
if (tocCodes.length > 0){
Arrays.asList(tocCodes).forEach(s -> destinations.add(topic + "_" + s));
} else { // no TOC codes = connecting to default feed
destinations.add(topic);
}
}
@Bean
public ActiveMQConnectionFactory connectionFactory() throws JMSException {
LOG.info("{}Connecting to AMQ at {}", LOG_PREFIX, amqConnectionUrl);
LOG.info("{}Using client id {}", LOG_PREFIX, clientId);
ActiveMQConnectionFactory connectionFactory =
new ActiveMQConnectionFactory(amqConnectionUrl);
Connection conn = connectionFactory.createConnection();
conn.setClientID(clientId);
conn.setExceptionListener(new AmqExceptionListener());
conn.start();
destinations.forEach(destinationName -> {
try {
for (int i = 0; i < numSubs; i++) {
Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(destinationName);
MessageConsumer messageConsumer = session.createConsumer(destination);
messageConsumer.setMessageListener(new MessageReceiver(databaseService, destinationName));
}
} catch (JMSException e) {
LOG.error("{}Error setting up queue @ {}", LOG_PREFIX, destinationName);
LOG.error(e.getMessage());
}
});
return connectionFactory;
}
}
public class MessageReceiver implements MessageListener, ExceptionListener {
public static final Logger LOG = LogManager.getLogger(MessageReceiver.class);
private static final String LOG_PREFIX = "[Message Receiver] ";
private DatabaseService databaseService;
public MessageReceiver(DatabaseService databaseService, String destinationName){
this.databaseService = databaseService;
LOG.info("{}Creating MessageReceiver for queue with destination: {}", LOG_PREFIX, destinationName);
}
@Override
public void onMessage(Message message) {
String messageText = null;
if (message instanceof TextMessage) {
TextMessage tm = (TextMessage) message;
try {
messageText = tm.getText();
} catch (JMSException e) {
LOG.error("{} Error getting message from AMQ", e);
}
} else if (message instanceof ActiveMQMessage) {
messageText = message.toString();
} else {
LOG.warn("{}Unrecognised message type, cannot process", LOG_PREFIX);
LOG.warn(message.toString());
}
try {
databaseService.sendMessageNoResponse(messageText);
} catch (Exception e) {
LOG.error("{}Unable to acknowledge message from AMQ. Message: {}", LOG_PREFIX, messageText, e);
}
}
}
public class AmqExceptionListener implements ExceptionListener {
public static final Logger LOG = LogManager.getLogger(AmqExceptionListener.class);
private static final String LOG_PREFIX = "[AmqExceptionListener ] ";
@Override
public void onException(JMSException e){
LOG.error("{}Exception thrown by ActiveMQ", LOG_PREFIX, e);
}
}
我从应用程序中获得的控制台输出仅是以下内容(很抱歉,由于没有太大用处,]][2019-12-12 14:43:30.292] [WARN ] Transport (tcp://[address]:61616) failed , attempting to automatically reconnect: java.io.EOFException
[2019-12-12 14:43:51.098] [WARN ] Failed to connect to [tcp://[address]:61616] after: 10 attempt(s) continuing to retry.
Process finished with exit code 0
我有一个小型的spring-boot应用程序设置,该应用程序连接到ActiveMQ上的一个或多个主题,这些主题在启动时在应用程序的application.properties文件中设置-然后将这些消息发送到...
java activemq 断线_java - 防止ActiveMQ重新连接失败时自动退出 - SO中文参考 - www.soinside.com...相关推荐
- java. tcp. 权限,java - tcpdump的不能够写PCAP文件。没有权限 - SO中文参考 - www.soinside.com...
我开发我的Java应用程序,所以我可以在我的机器接口的数据包嗅探和转储结果滚动PCAP文件的网络监控解决方案.当从Java代码启动(使用sudo)tcpdump命令,我得到tcpdump: /path ...
- 俄语转化成拉丁字母java_java - 如何在Java String中将西里尔字母转换为英语拉丁语? - SO中文参考 - www.soinside.com...
我在stackoverflow Transliteration from Cyrillic to Latin ICU4j java上找到了这个方法,它用于将西里尔语(俄语)转换为拉丁语(但如果需要,你 ...
- json解析嵌套jasn语句报错_java - Spring Boot:尝试解析Json时为InvalidTypeIdException - SO中文参考 - www.soinside.com...
我正在尝试将POJO映射到我得到的JSON响应:但是,我不断收到此错误:com.fasterxml.jackson.databind.exc.InvalidTypeIdException: Could ...
- java swing中英文支持,java - Swing国际化 - 如何在运行时更新语言 - SO中文参考 - www.soinside.com...
我通过扩展JLabel并覆盖getText来返回对语言选择的评估来解决这个问题. 您还需要一些发布/订阅机制来"告诉"您的标签语言已更改. 在这里我使用updateLanguage ...
- java 人脸检测_Java+OpenCV实现人脸检测并自动拍照
java+opencv实现人脸检测,调用笔记本摄像头实时抓拍,人脸会用红色边框标识出来,并且将抓拍的目录存放在src下,图片名称是时间戳. 环境配置:win7 64位,jdk1.8 CameraBas ...
- java pdf无法加载_java - 试图使用iText7合并来合并pdf,但是当我打开最终的合并pdf时,它说无法加载pdf文档 - SO中文参考 - www.soinside.com...
试图使用iText7合并来合并pdf,但是当我打开最终的合并pdf时,它说无法加载pdf文档 问题描述 投票:0回答:1 我正在使用itext7 PdfWriter创建两个ByteArrayOutpu ...
- java redis 故障切换_java使用Redis6–sentinel单点故障主从自动切换
Redis Sentinel Sentinel(哨兵)是用于监控redis集群中Master状态的工具,其已经被集成在redis2.4+的版本中 一.Sentinel作用: 1):Master状态检测 ...
- java access 密码_java 连接加密Access2007数据库时,不用输入用户名密码也能连上
java 连接加密Access2007数据库时,不用输入用户名密码也能连上 我用Access2007做了一个加密的数据库,用的是Access本身的功能加密的.双击打开Database2.mdb文件时, ...
- java 异常 中文_Java中所有的运行时异常,带中文解释
展开全部 算术异常类:ArithmeticExecption 空指针异常类:NullPointerException 类型强制转换异常:ClassCastException 数组负下标异常:Negat ...
最新文章
- java实现用户登录注册功能(用集合框架来实现)
- Adding a new op when using tensorflow in windows
- InstallShield安装打包编译自动化(3)- 更新Package GUID,Product GUID以及Upgrade GUID
- linux 添加用户_linux ---添加普通用户账号
- TP框架笔记 -- 394-model的创建
- IOS15给UICollection添加测试数字
- javascript实例——鼠标特效篇(包含2个实例)
- netty的channel介绍
- unix网络编程各种TCP客户-服务器程序设计实例(三)
- python利器-python利器app下载-python利器手机版 _5577安卓网
- iOS开发--添加定位功能
- 2021-07-01本科毕业设计需要查重什么?
- 分析手段之一:质谱仪GCMS质谱技术
- ECSHOP和SHOPEX快递单号查询中通插件V8.6专版
- 软阈值迭代算法(ISTA)和快速软阈值迭代算法(FISTA)
- Mac 用久了空间不足?教你如何清理磁盘空间
- ecshop小京东产品后台版权及logo修改
- css 背景渐变 图像_交叉渐变背景图像
- 游虎DOTA专区 - 内容丰富的DOTA专区,DOTA录像分析很不错的..
- 计算机主板系统安装系统安装系统,华硕主板安装系统了BIOS启动菜单为什么系统无法找到解决办法...
热门文章
- 微信群运营之设计运营思路
- rabbitmq简单运用
- Linq to SQL 的增删改查操作
- 2 android学习资料
- uboot load address、entry point、 bootm address以及kernel运行地址的意义及联系
- 爱情九十六课,位置决定爱情
- python es 数据库 ik_Linux系统:centos7下搭建ElasticSearch中间件,常用接口演示
- 华为root工具_华为Mate9解锁后无法ROOT 需要手动刷入Recovery怎么办【解决方法】...
- python列表姓氏_python数据分析实例(六) 中国姓氏数据
- 划分数据集代码(按照4:1的比例)以及根据各自文件名写入txt文件