具体代码 给你
客户端
import java.io.*;
import java.net.*;
public class Clinet
{
public static void main(String[] args)
{
InetAddress ia = null;
Socket s = null;
BufferedReader is = null;
BufferedWriter os = null;
PrintWriter pw = null;
BufferedReader br = null;
BufferedWriter bw = null;
try {
ia= InetAddress.getByName("127.0.0.1");
// System.out.println(ia.getHostAddress());
// System.out.println(ia.getHostName());
s= new Socket(ia, 9001);
is = new BufferedReader(new InputStreamReader(s.getInputStream()));
pw = new PrintWriter(s.getOutputStream(), true);
br = new BufferedReader(new InputStreamReader(System.in));
// System.out.println("输入路径:");
// String msg = br.readLine();
// pw.println(msg);
Thread2 t = new Thread2(is);
while(true)
{
try{
t.start();
// System.out.println("您说:");
String msg1 = br.readLine();
pw.println(msg1);
}
catch (java.lang.IllegalThreadStateException e)
{
// System.out.println("您说:");
String msg1 = br.readLine();
pw.println(msg1);
}
}
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
}
}
}
class Thread2 extends Thread
{
BufferedReader br ;
public Thread2(BufferedReader br)
{
this.br = br;
}
public void run()
{
while(true)
{
try {
String msg = br.readLine();
System.out.println("服务端说:"+msg);
sleep(1000);
} catch (IOException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
}
}
}
}
服务器端
import java.io.*;
import java.net.*;
public class Sever {
public static void main(String[] args)
{
ServerSocket ss = null;
Socket s = null;
BufferedReader is = null;
OutputStream os = null;
// PrintWriter pw = null;
PrintStream pw = null;
File f = null;
BufferedReader filebr = null;
try
{
ss = new ServerSocket(9001);
System.out.println("加载中");
s = ss.accept();
is = new BufferedReader(new InputStreamReader(s.getInputStream()));
os = s.getOutputStream();
pw = new PrintStream(s.getOutputStream(), true);
Thread1 t = new Thread1(is);
filebr = new BufferedReader(new InputStreamReader(System.in));
while(true)
{
try{
t.start();
// System.out.println("您说:");
String msg1 = filebr.readLine();
pw.println(msg1);
}
catch (java.lang.IllegalThreadStateException e) {
// System.out.println("您说:");
String msg1 = filebr.readLine();
pw.println(msg1);
}
}
}
catch (IOException e)
{
// TODO Auto-generated catch block
// e.printStackTrace();
}
}
}
class Thread1 extends Thread
{
BufferedReader br ;
static int size=0;
public Thread1(BufferedReader br)
{
this.br = br;
}
public void run()
{
size++;
while(true)
{
try {
String msg = br.readLine();
System.out.println("客户端说:"+msg);
sleep(1000);
} catch (IOException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
}
}
}
}
希望可以帮助你