初使化
public class SocketClientHelper {
private Socket socket;
private String serverIp;
private int serverPort;
public SocketClientHelper() {
}
}
StartConnect
public boolean StartConnect(String serverIp, int serverPort) {
this.serverIp = serverIp;
this.serverPort = serverPort;
try {
FutureTask<Boolean> futureTask = new FutureTask<Boolean>(callable);
new Thread(futureTask).start();
return futureTask.get();
} catch (InterruptedException | ExecutionException ee) {
ee.printStackTrace();
return false;
}
}
Callable callable = new Callable() {
@Override
public Object call() {
try {
socket = new Socket(serverIp, serverPort);
} catch (Exception e) {
e.printStackTrace();
return false;
}
return true;
}
};
StopConnect
public void StopConnect() {
if (socket != null) {
try {
socket.shutdownOutput();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
socket = null;
}
}
SendMessage
public void SendMessage(String msg) {
try {
if (socket.isConnected()) {
if (!socket.isOutputShutdown()) {
PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()), true);
printWriter.println(msg);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}