通过Apache Camel将SQL数据库中的二进制文件流式传输回endpoint

Question

我试图从SQL数据库中获取一些varbinary数据，这时对我的Camel服务进行了REST调用。我可以以字节数组的形式获取数据，并将其设置为Camel的主体Exchange，然后Servlet将其作为原始字节返回给调用者（web浏览器、应用程序等）。

我现在想用流来做这件事，而不是保存内存中的所有字节。如果我使用JdbcTemboard，当. Query方法完成时，我可以从结果集获得的连接和流都将关闭，即使我试图返回一个InputStream并将其设置为Exchange主体。这阻止了我从DB直接流式传输数据，通过Camel，然后返回给调用者。

如果我自己编写jdbc的东西，我可以在它打开时将流设置为exchange主体，但我认为我没有机会关闭我打开的连接和流，最终会因此耗尽资源。

我查看了onCompletion，但我不知道如何使用它来关闭我没有参考的流和连接，我不确定在所有数据流回到调用方后是否一定会执行。

我正在使用Camel 2.14.1中的REST DSL和Servlet组件。有没有什么方法可以在不写入文件的情况下完成这项工作？我稍后会在某个地方用定时任务来清理该文件？我希望避免这种情况，否则，在哑计时器清除数据之前，您会有一个争用条件来流回数据。

Answer 1

这样做的方法是，在您查询数据库的bean中，从Connectionpool获取Connection，创建Preared语句以获取您的数据的任何列，并使用ResultSet.getBinaryStream执行它来请求您的二进制数据。

这将为您提供一个InputStream，您可以将其设置为CamelExchangebody，如果您使用的是REST DSL，则必须设置RestBindingMode。关闭RESTendpoint上的。

将其设置为exchange主体后，使用setProperty（“此处为您的名字”，closeableresource）将流、连接和结果集作为属性附加到exchange上。

请注意，将它们设置为标头可能会导致Servlet将它们绑定到响应中，此外，通常有一个最大标头大小，这些大小将不适合。

在错误情况下，bean中的错误处理应该处理清除连接等问题。

然后在RESTendpoint调用的路由上，有一个onCompletion子句，它只在REST调用的使用者完成时执行。在该子句中，调用一个处理器，它提取您之前为需要关闭的资源设置的属性，对它们进行空检查，然后关闭它们。

很抱歉缺少代码片段，希望我有时间回到这里，但以上应该足够了。

tl；dr:onCompletion将在所有流通过连接传回后执行，至少对于使用Apache Camel的Servlet。