編集：問題を解決しました：
while(!finish.equals("readline")){
publish(finish);
finish = Main.in.readLine();
}
次のように変更する必要があります：
while(true){
publish(finish);
finish = Main.in.readLine();
}
古い質問：
私はJavaでチャットアプリケーションを書いています。簡単なGUIを作成しましたが、正常に動作しています。しかし今、私はチャットメッセージを収集する部分をスレッドセーフになるように書き直しました。ログイン時に、サーバーはチャットで準備ができているすべてのメッセージをクライアントにプッシュします。これはうまく機能します。この瞬間の後、GUIは応答し続け、コマンドを送信してサーバーに到達しますが、process-methodが呼び出されないため、何も返されません。私は何が間違っているのですか？
これが私が話しているコードです：
package Client;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.List;
import javax.swing.SwingWorker;
public class ChatReceiver extends SwingWorker<Void, String> {
@Override
protected Void doInBackground() {
try {
Main.echoSocket = new Socket(Main.ip, 4444);
Main.out = new PrintWriter(Main.echoSocket.getOutputStream(), true);
Main.in = new BufferedReader(new InputStreamReader(
Main.echoSocket.getInputStream()));
} catch (UnknownHostException e) {
System.err.println("Don't know about host.");
} catch (IOException e) {
System.err.println("Couldn't get I/O for "
+ "the connection to: localhost.");
}
publish("Sending Login-Request...");
Main.out.println("login");
try {
String text = Main.in.readLine();
String status = Main.in.readLine();
publish("Receiving: " + text + " " + status);
if(status.equals("readline") && text.equals("ready")){
String finish = "logging in...";
Main.out.println(Main.name + " SZUTKEY");
while(!finish.equals("readline")){
publish(finish);
finish = Main.in.readLine();
}
}else{
throw new RuntimeException("Fuck it login died!");
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
@Override
protected void process(List<String> chats) {
Main.printTest("xxx");
for(String s : chats.toArray(new String[0])){
Main.printTest("called");
Main.printTest(s);
}
Main.textField.validate();
Main.textField.repaint();
}
}
これは私のGUIで呼び出されます：
loginAction = new AbstractAction("Login") {
/**
*
*/
private static final long serialVersionUID = -3279591081543889275L;
@Override
public void actionPerformed( ActionEvent arg0 ) {
name = JOptionPane.showInputDialog("Please input your Chatname");
ip = JOptionPane.showInputDialog("Please input the Chatserver-IP", "localhost");
(chat = new ChatReceiver()).execute();
}
};