草庐IT

socket_nxt

全部标签

java - 在服务于 Socket 连接的两个线程之间共享公共(public)数据

我在SO上看到很多类似的问题,但几乎没有一个在图片中有Socket。所以请花点时间阅读问题。我有服务器应用程序(使用ServerSocket)监听请求,当客户端尝试连接时,会创建新线程来为客户端提供服务(并且服务器返回监听模式以接收新请求).现在,我需要根据其他客户端发送到服务器的内容来响应一个客户端。示例:ServerSocket监听传入连接。客户端A连接,创建新线程为A服务。客户端B连接,创建新线程为B服务。A向服务器发送消息“HellofromA”。将此消息作为对客户端B的响应发送。我是整个“线程间通信”的新手。显然,上面提到的情况听起来很简单,但我描述这个是为了获得提示,因为我

java - RxJava : Observing messages emitted from a socket

我仍在努力学习RxJava。有一件事我现在无法理解。每一篇试图学习如何使用Rx的文章都向我展示了如何基于已经“可预测”的来源创建Observable,即一组项目的序列(单个值或例如简单的Iterable).大多数情况下,您会看到类似Observable.just()的内容Observableobserverable=Observable.just("Hello,world!");或者Observable.from():Observable.from("apple","orange","banana").subscribe(fruit->System.out.println(fruit)

java - Weblogic BEA-000449 : Closing socket as no data read from it during the configured idle timeout of 5 secs

我已经开始在我的weblogic10日志文件中看到这条消息。我正在运行一个大约有40-350个并发用户的应用程序。我的问题是这个错误的真正含义是什么它将如何影响用户(如果有的话)可能是什么原因造成的谢谢 最佳答案 WhatdoesthiserrorreallymeanWeblogic正在关闭用于与其中一个服务器客户端通信的套接字,因为超过五秒没有发送数据,这是您为Weblogic的空闲超时配置的值。Whatcouldbecausingthis客户端程序连接到您的服务器,发送一些数据,然后1)不关闭连接或2)消失。

java - BufferedReader 从未就绪(Java 中的 Socket 编程)

我的套接字已经像这样声明了套接字:serverAddr=InetAddress.getByName(this.ip);socket=newSocket(serverAddr,port);out=newPrintWriter(newBufferedWriter(newOutputStreamWriter(socket.getOutputStream())),true);但是,以下内容不起作用。in.ready()始终返回false,如果删除程序将卡住在Stringmessage=in.readLine();privatevoidreceive(){try{InputStreamReade

Java 网络 : evented Socket/InputStream

我正在Java的套接字上实现一个面向事件的层,我想知道是否有一种方法可以确定是否有待读取的数据。我通常的方法是从套接字读取到缓冲区,并在缓冲区填充给定字节数时调用提供的回调(如果每次到达时都需要触发回调,则可以为0),但我怀疑Java已经在为我做缓冲。InputStream的available()方法是否可靠?我应该只read()并在Socket之上做我自己的缓冲吗?还是有别的办法? 最佳答案 简而言之,不。available()不可靠(至少不适合我)。我推荐使用java.nio.channels.SocketChannel连接Se

java - 读取 S3 文件时出现 "java.net.SocketException: Socket is closed"

我正在尝试从S3读取一个csv文本文件,然后将其中的每一行发送到分布式队列以进行处理。尝试读取它时,我在读取文件的不同点(在不同的执行中)收到“java.net.SocketException:套接字已关闭”异常。这是代码:AmazonS3s3=newAmazonS3Client(newPropertiesCredentials(MyClass.class.getResourceAsStream("myCredentials.properties")));StringbucketName="myBucket";Stringkey="myFile";S3Objectobject=s3.g

java - 守夜人 Selenium "socket hang up"

在Chrome中的CI上运行Nightwatch测试。有时(大约每5个版本中有一次)我在其中一个测试中遇到以下错误。在此之前的每个测试都可以正常工作。我有最新的Chromedriver和Selenium独立服务器。我认为问题是Selenium服务器在请求中途崩溃了,我不知道为什么。ErrorretrievinganewsessionfromtheseleniumserverConnectionrefused!Isseleniumserverstarted?{Error:sockethangupatcreateHangUpError(_http_client.js:254:15)atSo

WebSocket 和 Socket 的区别

WebSocket和Socket的区别就像Java和JavaScript,并没有什么太大的关系,但又不能说完全没关系。可以这么说:1.命名方面,Socket是一个深入人心的概念,WebSocket借用了这一概念;2.使用方面,完全两个东西。当我们探讨两件事物的区别和联系时,我们想探讨些什么?对这个问题最直接的解决方法应该是去了解Socket和WebSocket的来源和用法,那么它们的区别和联系就不言自明了。SocketSocket可以有很多意思,和IT较相关的本意大致是指在端到端的一个连接中,这两个端叫做Socket。对于IT从业者来说,它往往指的是TCP/IP网络环境中的两个连接端,大多数的

java - Tomcat EOFException : Unexpected EOF read on the socket 异常

我想更好地了解Tomcat如何处理请求以及为什么会出现我的特定问题。我正在尝试使用NetflixHystrix框架增强我现有的SpringMVCWeb应用程序。这涉及添加特定于hystrix的servlet来处理以/hystrix.stream结尾的请求。根据日志(如下),此映射有效并且请求被转发到正确的servlet。但是,抛出的异常不会在servlet中发生。我还尝试扩展servlet以添加额外的日志记录-但似乎没有调用servlet中的任何方法。异常似乎是由于我不知道的Tomcat内部工作而发生的。这是我的web.xml中的一个片段(请注意,我的应用程序的其余部分工作正常-这只是

java.sql.SQLException : Io exception: Socket read timed out vs Closed Connection 异常

我正在尝试研究有关连接到Oracle数据库的以下两个错误的问题:关闭连接java.sql.SQLException:Io异常:Socket读取超时我的理解:关闭连接:发生是因为存在某种网络中断或数据库由于某种“不活动”而关闭了sessionjava.sql.SQLException:Ioexception:Socketreadtimedout:这是连接成功建立但由于某种原因套接字/数据为空并最终超时的情况因为没有可用数据。是否可以在本地OracleDB环境中复制上述错误?步骤是什么?非常感谢您花时间回复。谢谢。 最佳答案 你对关闭连