//客户端
import java.io.*;
import java.net.*;
public class Client { public static void Client1() throws IOException{
int port=5555;
Socket s=new Socket("127.0.0.1",port);
DataInputStream dis=new DataInputStream(s.getInputStream());
DataOutputStream dos=new DataOutputStream(s.getOutputStream());
BufferedReader bf=new BufferedReader(new InputStreamReader(System.in));
String s1=null;
while(true){
s1=dis.readUTF();
if(s1.equals("exit"))
break;
System.out.println("send"+s1);
s1=bf.readLine();
if(s1.equals("exit"))
break;
System.out.println("send"+s1);
dos.writeUTF(s1);
dos.flush();
}
}
public static void main(String[] args) throws IOException{
Client1();
}
}
//服务器端public class Server {
public static void Server() throws IOException{
int port=5555;
ServerSocket ss=new ServerSocket(port);
Socket s=ss.accept();
DataInputStream dis=new DataInputStream(s.getInputStream());
DataOutputStream dos=new DataOutputStream(s.getOutputStream());
BufferedReader bf=new BufferedReader(new InputStreamReader(System.in));
String s1=null;
while(true){
s1=dis.readUTF();
if(s1.equals("exit"))
break;
System.out.println("send"+s1);
s1=bf.readLine();
if(s1.equals("exit"))
break;
System.out.println("send"+s1);
dos.writeUTF(s1);
dos.flush();
}
dis.close();
bf.close();
dos.close();
s.close();
} /**
* @param args
* @throws IOException
*/
public static void main(String[] args) throws IOException {
// TODO Auto-generated method stub
Server();
}
}
import java.io.*;
import java.net.*;
public class Client { public static void Client1() throws IOException{
int port=5555;
Socket s=new Socket("127.0.0.1",port);
DataInputStream dis=new DataInputStream(s.getInputStream());
DataOutputStream dos=new DataOutputStream(s.getOutputStream());
BufferedReader bf=new BufferedReader(new InputStreamReader(System.in));
String s1=null;
while(true){
s1=dis.readUTF();
if(s1.equals("exit"))
break;
System.out.println("send"+s1);
s1=bf.readLine();
if(s1.equals("exit"))
break;
System.out.println("send"+s1);
dos.writeUTF(s1);
dos.flush();
}
}
public static void main(String[] args) throws IOException{
Client1();
}
}
//服务器端public class Server {
public static void Server() throws IOException{
int port=5555;
ServerSocket ss=new ServerSocket(port);
Socket s=ss.accept();
DataInputStream dis=new DataInputStream(s.getInputStream());
DataOutputStream dos=new DataOutputStream(s.getOutputStream());
BufferedReader bf=new BufferedReader(new InputStreamReader(System.in));
String s1=null;
while(true){
s1=dis.readUTF();
if(s1.equals("exit"))
break;
System.out.println("send"+s1);
s1=bf.readLine();
if(s1.equals("exit"))
break;
System.out.println("send"+s1);
dos.writeUTF(s1);
dos.flush();
}
dis.close();
bf.close();
dos.close();
s.close();
} /**
* @param args
* @throws IOException
*/
public static void main(String[] args) throws IOException {
// TODO Auto-generated method stub
Server();
}
}
客户端、服务器都没有发送任何信息 就都开始从流中读入,应该会阻塞的。