public class MessageClient
{
public static void main(String[] argv) {
MessageClient client = new MessageClient();
client.converse();
}
protected void converse()
{
int port = new Integer(9000).intValue();
Socket sock = null;
try
{
sock = new Socket("localhost", port);
InputStream inputStream = sock.getInputStream();
OutputStream outputStream = sock.getOutputStream();
BufferedReader streamReader = new BufferedReader(new InputStreamReader(inputStream));
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
PrintStream printStream = new PrintStream(outputStream);
String line = null;
while ((line = reader.readLine()) != null)
{
printStream.print(line + "\n");
String response = streamReader.readLine();
System.out.println("Server response: " + response);
}
}
catch (IOException e) {
e.printStackTrace();
}
}
}
public class MessageServer
{
public static void main(String[] argv) {
MessageServer s = new MessageServer();
s.converse();
}
protected void converse()
{
int port = new Integer(9000).intValue();
ServerSocket sock = null;
try
{
sock = new ServerSocket(port);
Socket socket = sock.accept();
InputStream inputStream = socket.getInputStream();
OutputStream outputStream = socket.getOutputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
PrintStream printStream = new PrintStream(outputStream, true);
String line = null;
while ((line = reader.readLine()) != null)
{
System.out.println("From client: " + line);
printStream.print("Thanks" + "\n");
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
}