ActiveMQ Producer 间歇连接和持久化
ActiveMQ Producer Intermittent Connection and Persistence
我目前正在尝试寻找一种解决方案,通过生产者通过 TCP 持续传送数据。连接可能会中断很长时间。
这是否意味着我需要在等待建立连接时实现自己的数据持久化形式?或者是否有一些方法,如故障转移,ActiveMQ 可以等待连接重新连接,然后持久地传递消息。我目前的问题是,如果没有连接,我无法创建生产者,因此在形成连接期间我的消息无处可去。
我使用自己的持久性形式没有问题,但我更愿意使用 ActiveMQ 提供的内置持久性。
我希望我的问题很清楚。
这是一个普遍的问题,可以通过几种方式解决。一种方法是您描述的自己存储数据并在连接恢复时发送数据的方法。另一种经常使用的方法是在本地代理和远程代理之间使用 embedded or local broker to produce the messages to and create a network connection。当连接断开时,嵌入式代理将存储消息,当代理之间的网络连接恢复时,本地可以将存储的消息转发到远程代理(中心辐射型)。请记住,本地代理需要足够的存储空间来管理您预计在本地和远程代理之间的典型停机期间累积的消息数。
我目前正在尝试寻找一种解决方案,通过生产者通过 TCP 持续传送数据。连接可能会中断很长时间。
这是否意味着我需要在等待建立连接时实现自己的数据持久化形式?或者是否有一些方法,如故障转移,ActiveMQ 可以等待连接重新连接,然后持久地传递消息。我目前的问题是,如果没有连接,我无法创建生产者,因此在形成连接期间我的消息无处可去。
我使用自己的持久性形式没有问题,但我更愿意使用 ActiveMQ 提供的内置持久性。
我希望我的问题很清楚。
这是一个普遍的问题,可以通过几种方式解决。一种方法是您描述的自己存储数据并在连接恢复时发送数据的方法。另一种经常使用的方法是在本地代理和远程代理之间使用 embedded or local broker to produce the messages to and create a network connection。当连接断开时,嵌入式代理将存储消息,当代理之间的网络连接恢复时,本地可以将存储的消息转发到远程代理(中心辐射型)。请记住,本地代理需要足够的存储空间来管理您预计在本地和远程代理之间的典型停机期间累积的消息数。