草庐IT

stream_writable

全部标签

java - MongoSocketReadException : Prematurely reached end of stream (after a period of inactivity)

在一段时间不活动后,我在find调用(默认Java驱动程序)中收到此错误。我尝试添加手动心跳(写入上限集合),但没有帮助。我只有在连接到compose上的实例时才会遇到问题(即不在本地上下文中)。MongoDB版本是3.2.8,最新驱动(3.3),使用Java8。有什么想法吗? 最佳答案 我在一些文档中找到了它:对于长时间运行的应用程序,通常谨慎的做法是在几毫秒内启用“keepAlive”。如果没有它,一段时间后您可能会开始看到“连接关闭”错误,这似乎是没有原因的。检查这是否有帮助。当您连接到mongoDB时,您可以将套接字选项传递

c++ - SOCK_DGRAM 和 SOCK_STREAM 是什么?

我刚刚遇到一个奇怪的事情,我看到应用程序默认情况下它们使用SOCK_STREAM函数。为什么会这样?这SOCK_STREAM只是创建多个流吗?或者它是可用于创建TCP流的标准SOCK_STREAM函数?我认为tsunami是基于UDP的,但仍然具有一些类似于TCP的功能,例如TCP公平、友好等。有人可以解释一下这个问题吗?我对此感到非常困惑。 最佳答案 TCP几乎总是使用SOCK_STREAM而UDP使用SOCK_DGRAM。TCP(SOCK_STREAM)是一种基于连接的协议(protocol)。连接已建立,并且双方进行对话,直到

amazon-web-services - 无 SDK 的 Amazon Transcribe Streaming API

我正在尝试使用来自Go1.11的Amazon新的流式转录API。目前亚马逊只提供JavaSDK,所以我正在尝试低级方式。唯一相关的文档是here但它没有显示端点。我在Javaexample中找到了它它是https://transcribestreaming..amazonaws.com我正在尝试爱尔兰地区,即https://transcribestreaming.eu-west-1.amazonaws.com.这是我打开HTTP/2双向流的代码:import("crypto/tls""github.com/aws/aws-sdk-go-v2/aws""github.com/aws/aw

linux - UNIX 域 STREAM 和 DATAGRAM 套接字之间的区别?

这个问题NOT是关于STREAM类型和DATAGRAM类型INTERNET套接字的区别。我知道STREAM套接字使用TCP,数据报套接字使用UDP以及所有TCP、UDP内容、按顺序到达的数据包、ACK、NACK等。我了解这些在互联网上的重要性。Q1)当我创建一个本地套接字的UNIX域套接字时,该套接字是STREAM套接字还是DATAGRAM套接字有什么关系。这种类型的套接字会将数据写入套接字文件,在这种情况下协议(protocol)是否重要,因为我没有通过网络传输数据?如果我使用基于UNIX的DATAGRAM套接字,在这种情况下是否有可能丢失数据?Q2)UNIXDATAGRAM套接字是

linux - Linux 上的 NuGet : Error getting response stream

我正在尝试在Linux(Ubuntu12)上运行NuGet。我有Mono3.0.6(从源代码编译)。$mono--runtime=v4.0.30319.nuget/NuGet.exeupdate-selfCheckingforupdatesfromhttps://nuget.org/api/v2/.Errorgettingresponsestream(Write:Theauthenticationordecryptionhasfailed.):SendFailure我收集到,该错误是由于某些证书(最有可能是nuget.org证书)不受信任所致。这个blogposthasmoredeta

ruby-on-rails - 在 PATH 中获取警告 "Insecure world writable dir/home/chance ",rails 和 gem 的模式 040777

我试过this但它没有用,似乎适用于osx。我有一个带有rvm、rails3和ruby​​1.9.2的全新Ubuntu10.10安装。我有一个新的rails应用程序,但使用gem或rails会导致以下警告(有滞后)。$rails-v/home/chance/.rvm/gems/ruby-1.9.2-p180@global/gems/railties-3.0.5/lib/rails/script_rails_loader.rb:11:warning:Insecureworldwritabledir/home/chanceinPATH,mode040777/home/chance/.rvm

PHP file_get_contents() 返回 "failed to open stream: HTTP request failed!"

我在从PHP代码调用url时遇到问题。我需要使用我的PHP代码中的查询字符串调用服务。如果我在浏览器中输入url,它可以正常工作,但如果我使用file-get-contents()进行调用,我会得到:Warning:file-get-contents(http://....)failedtoopenstream:HTTPrequestfailed!HTTP/1.1202Acceptedin...我使用的代码是:$query=file_get_contents('http://###.##.##.##/mp/get?mpsrc=http://mybucket.s3.amazonaws.c

java - "Stream"和 "Buffer"在 Java I/O 中究竟是什么意思?

我刚刚了解了使用BufferedReader的输入/输出。我想知道Stream和Buffer这两个词到底是什么意思?这行代码还有什么作用:BufferedReaderbr=newBufferedReader(newInputStreamReader(System.in)); 最佳答案 Java有两种用于输入和输出(I/O)的类:streams和readers/writers。流(InputStream、OutputStream以及扩展这些的所有内容)用于从文件、网络或任何其他设备读取和写入二进制数据。Readers和writers用

具有批处理功能的 Java 8 Stream

我有一个包含项目列表的大文件。我想创建一批项目,用这批项目发出一个HTTP请求(所有项目都需要作为HTTP请求中的参数)。我可以使用for循环非常轻松地做到这一点,但作为Java8爱好者,我想尝试使用Java8的Stream框架编写它(并获得延迟处理的好处)。例子:Listbatch=newArrayList(BATCH_SIZE);for(inti=0;i0)process(batch);我想做一些很长的事情lazyFileStream.group(500).map(processBatch).collect(toList())最好的方法是什么? 最佳答案

mongodb - MongoDB Change Streams 导致性能严重下降

我想获得有关Node.js中MongoDB数据库更改的实时更新。单个MongoDB更改流几乎可以立即发送更新通知。但是,当我打开多个(10+)个流时,数据库写入和通知到达之间会出现大量延迟(长达几分钟)。这就是我设置变更流的方式:letcursor=collection.watch([{$match:{"fullDocument.room":roomId}},]);cursor.stream().on("data",doc=>{...});我尝试了另一种设置流的方法,但速度一样慢:letcursor=collection.aggregate([{$changeStream:{}},{$