2
正しくフラッシュすることを拒否するjava.net.SocketOutputStreamで不満を感じています！私は明らかに見落とさなければならない。以下の私のGroovyスクリプトでは、Galaxy Nexus Android 4.0.2の携帯電話で動作するシンプルなソケットサーバーに接続しようとしましたが、5秒間のタイムアウトが切れた直後にソケットのクローズ例外が発生します。Groovyソケットをフラッシュできない
SocketClient.groovy
import java.net.*
socket = new Socket()
socket.connect(new InetSocketAddress(InetAddress.getByAddress([172,17,57,21] as byte[]), 58789), 5000)
println "Connected!"
socket.withStreams { input, output ->
println "Processing ${input.class.name} and ${output.class.name} streams..."
output.withWriter {
it << 'echo testing\n\n';
it.flush();
output.flush()
def readerThread = Thread.start {
println "Request written, reading response..."; println input.text
}
println "Waiting 5 secs for read to complete."
readerThread.join(5000)
}
println "Stream closed!"
}
私は作家フラッシングと間接的にラッピングへの出力ストリームの直接フラッシュを含むフラッシュのすべての異なる手段を、試してみました。ストリームが閉じられてソケットを閉じる原因となるまで、サーバーにデータは表示されず、ソケットから読み取る試行がクラッシュします。私は間違って何をしていますか？下のAndroidコードもインラインで表示します。これは、ソケットサーバーを起動する簡単なアクティビティです。
私は疑問に思ってMyServer.java
package com.example;
import android.app.Activity;
import android.os.Bundle;
import android.view.View;
import android.widget.TextView;
public class MyServer extends Activity
{
/** Called when the activity is first created. */
@Override
public void onCreate(Bundle savedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
RawSocketServer rawSocketServer = new RawSocketServer();
String port = rawSocketServer.getLocalPort();
TextView textView = (TextView) this.findViewById(R.id.mainTextView);
textView.setText("Server bound to port " + port);
rawSocketServer.start();
}
}
RawSocketServer.java
package com.example;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
* Created by IntelliJ IDEA.
* User: cliff
* Date: 5/9/12
* Time: 4:03 PM
*/
public class RawSocketServer {
public static final int PORT = 0;
private ServerSocket serverSocket;
public RawSocketServer() {
this(PORT);
}
public RawSocketServer(int port) {
try {
this.serverSocket = new ServerSocket(port);
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("server cannot bind to port " + port);
}
}
public void start() {
new Thread(new Runnable() {
public void run() {
go();
}
}).start();
}
private void go() {
Socket socket = null;
while (true) {
try {
socket = this.serverSocket.accept();
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("cannot accept from server socket" + e);
}
BufferedReader reader = null;
try {
reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("Could not get input stream from socket. " + e);
}
PrintWriter writer = null;
try {
writer = new PrintWriter(socket.getOutputStream());
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("Could not get output stream from socket. " + e);
}
try {
for (String line = reader.readLine(); line !=null; line = reader.readLine()) {
writer.print(line);
}
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException("Error reading/writing from/to socket. " + e);
}
}
}
public String getLocalPort() {
return "" + serverSocket.getLocalPort();
}
}
ちょっと黒っぽく、いいキャッチ！それは完全に意味がある、私はいくつかを確認します！ – Cliff
私は昨夜これをもう一度試して、Groovyソケットクライアントに新しい行を追加しましたが、私はまだ同じ動作をします。私はちょうどサーバーが同じ問題を抱えているかもしれないというあなたの言及を思いついたので、次にそれを試してみましょう。 – Cliff