我快崩溃了···网络传输的JB问题·

//==============================================客户端============================
package qq;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;public class Clients implements Runnable{
 Socket b=null;


public static void main(String[] args) {
Socket d;
Clients c=new Clients();
Thread th=new Thread(c);
th.start();
try {
d = new Socket("localhost",8000);
Baa a=new Baa(d);
Thread th1=new Thread(a);
th1.start();
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

public void run() {

try {
while(true){
b=new Socket("localhost",8000);
Scanner sr=new Scanner(System.in);
String ss=sr.nextLine();
OutputStream oos=b.getOutputStream();
PrintStream ps=new PrintStream(oos);
ps.println(ss);
}
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} }}
class Baa  implements Runnable{
Socket t = null;
InputStream in;
public Baa(Socket t){
this.t=t;
}
public void run() {
try {
// t=new Socket("localhost",8000);
InputStream in=t.getInputStream();
BufferedReader ber=new BufferedReader(new InputStreamReader(in));
String str=ber.readLine();
System.out.println("服务器:"+str);
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}//===========================================服务器=======================================================
package qq;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class Serverqi implements Runnable{
static ServerSocket b = null;
Socket s = null;
public static void main(String[] args) {

try {
b = new ServerSocket(8000);
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
Serverqi q=new Serverqi();
Thread th=new Thread(q);
th.start();


Ba b1=new Ba(b);
Thread th1=new Thread(b1);
th1.start();
}


public void run() {

try {
while(true){
s=b.accept();
InputStream in=s.getInputStream();
BufferedReader ber=new BufferedReader(new InputStreamReader(in));
String str=ber.readLine();
System.out.println("客户端:"+str);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}}class Ba implements Runnable{
Socket s = null;
ServerSocket b = null; 
public Ba(ServerSocket b){
this.b=b;
}
public void run() {
// while(true){
try {
s=b.accept();
Scanner sr=new Scanner(System.in);
String ss=sr.nextLine();
OutputStream oos;
oos = s.getOutputStream();
PrintStream ps=new PrintStream(oos);
ps.println(ss);
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
// }
}
}
为什么我在客户端上输入随便输入多少次服务器上都能接收到····服务器发给客户端去只能发成功一次这是为什么啊·········