Tcp/IP实例

package selftest;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class SocketTest
{

public SocketTest()
{
// TODO Auto-generated constructor stub
}

/**
* @param args
*/
public static void main(String[] args) throws Exception
{

System.out.println("server");
Server s = new Server();
s.receive().start();
s.send().start();
}
}

class Server
{

public Server()
{
}

public Thread receive()
{
return new Thread()
{
@Override
public void run()
{
try
{
ServerSocket rserver = new ServerSocket(7777);
Socket rsocket = rserver.accept();
BufferedReader rbr = new BufferedReader(
new InputStreamReader(rsocket.getInputStream()));
String client = "";
while (true)
{
client = rbr.readLine();
System.out.println("client say: " + client);
}
/*rbr.close();
rsocket.close();
rserver.close();*/
}
catch (IOException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
};
}

public Thread send()
{
return new Thread()
{
@Override
public void run()
{
try
{
String line = "";
Socket client = null;
client = new Socket("192.168.1.42", 8888);
BufferedReader br = new BufferedReader(
new InputStreamReader(System.in));
PrintWriter pw2 = new PrintWriter(new BufferedWriter(
                            new OutputStreamWriter(client.getOutputStream())), true);
line = br.readLine();
while (true)
{
//line = "server say: " + line;
pw2.println(line);
//pw.flush();
System.out.println("server say: "+line);
line = br.readLine();
// socketTest.writer(client.getOutputStream(),
// "client:");
// socketTest.read(client.getInputStream(),
// "client:");
}
/*br.close();
br.close();
client.close();*/
}
catch (Exception e)
{
try
                    {
                        Thread.sleep(1000);
                    } catch (Exception ex)
                    {
                        ex.printStackTrace();
                    }
}
}
};
}
}

package selftest;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class SocketTest2
{
public static void main(String[] args)
{
System.out.println("client");
SocketTest2 c = new SocketTest2();
c.receive().start();
c.send().start();
}

public SocketTest2()
{

}

public Thread receive()
{
return new Thread()
{
@Override
public void run()
{
try
{
ServerSocket rserver = new ServerSocket(8888);


String client = "";

while (true)
{Socket rsocket = rserver.accept();BufferedReader rbr = new BufferedReader(
new InputStreamReader(rsocket.getInputStream()));
client = rbr.readLine();
System.out.println("server say: " + client);
}
/*
* rbr.close(); rsocket.close(); rserver.close();
*/
}
catch (IOException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
};
}

public Thread send()
{
return new Thread()
{
@Override
public void run()
{
try
{
String line = "";
Socket client = null;
client = new Socket("192.168.1.42", 7777);
BufferedReader br = new BufferedReader(
new InputStreamReader(System.in));
PrintWriter pw = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(client.getOutputStream())),
true);
line = br.readLine();
while (true)
{
pw.println(line);
// pw.flush();
System.out.println("client say: " + line);
line = br.readLine();
// socketTest.writer(client.getOutputStream(),
// "client:");
// socketTest.read(client.getInputStream(),
// "client:");
}
/*
* br.close(); br.close(); client.close();
*/
}
catch (Exception e)
{
try
{
Thread.sleep(1000);
}
catch (Exception ex)
{
ex.printStackTrace();
}
}
}
};
}
}