如何创建持久性TCPSockets？

如何解决如何创建持久性TCPSockets？

| 我有一台服务器，它连续向客户端发送两条消息：

require \'socket\'
require \'thread\'
connections = []
server = TCPServer.new(9998)
loop do
  Thread.start(server.accept) do |client|
    client.print \'Once\'
    client.print \'Upon a time.\'
  end #eo Thread
end #eo infinte loop

客户是：

require \'socket\'
client = TCPSocket.new(\'localhost\',9998)
2.times { print client.read }
client.close

客户端“处于暂停状态”，直到我关闭服务器，然后才打印出消息。我知道在服务器上添加ѭ2可以解决暂停问题，但是我不想关闭套接字。 我知道有些应用程序会重用TCPSocket。因此，它可以是

Client > Server

，

Server > Client

，

Client > Server x2

，依此类推。我确信在Ruby中可以做到这一点；我只是不知道如何。 因此，我的问题清单是： 如上所述，如何创建持久服务器<->客户端连接？ 有没有更好的方法可以在不使用

loop

的情况下保持服务器打开？ 为什么在服务器中没有

client.close

的情况下如此保持挂起状态？服务器在发送消息之前是否缓存消息？     

解决方法

              如上所述，如何创建持久服务器<->客户端连接。    您有多种选择：您可以编写一个线程服务器，其中一个共享内存最多的单个“进程”执行多个执行线程，每个线程都具有一些线程本地存储，例如。

client

。或者，您可以编写一个多进程服务器，其中每个客户端连接都通过ѭ9获得自己的独立进程（这几乎意味着它只能在Unix上运行，因为Windows尝试实现ѭ9永远无法正常工作）。或者，您可以编写基于事件循环的状态机，并使用

select(2)

或

poll(2)

或

epoll(4)

管理哪些客户端可读，可写且有错误。 在它们之间进行选择似乎很困难，但是有可用的指南。我想建议-小型系统（您预计仅具有20-30个并发客户端）可以通过线程或分支服务器很好地处理。如果您希望超出并发客户端的数量，则应使用EventMachine或libevent之类的工具来编写服务器。 （无论哪种维护方式可能都比较容易，也可能不容易。）   2）有没有使服务器保持打开状态而不使用循环的更好方法[因为我感觉自己已经通过创建一个无限循环而犯了谋杀罪] 无限循环是非常好的:)，但有时提供一种重启服务器或通过via14或专用命令界面终止服务器的方法是有意义的。   3）为什么在服务器中没有client.close的情况下它会保持暂停状态？服务器在发送消息之前是否缓存消息？ 嗯，这是您真正需要的问题-TCP将尝试缓冲来自服务器的多个数据包的结果，并且由于可能需要在路由中对太大的数据包进行分段，因此作为客户端，您无法保证保留任何类型的数据报边界。 服务器的TCP / IP堆栈很有可能在发送第一个数据包之前稍等片刻，以查看是否很快就会有更多数据。 （它经常这样做。）可能将对

client.print()

的两个调用合并为一个TCP数据包。您的客户两次呼叫“ 16”，但是可能只有足够的数据可以读取一次。如果想让TCP流立即发送第一个数据包，可以考虑设置ѭ17套接字选项以禁用此小延迟。 （但是它可能无法完全解决所有问题；您可能需要将它与

TCP_CORK

结合使用，以尝试“整理”所有写操作，直到您明确清除它们为止。这可能是一个糟糕的主意。） 更好的选择是重新编写客户端，以了解服务器与客户端之间的协议。它需要将输入读入缓冲区，解析缓冲区以查找“完整消息”，使用这些消息，然后返回其主事件循环。 也许您的协议是读/写以

\"\\n\"

字符结尾的ASCII或UTF-8。在这种情况下，您可以将

print

更改为

puts

，或在适当的位置添加

\\n

，然后将

read()

更改为

readline()

。 （这将使标准IO库为您处理您的协议。）另一种方法是发送具有长度+数据对的数据，并等待正确的数据长度。     ,        改用看跌期权。如果要确定发送成功，请使用socket.flush。否则将缓冲数据。