我想在Java套接字程序中實現多線程。到目前爲止,我已經嘗試過單個連接並且它可以工作,但由於是單個連接,所以過程很慢。我應該如何繼續以使多線程處理速度更快?Java套接字程序中的多線程
import java.io.BufferedInputStream;
import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
public class MRPosting {
public static String MRPost(String strRequestMessage, String strIP,
int intPort) throws Exception {
String strResponseMessage = "";
try{
Socket socket = null;
socket = new Socket(strIP, intPort);
BufferedInputStream bin = new BufferedInputStream(
socket.getInputStream());
PrintWriter pw1 = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(socket.getOutputStream())), true);
pw1.println(strRequestMessage);
pw1.flush();
strResponseMessage = readInputStream(bin);
socket.close();
socket = null;
}catch(Exception e){
strResponseMessage = "ERROR:MRPORT_JAVA:"+e.toString();
return strResponseMessage;
}
return strResponseMessage;
}
public static String readInputStream(BufferedInputStream in)
throws Exception {
String read_msg = "";
int i = in.read();
if (i == -1) {
return "-1";
}
read_msg = read_msg + (char) i;
int available = in.available();
if (available > 0) {
byte[] Data = new byte[available];
in.read(Data);
read_msg = read_msg + new String(Data);
}
return read_msg;
}
}
到目前爲止,您尚未顯示您嘗試過的線程 – beny23