假设我们在 Java 中有一个简单的 Echo 客户端/服务器对。据我了解，一旦 socket 的一侧断开，整个连接就会消失。
但是，如果我想要一个可以始终保持 Activity 状态的服务器，即使客户端挂掉了。我希望能够恢复断开的连接。
回声服务器:
import java.net.Socket;
import java.net.ServerSocket;
public class EchoServer {
public static void main(String[] args) throws Exception {
// create socket
int port = 4444;
ServerSocket serverSocket = new ServerSocket(port);
System.err.println("Started server on port " + port);
// repeatedly wait for connections, and process
while (true) {
// a "blocking" call which waits until a connection is requested
Socket clientSocket = serverSocket.accept();
System.err.println("Accepted connection from client");
// open up IO streams
In in = new In (clientSocket);
Out out = new Out(clientSocket);
// waits for data and reads it in until connection dies
// readLine() blocks until the server receives a new line from client
String s;
while ((s = in.readLine()) != null) {
out.println(s);
}
// close IO streams, then socket
System.err.println("Closing connection with client");
out.close();
in.close();
clientSocket.close();
}
}
}
感谢任何提示
最佳答案
您缺少的是“ session ”的概念。想一想服务器的位置，当一些位“在线”到达时。这些怎么办？使用 TCP/IP，在线路上已经存在一些信息，即:
服务器的操作系统使用 src/dest addr/port 信息来决定这是否是“一个已经在进行中的对话”。它主要考虑 dest port(因为消息已经通过 Internet 和防火墙到达机器本身)来决定是否让您的 Java 程序监听“dest port”。但是，它使用整个 src-addr/src-port/dest-addr/dest-port 来尝试将有效载荷传递给您的程序按照发送者发送它们的顺序(这可能不是他们到达的顺序，因为中间有互联网)。请注意，单个“消息”实际上可能会分成多个数据包。您的操作系统的 TCP/IP 堆栈正在为您完成大量工作。
但是，请注意，为了代表您执行此功能，操作系统必须投入一些资源来“跟踪”TCP/IP session 的状态。至少，对于每组 port/addr src/dest，需要有一个计数器来记录最后一个收到的“数据包”，一些缓冲区空间来保存数据包，直到你的程序准备好使用它们，等等
现在 TCP/IP 堆栈实现者面临的问题是“我应该‘坚持’到这种状态多长时间”？ 10秒够吗？ 20分钟？在某个时候，在一段时间没有收到客户端的消息后， session 必须“超时”。如果在一个序列中有更多的数据包要发送，并且客户端再次开始发送它们，服务器必须能够说“抱歉，你正在向我发送一些先前消息的数据包 234，但是因为我没有收到你一会儿，我扔掉了数据包 1-233。我们可以重新开始吗？”。
所以从这个意义上说，没有办法阻止客户端“断开连接”。当然，您可以继续监听套接字，以防客户端恢复并发送更多数据。但是您和您的客户需要一种方法来“从中断处继续”。
在 HTTP 中，这是通过使用“ session cookie”实现的——服务器提供给客户端的一个长的唯一字符串，并且客户端重新发送每个新请求(无论它是否发生在同一个 TCP 级 session 中) ).这是一个“应用程序级 session ”，其生命周期比 TCP session 长。
由于您正在编写一个应用程序，并且听起来您对客户端和服务器彼此之间的对话(“协议(protocol)”)有一定程度的控制权，因此您有更多关于如何达成一致的选择什么是 session ，如果客户端“离开”( session 超时)如何处理事情，以及双方将如何恢复并“从我们离开的地方继续”(重新建立 session )。不要忘记身份验证!
正如其他人所说，这在很大程度上取决于您要实现的目标。
关于java - 在java网络编程中，有没有办法在Client端关闭的情况下保持Server端打开？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31531422/
这是在Ruby中设置默认值的常用方法:classQuietByDefaultdefinitialize(opts={})@verbose=opts[:verbose]endend这是一个容易落入的陷阱:classVerboseNoMatterWhatdefinitialize(opts={})@verbose=opts[:verbose]||trueendend正确的做法是:classVerboseByDefaultdefinitialize(opts={})@verbose=opts.include?(:verbose)?opts[:verbose]:trueendend编写Verb
我想在一个没有Sass引擎的类中使用Sass颜色函数。我已经在项目中使用了sassgem，所以我认为搭载会像以下一样简单:classRectangleincludeSass::Script::FunctionsdefcolorSass::Script::Color.new([0x82,0x39,0x06])enddefrender#hamlengineexecutedwithcontextofself#sothatwithintemlateicouldcall#%stop{offset:'0%',stop:{color:lighten(color)}}endend更新:参见上面的#re
我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么？ 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设？ 关于java-等价于Java中的RubyHash，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/22737685/
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java，并成功地将它与另一个Java包一起使用，但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我最近决定从我的系统中卸载RVM。在thispage提出的一些论点说服我:实际上，我的决定是，我根本不想担心Ruby的多个版本。我只想使用1.9.2-p290版本而不用担心其他任何事情。但是，当我在我的Mac上运行ruby--version时，它告诉我我的版本是1.8.7。我四处寻找如何简单地从我的Mac上卸载这个Ruby，但奇怪的是我没有找到任何东西。似乎唯一想卸载Ruby的人运行linux，而使用Mac的每个人都推荐RVM。如何从我的Mac上卸载Ruby1.8.7？我想升级到1.9.2-p290版本，并且我希望我的系统上只有一个版本。 最佳答案
下面的代码在我第一次运行它时就可以正常工作:require'rubygems'require'spreadsheet'book=Spreadsheet.open'/Users/me/myruby/Mywks.xls'sheet=book.worksheet0row=sheet.row(1)putsrow[1]book.write'/Users/me/myruby/Mywks.xls'当我再次运行它时，我会收到更多消息，例如:/Library/Ruby/Gems/1.8/gems/spreadsheet-0.6.5.9/lib/spreadsheet/excel/reader.rb:11
我在Rails应用程序中使用CarrierWave/Fog将视频上传到AmazonS3。有没有办法判断上传的进度，让我可以显示上传进度如何？ 最佳答案 CarrierWave和Fog本身没有这种功能；你需要一个前端uploader来显示进度。当我不得不解决这个问题时，我使用了jQueryfileupload因为我的堆栈中已经有jQuery。甚至还有apostonCarrierWaveintegration因此您只需按照那里的说明操作即可获得适用于您的应用的进度条。 关于ruby-on-r
我只想对我一直在思考的这个问题有其他意见，例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我
什么是ruby的rack或python的Java的wsgi？还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht
这篇文章是继上一篇文章“Observability：从零开始创建Java微服务并监控它（一）”的续篇。在上一篇文章中，我们讲述了如何创建一个Javaweb应用，并使用Filebeat来收集应用所生成的日志。在今天的文章中，我来详述如何收集应用的指标，使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值，然后一切都回到一个请求。这也意味着这些指标可能不准确，你还想提取最小/