草庐IT

READ_WRITE

全部标签

c# - 使用 .Net 的 NetworkStream.Read/BeginRead 分隔应用程序协议(protocol)帧

我的问题对网络编程来说更笼统,但因为我正在尝试编写一个ModbusTCP服务器(从站),所以我将用它来说明我的问题。在ModbusTCP帧中,帧的第5和第6个字节给出了帧的大小:字节1和2:交易ID字节3&4:协议(protocol)Idbytes5&6:帧中剩余多少字节字节7-n:帧的其余部分。当使用NetworkStream.Read()/BeginRead()时,如何分隔接收到的帧?我看到一些开源实现只读取前6个字节,解析字节5和6以获得帧其余部分的大小,然后读取帧的其余部分。但是,如果您的框架中没有开始和结束定界符,您如何知道框架的开始和结束位置?例如,客户端可能发送了一些垃圾

java - 与 Java 服务器的 PHP tcp 连接在 socket_read() 上挂起

我正在尝试创建一个PHP客户端来连接到一个简单的Java服务器,发送一些数据,然后接收返回的响应。Java服务器在与用Java编码的简单客户端交互时响应良好,但是一旦从PHP客户端发送请求,它就会在调用socket_read()时无限期挂起。如果这一行被注释掉,数据就可以正常到达,但如果没有注释掉,就好像Java服务器根本没有接收到数据。这与之前提出的问题非常相似:SimpleJavaTCPServerandPHPClientProblems但据我所知,我的代码在操作上与给出的解决方案几乎相同。Java服务器是多线程的,用于程序的其他部分,我不认为这是导致问题的原因。php脚本有一个U

sockets - 如何模拟 boost::asio::write 超时

我正在尝试用超时模拟boost::asio::write。或者你可以说,我正在尝试使用带有超时的boost::asio::async_write。如我所见,boost::asio::write会阻塞,直到所有数据都在另一侧被写入和读取。这种功能当然需要超时。那么,通读thissimpleanswerhere由RobertHegner演示如何使用timeout执行boost::asio::async_read,我正在尝试采用相同的逻辑通过这样做来写:size_twrite_data_with_time_out(){longtime_out_secs=2;boost::optionalti

c - write() 和 TCP/IP 开销

如果我使用write()逐字节写入套接字文件描述符,现在每个字节都是一个数据包吗?套接字是否会为每个字节添加TCP/IPheader?或者它是否有一个缓冲机制(我个人对此表示怀疑,因为我没有显式刷新)。例如:write(fd,'a',1);write(fd,'b',1);write(fd,'c',1);这会不会比say效率低write(fd,'abc',3);我必须在这里问这个问题,因为我不具备监控流量中TCP/IPheader的专业知识。谢谢。 最佳答案 不,并不是每个字节都会变成一个数据包。由于Nagle算法和其他因素,有些可能

c++ - boost:asio::async_write:已发送数据但未调用处理程序

我有以下类定义://SocketTypeTmaybee.g.'boost::asio::ip::tcp::socket'templateclassSocket:publicSocketTypeT,publicboost::enable_shared_from_this>{[...]在这个类中,我有以下方法“writeAsync”:voidwriteAsync(conststd::string&strData){boost::asio::async_write(*this,boost::asio::buffer(strData),boost::bind(&Socket::handle_w

java - 安卓 : Keep socket open to read message from server

我正在开发一个Android应用程序首先,我必须通过TCP套接字连接到硬件服务器连接后,我必须发送*99*1##到服务器,然后服务器将响应"*#*1##*#*1##"然后,我需要让这个套接字保持Activity状态并读取传入的消息在这之后,服务器可以不时地向我发送消息。但是,消息何时发送或消息长度未确定。每条消息都以“##”结尾,例如*1*1*18##、*1*0*19##、*1*1*#4*11##等。当客户端(此应用程序)收到消息时,它会通知Activity更新UI。因此,我创建了一个线程子类来执行此操作publicclassServerThreadextendsThread{publ

javascript - Boost::asio::async_read_until 从不调用处理程序

我正在尝试在本地网络上的两台计算机之间建立连接,一台使用BoostAsioC++TCP异步服务器示例的略微修改版本,另一台使用NodeJS。tcp_client.js:varnet=require('net');varHOST='127.0.0.1';varPORT=14002;varclient=newnet.Socket();client.connect(PORT,HOST,function(){console.log('CONNECTEDTO:'+HOST+':'+PORT);//Writeamessagetothesocketassoonastheclientisconnect

c++ - 在 linux 中调用 socket.close 后 socket.read_some 需要很长时间才能返回

我将Boost.Asio用作简单的套接字库。当我打开一个套接字时,我创建了一个线程,该线程不断读取该套接字,并在套接字关闭或发生其他一些错误时返回。while((read=socket->read_some(buf,ec))!=0){//dealwithbytesread}此代码在Windows和Mac上运行良好。然而,对于Linux,当从主线程关闭套接字时,socket::read_some需要很长时间才能返回-我发现它超过2分钟。我可以做些什么来改进它吗? 最佳答案 如果你愿意cancel-ability,使用异步套接字。不要使

boost::asio::read 抛出编译错误 'read_some' 不是 'boost::shared_ptr<boost::asio::ip::tcp::socket>' 的成员

我正在尝试构建一个客户端以通过特定协议(protocol)从服务器获取数据。我知道我的代码不是最好的-但目前我仍在试验BoostASIO的基本功能。我想从TCP-Function中实现读取,它会阻塞直到接收到特定数量的字节。我的问题:当我调用boost::asio::read或boost::asio::write时出现以下错误:错误C2039:“read_some”:不是boost::shared_ptr的成员我正在使用VS2013Professional,Boost1.55.00(预编译)。这是我的代码:(您可以通过注释“//HEEERE”找到该行boost::mutexcout_l

java - TCP/IP 客户端 : best way to read multiple inputstreams from server

我正在创建一个java客户端程序,它向服务器发送命令,服务器发回确认和响应字符串。Theresponseissentbackinthismannerclient->server:cmd_stringserver->client:ack_msg(06)server->client:response_msg当我尝试读取输入时,我只能通过一个输入流读取确认消息我的客户端程序能够以某种方式读取消息(hacky方法)。要读取输入,我必须使用Bufferedreader读取确认消息。此缓冲阅读器只能读取ack_msg而不能读取以下消息需要DataInputstream代码来读取响应消息。如果我跳过