asyncsocket相关内容
我正在尝试理解异步库,特别是使用套接字。我写了一些代码,试图获得理解, 我想异步运行发送器套接字和接收器套接字。我把所有的数据都发送到了最后一个,但是之后我必须再运行一次循环。看一下如何做到这一点,我发现了this link from stackoverflow,我在下面实现了它--但是这里发生了什么呢?有没有比先调用stop再调用run_forever更好/更明智的方法呢? 事件循环
..
我正在尝试让 iPhone 程序在模拟器上运行.我的问题是接收 UDP 数据.我使用 asyncUdpSocket.如果我创建一个套接字并使用 sendData:(NSData) toHost:,... 它工作正常. 我想不明白的是接收函数是如何工作的. 我假设是这样的: socket = [[AsyncUdpSocket alloc] initWithDelegate:self];
..
我有一个异步 UDP 服务器类,其套接字绑定在 IPAddress.Any 上,我想知道接收到的数据包发送到哪个 IPAddress(...或在哪个 IPAddress 上接收).看来我不能只使用 Socket.LocalEndPoint 属性,因为它总是返回 0.0.0.0 (这是有道理的,因为它绑定到那个......). 以下是我目前正在使用的代码中有趣的部分: private Soc
..
我用套接字编写了一个 pythonic 服务器.它应该同时(并行)接收请求并并行响应它们.当我向它发送多个请求时,回复的时间比我预期的要长. 服务器: 导入日期时间导入异步,timeit导入json,回溯从异步导入 get_event_loop请求列表 = []循环 = asyncio.get_event_loop()async def handleData(reader, writer)
..
我一直在使用 cocoaasyncsocket 作为使用 asyncsocket 的 Windows .net 服务器的客户端.我正在使用 ProtocolBuffers 对消息进行编码.这些共同构成了一套很棒的工具. 但是最近我注意到,如果我让客户端长时间连接到服务器 - 很多小时 - 当我尝试请求数据时,消息似乎已发送但从未到达服务器.我将此称为“无声"断开连接,因为我没有收到通常出现网
..
我有一个代码,它使用异步套接字向客户端发送消息并期待它的响应.如果客户端没有在指定的内部回复,它将认为超时.网上有些文章建议使用WaitOne,但这会阻塞线程,推迟使用I/O完成的目的. 处理异步套接字超时的最佳方法是什么? Sub OnSend(ByVal ar As IAsyncResult)Dim socket As Socket = CType(ar.AsyncState ,So
..
我最初在我的活动中实现了一个异步任务,它将数据发送到服务器.但是当我改变活动时,连接丢失了.为了避免这种情况,我的方法是实现一个集中网络操作并将数据发送到服务器的服务,该服务的代码如下 import java.io.BufferedWriter;导入 java.io.OutputStreamWriter;导入 java.io.PrintWriter;导入 java.net.InetAddress
..
我有这两个类,它们是我的服务器应用程序(桌面)的一部分,需要在建立连接后将命令发送回客户端. 当我尝试这样做时: clients[i].Send("info"); Send() 例程(Listener.cs)是可访问的,但我有以下语法错误: 如何解决这个问题? Listener.cs 使用系统;使用 System.Collections.Generic;使用 System.
..
我按照以下方案编写了一个多线程UDP服务器: 方案:1 个接收线程(多个Worker Threads,每个都有自己的Socket,没有bindend,只创建了Ipv4、UDP、Datagram)消息被推送到 1 个工人,然后继续执行,然后发送一个带有自己的套接字的应答. 问题:这在我自己的所有测试程序上都可以完美运行,但由于某些奇怪的原因,它不适用于我正在模拟服务器的旧软件.该软件使用
..
在本地千兆网络上,我有一个使用单个 TCP 服务器和多个客户端的应用程序.每个客户端每 30 秒 ping 服务器,打开 TCP 连接,向其发送状态消息,然后关闭. 服务器使用 SocketAsyncEventArgs 设置,与 这里(为简洁起见省略) 客户端使用 TcpClient. 客户端代码相关部分: using (TcpClient client = new TcpCl
..
我正在尝试为我的项目实现异步套接字.这是代码 public void Start(int listenPort){var ipHostInfo = Dns.Resolve(Dns.GetHostName());var ipAddress = ipHostInfo.AddressList[0];var localEndPoint = new IPEndPoint(ipAddress, liste
..
如何使以下可观察的重复发生,直到stream.DataAvailable为false? 目前看来它永远不会停止. AsyncReadChunk和Observable.在Defer部分内部返回,先进行OnNext调用,再进行OnCompleted调用. 当Repeat收到OnNext调用时,会将其传递给TakeWhile.当TakeWhile's不满意时,它会完成可观察到的操作,但是我认为On
..
我从几个示例中提取了设置连接到服务器的全双工C#TCP客户端的信息.基本概念是客户端和服务器都发送/接收消息(命令和事件).因此,我开发了FullDuplexSocket类,该类公开了一个Send方法将消息发送到服务器,以及一个事件处理程序以从服务器接收消息.一切正常,除了我似乎无法刷新从服务器接收到的消息缓冲区.每次服务器发送新消息时,我套接字中的缓冲区将包含所有旧消息(已读取)和新消息.我可以
..
我目前正在从事一个项目,该项目需要通过网络与分布式系统的某些实体使用不同数据类型的通信,并且我正在使用ZMQ。 该项目的主要目标是拥有一个中央节点,为可以随时连接的客户端提供服务。对于连接的每个客户端,中央节点应管理两者之间的消息通信。 当前,目前,所有通信都通过TCP进行。 客户端需要发送和随时接收消息,因此它们是 ZMQ_DEALER 类型的套接字,中央节点是 ZMQ_ROU
..
我对异步编程并不很熟悉,我有一个问题. 我的问题如下.给定boost.asio中C ++ 11的echo_server示例:我想知道是否可以在C ++ 14中将std::make_shared替换为C ++ 14中的std::unique_ptr,从而避免引用计数的开销. 我不确定,因为我们有shared_from_this(),但没有类似uniqu
..
我正在tcp::socket上使用boost::asio::connect.当一切正常时,connect立即返回,但在网络较差的情况下,connect在经过15秒的日志等待后超时.我不能等那么久,所以想减少超时时间.不幸的是,到目前为止,我还没有遇到任何解决方案. 我看到了使用async_wait和decimate_timer一起使用的解决方案,但是所有这些示例都是用于接收/发送操作,而不是
..
与使用(双向)NetworkStream的异步IO有关, MSDN 说:“每次对BeginRead的调用都必须调用一次EndRead." 即使EndRead()会引发异常,例如在发出BeginRead()之后关闭NetworkStream的情况下,这也是真的吗? 我不需要引发异常的开销,但是我也不想泄漏由BeginRead()保留的OS宝贵资源. 我也知道在测试流状态和条件End
..
我有一个Java android代码,该代码将数据(图像或文本)发送到C#应用程序,以接收这些数据(我正在使用异步套接字).但是存在一个相对于 BeginReceive() 函数的问题,当发送图像时,该函数没有接收到完整的数据.那么,我该如何制作一种“循环"来接收完整的数据并在显示后(例如)图片框上的图片? 表格 private Listener listener; private T
..
我正在使用GCDAsyncUdpSocket将数据发送/接收到多播组.在GCDAsyncUdpSocket.m文件中,我找到了下面的设置,并将其更改为例如32768.但是我仍然无法接收到大于9216字节的数据包. max4ReceiveSize = 9216; max6ReceiveSize = 9216; 还有其他设置吗? 编辑: 我发现GCDAsyncUdpSocket类确实提
..
关于如何检查端口是否打开,我还没有找到任何东西.我尝试使用AsyncSocket类实现它,但是尽管我拒绝了到服务器上该端口的所有连接,但它始终返回TRUE. 此外,我尝试使用AsyncSocket的isConnected方法,但始终返回FALSE. 到目前为止,我的代码: //Init socket socket=[[AsyncSocket alloc] initWithDelegat
..