ActiveMQ Producer 间歇性连接和持久性



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

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

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

我希望我的问题很清楚。

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

最新更新