我正在尝试使用
Java中的couchdb(连续)更改API,并发现在耗尽当前更改列表后,流似乎已关闭,而不是永远保持打开它应该如此.
我正在使用的代码如下.我希望永远不会退出while循环,但只要当前现有的更改完成流式传输就会立即执行.我对couchdb和Java都比较新,所以可能会遗漏一些明显的东西.任何人都可以告诉我如何正确地写这个吗?
URL url = new URL("[path to database here]/_changes?Feed=continuous";); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setDoOutput(true); conn.setUseCaches(false); conn.setRequestProperty("Connection","Keep-Alive"); conn.setRequestMethod("GET"); BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream())); String line; while((line = reader.readLine()) != null){ // do something with the line here } // Should never get here under normal circumstances reader.close();
解决方法
除非提供不同的超时值或心跳,否则实际默认超时为60000毫秒(60秒).我在十月份更新了
_changes wiki page并包含了我在代码中遇到的任何默认值.
设置心跳基本上意味着您将在客户端观察超时,即心跳周期没有换行意味着您肯定丢失了连接.我相信如果有心跳,CouchDB会禁用其超时检查.