ActiveMQ Producer 间歇连接和持久化

Question

我目前正在尝试寻找一种解决方案，以通过 TCP 上的生产者持续传递数据。连接可能会长时间断开。

这是否意味着我需要在等待建立连接时实现自己的数据持久性形式？或者是否有一些方法，例如故障转移，ActiveMQ 可以等待连接重新连接，然后持久地传递消息。我目前的问题是，如果没有连接，我将无法创建生产者，因此在形成连接期间我的消息无处可去。

我使用自己的持久性形式没有问题，但我更愿意使用 ActiveMQ 提供的内置持久性。

我希望我的问题很清楚。

Answer 1

这是一个常见的问题，可以通过几种方式解决。一种方法是您描述的方法，您自己存储数据并在连接恢复时发送数据。另一种经常使用的方法是使用embedded 或本地代理来生成消息并在本地代理和远程之间创建network connection。当连接断开时，嵌入式代理将存储消息，并且当代理之间的网络连接恢复时，本地可以将存储的消息转发到远程代理（集线器和辐射类）。请记住，本地代理需要足够的存储空间来管理您期望在本地和远程代理之间的典型停机期间累积的消息数量。