銆€銆€import java.io.*; 銆€銆€import java.net.*; 銆€銆€public class MyServer { 銆€銆€public static void main(String[] args) throws IOException{ 銆€銆€ServerSocket server=new ServerSocket(5678); 銆€銆€while(true){ 銆€銆€銆€Socket client=server.accept(); 銆€銆€銆€BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream())); 銆€銆€銆€PrintWriter out=new PrintWriter(client.getOutputStream()); 銆€銆€銆€while(true){ 銆€銆€銆€銆€String str=in.readLine(); 銆€銆€銆€銆€System.out.println(str); 銆€銆€銆€銆€out.println("has receive...."); 銆€銆€銆€銆€out.flush(); 銆€銆€銆€銆€if(str.equals("end")) 銆€銆€銆€銆€銆€break; 銆€銆€銆€} 銆€銆€銆€client.close(); 銆€銆€} 銆€銆€} 銆€銆€} |
銆€銆€import java.net.*; 銆€銆€import java.io.*; 銆€銆€public class MultiUser extends Thread{ 銆€銆€private Socket client; 銆€銆€public MultiUser(Socket c){ 銆€銆€this.client=c; 銆€銆€} 銆€銆€public void run(){ 銆€銆€try{ 銆€銆€銆€BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream())); 銆€銆€銆€PrintWriter out=new PrintWriter(client.getOutputStream()); 銆€銆€銆€//Mutil User but can parallel 銆€銆€銆€while(true){ 銆€銆€銆€銆€String str=in.readLine(); 銆€銆€銆€銆€System.out.println(str); 銆€銆€銆€銆€out.println("has receive...."); 銆€銆€銆€銆€out.flush(); 銆€銆€銆€銆€if(str.equals("end")) 銆€銆€銆€銆€銆€break; 銆€銆€銆€} 銆€銆€銆€client.close(); 銆€銆€}catch(IOException ex){ 銆€銆€}finally{ 銆€銆€} 銆€銆€} 銆€銆€public static void main(String[] args)throws IOException{ 銆€銆€ServerSocket server=new ServerSocket(5678); 銆€銆€while(true){ 銆€銆€//transfer location change Single User or Multi User 銆€銆€MultiUser mu=new MultiUser(server.accept()); 銆€銆€mu.start(); 銆€銆€} 銆€銆€} 銆€銆€} |
BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream())); PrintWriter out=new PrintWriter(client.getOutputStream()); |
DataInputStream isFromClient = new DataInputStream(client.getInputStream()); DataOutputStream osToClient = new DataOutputStream(client.getOutputStream()); |