草庐IT

data_stream

全部标签

c - socket()中 "protocol"为SOCK_DGRAM或SOCK_STREAM时是否需要指定 "type"?

来自APUE#includeintsocket(intdomain,inttype,intprotocol);地点:type可以是SOCK_DGRAM、SOCK_RAW、SOCK_SEQPACKET、SOCK_STREAM和protocol可以是IPPROTO_TCP,IPPROTO_UDP,...SOCK_DGRAM可以与IPPROTO_UDP一起工作,但不能与IPPROTO_TCP一起工作吗?SOCK_STREAM可以与IPPROTO_TCP一起工作,但不能与IPPROTO_UDP一起工作吗?如果答案是肯定的,是否意味着当type为SOCK_DGRAM或SOCK_STREAM时,我

c++ - 最佳实践 : Sending typed data over TCP

我想实现一个服务器,它有一些方法,可以从中接受二维点数组(结构)。我想知道我是否应该将它实现为WebService或简单的TCP套接字。目标系统是在DebianLinux上运行的C++。就我的理解而言,WebService是基于XML/SOAP的,我可以在任何其他客户端系统上使用该接口(interface),包括它的所有数据类型。相反,普通的TCP套接字只是读取字节数组。但是有没有一种简单的方法可以通过TCP套接字实现强类型数据传输,这样我就不需要网络服务器来运行WebService?这里是一个C#示例,服务器的界面应该是这样的:publicinterfaceIService{void

.net - wcf tcp async streamed 是可能的吗?

我有一个使用tcp的服务,并且我的所有方法都是异步的,所以我实现了Begin/End方法(我使用C#4.0)。如果我只修改我的app.confing以将传输模式设置为Streamed而不是Buffered,当我在客户端中进行异步调用时,应用程序将永远等待响应。但是,如果我将传输模式更改为缓冲,则它可以正常工作。我还注意到我需要在缓冲传输模式下使用reliableSession,因为当我启动应用程序时,我收到错误10061,目标服务主动拒绝连接。我知道如果我想使用流式传输模式我不需要禁用dereliableSession,所以我想问是否可以使用异步方法的流式传输模式。谢谢。编辑:我正在尝

c# - 如何判断 Stream 何时结束?

如何在不使用BinaryWriter/Reader的情况下向接收方嵌入或告知TCP流的大小?必须有一种快速的方法让它知道它是否已经到达终点,当然,除非终止连接。tcp.GetStream().Write(ms.GetBuffer(),0,(int)ms.Length);我就是这样发送的,但接收是困难的部分。编辑:这对我不起作用:while(tt1.GetStream().DataAvailable){su=Image.FromStream(tt1.GetStream());} 最佳答案 不,没有办法(快或慢)告诉您何时到达网络流的末

node.js - 当没有设置 "on data"事件监听器时,nodejs http模块会做什么?

'usestrict';consthttp=require('http');constfs=require('fs');http.createServer((req,res)=>{(async()=>{await(newPromise((resolve,reject)=>setTimeout(resolve,10000)));console.log('recv...');req.setEncoding('utf8');req.on('data',(chunk)=>{fs.writeFileSync('test.txt',chunk,{flag:'a'});});req.on('end'

php - 如何为 set socks 5 或 php stream_socket_client 的 http 代理制作上下文数组

我不确定如何在php中为流套接字的tcp代理配置流上下文参数。我发现并测试了以下代码,但它不适用于流套接字。$context=stream_context_create(array('http'=>array('proxy'=>'tcp://'.$proxy,)));$srvHandle=stream_socket_client("tcp://{$this->server}",$errno,$errstr,30,STREAM_CLIENT_CONNECT,$context);if($srvHandle===false)$this->LogError("failedtoconnectwi

node.js - Node : TCP socket server only returns data the first time

我正在尝试在node.js中编写一个小型中继脚本,用于监听本地套接字上传入的TCP连接,并在获得连接时将流量转发给第3方。它还必须从第3方获取任何返回的数据并将其发送回原始本地套接字。我试过像http://delog.wordpress.com/2011/07/19/a-tcp-relay-mechanism-with-node-js/这样的代码它确实有效,但它要求发送者是一个正在监听套接字本身的服务器,我的实用程序旨在与任何试图创建出站TCP连接的程序一起使用。不幸的是,我遇到的问题是第一次一切都很好,客户端将数据发送到“路由器”程序,路由器将其转发到另一台服务器,然后从客户端返回数

c# - 通过 TCP 发送大对象 : "End of Stream encountered before parsing was completed"

每当我尝试从NetworkStream中反序列化double列表时,我总是收到SerializationException:EndofStreamencounteredbeforeparsingwascompleted我有一个简单的客户端服务器架构:我的TcpTransportClient包装了TcpClient的功能,我使用了两种基本方法:Send(发送消息)和Receive(阻塞直到收到消息)。Send函数接收一个Message,使用BinaryFormatter将其序列化并通过NetworkStream发送字节.publicvoidSend(Messagemessage){if(

c - TCP 套接字 : Can read() still fail with EINTR when select() indicates there are data available?

我正在使用select()从TCP套接字进行非阻塞read()。当select()指示有数据可供读取时,我不确定在read()之后是否还需要处理EINTR。 最佳答案 是的,绝对是。select函数是一个状态报告函数,它会在您调用select和您注意到它的返回值之间的某个时间报告某物的状态。它绝对没有任何future保证。这是一个非常普遍的误解。但是认为select确保future的操作将提供某些特定结果的想法与认为检查磁盘上是否有可用空间意味着future的写入不会失败一样是错误的。根据其判断,即使您认为有足够的可用空间,该实现也

php - 使 stream_socket_server 在第一次收到数据包后保持功能

我试图通过PHP的stream_socket_server()使tcp套接字服务器创建和维护持久的双向通信。Shortversionofquestion:howtohavetcpservercreatedwithstream_socket_server()stayingalive-notfailingtoreceivedataafterfirstsuccessfuldatareceptionwhichisinmycaseonesinglecharactertypedinterminalaftertelnetcommand?长版-我期望实现的目标只是为了说明,请查看使用smtp服务器远程