我正在编写一个大型Java应用程序的服务器部分,用于通过TCP/IP使用Java套接字与客户端通信。客户端(用PHP编写)连接到服务器,以XML格式发送查询,然后服务器发回响应。查询响应可以在单个连接中重复多次。
服务器端相当简单。它应该允许多个客户端连接,所以有一个线程侦听并为每个接受的连接生成一个会话。会话由一个对象组成,该对象包含两个用于发送和接收的LinkedBlockingQueue、两个用于使用这些队列发送和接收消息的线程以及一个处理线程。
问题是,任何消息实际上只有在套接字关闭后才能传输。响应消息进入消息队列和打印流。println()方法没有问题,但wireshark仅在客户端关闭其一侧的连接时报告传输。启用自动刷新或使用flush()创建PrintStream不起作用。关闭服务器端的套接字也不起作用,服务器仍然可以工作并接收消息。
此外,客户端在服务器端接收查询的当前实现运行良好,同样适用于本地Linux虚拟机的echo-e"test"|ocat-TCP4:192.168.37.1:1337
,但当我telnet到服务器,并尝试发送一些东西,然后服务器不接收任何东西,直到我关闭telnet客户端,与上述相同的问题。
相关的服务器代码(整个应用程序太大,无法粘贴所有内容,我正在使用很多其他人的代码):
package Logic.XMLInterfaceForClient;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.util.HashSet;
import java.util.concurrent.LinkedBlockingQueue;
import Data.Config;
import Logic.Log;
public class ClientSession {
/**
* @author McMonster
*
*/
public class MessageTransmitter extends Thread {
private final Socket socket;
private final ClientSession parent;
private PrintStream out;
/**
* @param socket
* @param parent
*/
public MessageTransmitter(Socket socket, ClientSession parent) {
this.socket = socket;
this.parent = parent;
}
/*
* (non-Javadoc)
*
* @see java.lang.Runnable#run()
*/
@Override
public void run() {
try {
out = new PrintStream(socket.getOutputStream(), true);
while (!socket.isClosed()) {
try {
String msg = parent.transmit.take();
// System.out.println(msg);
out.println(msg);
out.flush();
}
catch(InterruptedException e) {
// INFO: purposefully left empty to suppress spurious
// wakeups
}
}
}
catch(IOException e) {
parent.fail(e);
}
}
}
/**
* @author McMonster
*
*/
public class MessageReceiver extends Thread {
private final Socket socket;
private final ClientSession parent;
private BufferedReader in;
/**
* @param socket
* @param parent
*/
public MessageReceiver(Socket socket, ClientSession parent) {
this.socket = socket;
this.parent = parent;
}
/*
* (non-Javadoc)
*
* @see java.lang.Runnable#run()
*/
@Override
public void run() {
try {
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
while (!socket.isClosed()) {
String message = "";
String line;
while ((line = in.readLine()) != null) {
message = message + line + "\n";
}
if(message != "") {
parent.receive.offer(message.toString());
}
}
}
catch(IOException e) {
parent.fail(e);
}
}
}
public final LinkedBlockingQueue<String> transmit = new LinkedBlockingQueue<>();
public final LinkedBlockingQueue<String> receive = new LinkedBlockingQueue<>();
private final XMLQueryHandler xqh;
private final Socket socket;
private String user = null;
private HashSet<String> privileges = null;
/**
* @param socket
* @param config
* @throws IOException
* @throws IllegalArgumentException
*/
public ClientSession(Socket socket, Config config)
throws IOException,
IllegalArgumentException {
// to avoid client session without the client
if(socket == null) throw new IllegalArgumentException("Socket can't be null.");
this.socket = socket;
// we do not need to keep track of the two following threads since I/O
// operations are currently blocking, closing the sockets will cause
// them to shut down
new MessageReceiver(socket, this).start();
new MessageTransmitter(socket, this).start();
xqh = new XMLQueryHandler(config, this);
xqh.start();
}
public void triggerTopologyRefresh() {
xqh.setRefresh(true);
}
public void closeSession() {
try {
xqh.setFinished(true);
socket.close();
}
catch(IOException e) {
e.printStackTrace();
Log.write(e.getMessage());
}
}
/**
* Used for reporting failures in any of the session processing threads.
* Handles logging of what happened and shuts down all session threads.
*
* @param t
* cause of the failure
*/
synchronized void fail(Throwable t) {
t.printStackTrace();
Log.write(t.getMessage());
closeSession();
}
synchronized boolean userLogin(String login, HashSet<String> privileges) {
boolean success = false;
if(!privileges.isEmpty()) {
user = login;
this.privileges = privileges;
success = true;
}
return success;
}
public synchronized boolean isLoggedIn() {
return user != null;
}
/**
* @return the privileges
*/
public HashSet<String> getPrivileges() {
return privileges;
}
}
我能理解为什么在关闭套接字之前,服务器上不会收到任何消息——这似乎符合设计。在里面readLine()仅在到达流的结尾时返回null,对于TCP套接字流,这意味着套接字关闭。如果希望readLine()循环在此之前返回,则循环中的代码必须使用TCP之上定义消息的任何协议来检测消息的结尾。
这与发送完全无关。更准确的说法是,如果你一直读到流的末尾,你就不会得到流的末尾,直到对等方通过关闭套接字结束流。
这是一个同义反复。
问题内容: 我有工作的服务器和客户端应用程序,它们在发送小文件时可以完美工作,但是当我尝试通过套接字发送例如700mb的电影文件时,它给了我 我在互联网上搜索并找到了一些有关发送大文件的教程,但并不太了解它们,但是我认为我的麻烦在于编写文件。 这是服务器用来写入我的文件的代码: 这是我的客户用来发送文件的代码: 问题答案: 它之所以给您,是因为您试图在发送之前将整个文件读入内存。这完全是100%完
我试着做一个简单的服务器-客户机套接字通信,但服务器似乎无法正常工作。无论何时发送或接收,我都会收到此错误: 非插座上的插座操作:非插座上的插座操作 奇怪的是,这只会在服务器发送时出现。客户似乎还可以:
我是一个初学者程序员,所以这很可能是显而易见的,我忽略了答案。但说到这个问题。 我有一个由两部分组成的程序(它比这个例子稍微复杂一点,但情况是一样的)。该程序在客户端和服务器之间触发了多条消息。我在服务器端有一个PrintWriter来向客户机发送消息,在客户机上有一个BufferedReader来读取发送的消息。当这个例子运行时,我得到了两行作为输出。第一个消息是两个消息,第二个消息是NULL。
问题内容: 您好,我尝试使用Java中的客户端-服务器类发送文件。由于某种原因,当调用发送文件的方法时,套接字关闭。这是代码: 和来自客户端的代码: 和我得到的错误消息:严重:null java.net.SocketException:套接字已关闭 我对此并没有真正的经验,所以如果有帮助的话会很棒。 问题答案: 该方法返回一个,代表它实际读取的字节数。不能保证从字节数组中读取所需的字节数。它通常会
我正试图通过Java的socket发送一个custome对象。我知道我需要将具有我需要发送的对象的类放在相同的包中,具有相同的serialVersionUID并实现Serializable。我已经这样做了,但我仍然不能通过套接字发送对象。我错在哪里了? 以下是客户端代码: 客户端中的类用户 发送user类对象的代码: 这里是服务器的代码: user类的代码:与客户端的user完全相同(我从客户端复
问题内容: 我正在使用Java应用程序,需要通过套接字连接尽快将500,000个整数的数组从一台Android手机发送到另一台Android手机。无论是使用ObjectOutputStreams,ByteBuffers还是低级的掩码和移位转换,主要的瓶颈似乎都是在转换整数,以便套接字可以使用它们。通过套接字从一个Java应用程序向另一个Java应用程序发送int []的最快方法是什么? 这是到目前