자바 네트워크 프로 그래 밍 -> 상용 모듈

import java.io.*;
import java.util.*;
import java.net.*;

/*
	                    ，   

		1、  ServerSocket，      
		2、accept()              。
		3、  Socket getInputStream()             。
			   ，  
			  Socket getOutputStream()             。
			      
		4、  socket
*/

//   
class MyServer 
{
	public static void main(String[] args) throws Exception
	{
		ServerSocket srv = new ServerSocket(8189);

		Socket so = srv.accept();
		InetAddress inet = so.getLocalAddress();

		String ip = inet.getHostAddress();

		System.out.println(ip + "..connected");
		//   
		InputStream inStream = so.getInputStream();
		//   
		OutputStream outStream = so.getOutputStream();

		Scanner in = new Scanner(inStream);
		PrintWriter out = new PrintWriter(outStream, true); //   

		//               ，      ，  BYE  
		boolean done = false;

		while (!done && in.hasNext())
		{
			String str = in.nextLine();
			out.println(str.toUpperCase());
			if (str.equals("BYE"))
			{
				done = true;
			}
		}

		so.close();
	}
}


//   

/*
	1、     
	2、           
	3、     
*/
class MyClient
{
	public static void main(String[] args) throws Exception
	{
		Socket so = new Socket("localhost",8190);
		
		//   
		InputStream inStream = so.getInputStream();
		//   
		OutputStream outStream = so.getOutputStream();

		Scanner in = new Scanner(inStream);
		PrintWriter out = new PrintWriter(outStream, true); //   

		//     
		Scanner keyIn = new Scanner(System.in);

		while (keyIn.hasNext())
		{
			String str = keyIn.nextLine();
			out.println(str);
			System.out.println(in.nextLine());
		}
		so.close();
	}
}

 、     ：     
import java.io.*;
import java.net.*;
import java.util.Scanner;

/*
	     ，          
	
	  ：              ，          
*/

//    
class ServerThread implements Runnable
{
	private Socket so;
	ServerThread(Socket s) {
		this.so = s;
	}

	public void run() {
		try
		{
			InetAddress inet = so.getLocalAddress();
			String ip = inet.getHostAddress();

			System.out.println(ip + "..connected");
			//   
			InputStream inStream = so.getInputStream();
			//   
			OutputStream outStream = so.getOutputStream();

			Scanner in = new Scanner(inStream);
			PrintWriter out = new PrintWriter(outStream, true); //   

			//               ，      ，  BYE  
			boolean done = false;

			while (!done && in.hasNext())
			{
				String str = in.nextLine();
				out.println(str.toUpperCase());
				if (str.equals("BYE"))
				{
					done = true;
				}
			}
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
		finally
		{
			try
			{
				so.close();
			}
			catch (IOException ie)
			{
				ie.printStackTrace();
			}
		}
		
	}
}

class MySuperServer
{
	public static void main(String[] args) throws Exception
	{	
		ServerSocket s = new ServerSocket(8190);
		while(true)
		{
			Socket so = s.accept();

			Runnable r = new ServerThread(so);
			new Thread(r).start();
		}
	}
}

import java.io.*;
import java.net.*;
import static java.lang.Math.*;

/*
	       ，   

	1、  ServerSocket  
*/

//       
class PicThread implements Runnable
{	
	private Socket so;
	PicThread(Socket s) {
		this.so = s;
	}

	public void run() {
		try
		{
			//         IP  
			InetAddress inet = so.getInetAddress();
			String ip = inet.getHostAddress();
			System.out.println(ip + "..connected...");
			
			//     
			InputStream in = so.getInputStream();

			OutputStream out = so.getOutputStream();

		
			File picFile = new File(ip + "(" + (int)(random()*100) + ").jpg");
			
			FileOutputStream fos = new FileOutputStream(picFile);

			//    
			byte[] buf = new byte[1024];
			int len = 0;
			while ((len = in.read(buf)) != -1)
			{
				fos.write(buf, 0, len);
			}
			
			//            
			out.write("    ".getBytes());
			so.close();
			fos.close();

		}
		catch (Exception e)
		{
			new RuntimeException("      ！");
		}
		
		
	}
}

//   
class UploadPicServer
{
	public static void main(String[] args) throws Exception
	{
		ServerSocket s = new ServerSocket(8999);

		while (true)
		{
			Socket so = s.accept();
			Runnable r = new PicThread(so);
			new Thread(r).start();
		}
	}
}

/*
	       
*/
class UploadPicClient
{
	public static void main(String[] args) throws Exception
	{
		Socket so = new Socket("127.0.0.1",8999);

		//   
		InputStream inStream = so.getInputStream();
		//   
		OutputStream outStream = so.getOutputStream();

		//     
		File picFile = new File(args[0]);

		FileInputStream fileIn = new FileInputStream(picFile);

		byte[] bufout = new byte[1024];
		int len = 0;
		while ((len = fileIn.read(bufout)) != -1)
		{
			outStream.write(bufout, 0, len);
		}
		so.shutdownOutput();

		//          
		byte[] bufIn = new byte[1024];
		int num = inStream.read(bufIn);
		System.out.println(new String(bufIn,0,num));

		so.close();
		inStream.close();
		outStream.close();
		fileIn.close();
	}
}

  ：
import java.net.*;
import java.io.*;

/*
	URL  URLConnection
*/
class HttpTest 
{
	public static void main(String[] args) throws Exception
	{
		URL url = new URL("http://127.0.0.1/index.html");

		URLConnection u = url.openConnection();

		InputStream webFile = u.getInputStream();

		byte[] buf = new byte[1024];
		int len = 0;
		while ((len = webFile.read(buf)) != -1)
		{
			System.out.println(new String(buf, 0, len));
		}
		System.out.println(len);
		webFile.close();
	}
}