import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
public class SocketClient
{
Socket socket = null;
public SocketClient(String serverIP, String serverPort)
{
try
{
this.socket = new Socket(serverIP, Integer.parseInt(serverPort));
} catch (NumberFormatException e1)
{
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (UnknownHostException e1)
{
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (IOException e1)
{
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
public void run()
{
try
{
OutputStream netOut = socket.getOutputStream();
DataOutputStream doc = new DataOutputStream(netOut);
DataInputStream in = new DataInputStream(socket.getInputStream());
System.out.println("ACK_From_Server>" + in.readUTF());
int c;
String inputStr = "";
while (true)
{
inputStr="";
while ((c = System.in.read()) != -1)
{
if (c == '\n')
{
break;
}
inputStr = inputStr + (char) c;
inputStr = inputStr.replace('\r', ' ');
inputStr = inputStr.replace('\t', ' ');
}
doc.writeUTF(inputStr.trim());
System.out.println("ACK_From_Server>>" + in.readUTF());
if (inputStr.trim().equals("exit"))
{
System.out.println("##exit server successfully.");
break;
}
}
netOut.close();
doc.close();
in.close();
} catch (UnknownHostException e)
{
e.printStackTrace();
} catch (IOException e)
{
e.printStackTrace();
} finally
{
if (socket != null)
{
try
{
socket.close();
} catch (IOException e)
{
}
}
}
}
}
- 1
- 2
前往页