java网络编程基础

//首先，从服务器端开始。在服务器端首先要做的是创建一个ServerSocket类型的对象
ServerSocket ss = new ServerSocket(9000); //创建ServerSockert对象ss，并把ss绑定到9000端口，IP地址是电脑当前地址
										  //查看地址命令：ipconfig
//创建完ServerSocket对象ss之后，下一步就该调用ServerSocket类的accept方法,该方法签名如下:
public Socket accept() throws IOException
//这个方法返回一个Socket对象，这个方法的目的在于等待连接。如果没有一个客户端连接过来的话，则这个accept方法会一直不会返回。
//返回的Socket对象，我们可以比喻为一部电话机，很显然，通过一个电话号码和一个分机号，可以唯一的找到一台电话机。


//那么客户端怎么连接到服务器上呢？可以在客户端创建一个Socket对象连接服务器，如下：
Socket s = new Socket("150.236.56.101", 9000); 
//在创建Socket的时候，给出服务器IP地址和端口号，这样就创建了一个Socket对象并连接服务器，
//此时客户端和服务器都有一个Socket对象，并保持连通，这就意味着两点已经连接了，可以进行数据交互了。

/**
* 服务端
*/

//TcpServer.java
public class TcpServer {

	public static void main(String[] args) throws IOException {
		ServerSocket ss = new ServerSocket(9000);
		while (true) {
			Socket s = ss.accept();
			Thread t = new IoThread(s); //多个client可同时访问server
			t.start();
		}
	}
}

//IoThread.java
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

public class IoThread extends Thread {
	private Socket s;
	
	public IoThread() {
		super();
	}
	public IoThread(Socket s) {
		this.s = s;
	}

	@Override
	public void run() {
		try {
			BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
			String line = br.readLine();
			
			PrintWriter pw = new PrintWriter(new OutputStreamWriter(s.getOutputStream()));
			pw.write("from server: " + line);
			pw.flush();
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			try {
				s.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}


/**
* 客户端
*/

//TcpClient.java
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class TcpClient {
	public static void main(String[] args) throws UnknownHostException, IOException {
		Socket s = new Socket("127.0.0.1", 9000);
		
		PrintWriter pw = new PrintWriter(s.getOutputStream());
		System.out.print("请输入：");
		String line = new BufferedReader(new InputStreamReader(System.in)).readLine();
		pw.println(line);
		pw.flush();
		
		BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
		String line2 = br.readLine();
		System.out.println(line2);
		
		s.close();
	}
}


//运行结果：
请输入：你好啊
from server: 你好啊

//客户端要发送数据，得先创建一个DatagramSocket，代码如下：
DatagramSocket socket = new DatagramSocket();
//上面的代码没有指定客户端的端口，这样的话，系统会自动为客户端分配一个随机的端口号。
//为什么服务器端的端口号不能让系统随机分配呢？因为服务器端的地址和端口号是必须要向外界公布，供客户端去访问的，
//如果一个网站向外公布：网站地址：xxxxxxxx，网站端口：随机，这样的话让用户究竟怎么访问你的网站？因此，服务器端必须手动指定端口号。

//客户端创建了一个DatagramSocket之后，就可以准备发送的数据了。
byte[] data = str.getBytes(); //data数组中保存的就是需要发送的数据内容

//然后，应当把data封装到一个DatagramPacket中，代码如下：
DatagramPacket packet = new DatagramPacket(
	data, 
	0, 
	data.length,
	new InetSocketAddress("150.236.56.101", 9000));

//当一切准备就绪之后，客户端就可以调用socket的send方法，发送packet对象。代码如下：
socket.send(packet); //这样，数据就从客户端发送到了服务器。



//接下来，就是服务器如何接收了。
//先要创建一个DatagramSocket类型的对象，代码如下：
DatagramSocket socket = new DatagramSocket(9000); 

//在接收数据的时候，同样需要一个DatagramPacket。这个DatagramPacket对象就好比是传真机上的纸，在收传真的时候，
//需要传真机里放上白纸，然后传真机根据发过来的内容，在白纸上打印出来。当传真接受完毕之后，这张纸上就记录了接受到的内容。
//我们首先要创建一个空数组，这个数组就好像是白纸。
byte[] buf = new byte[100];

//然后，根据这张白纸，创建一个DatagramPacket：
DatagramPacket paper = new DatagramPacket(buf, 0, buf.length);

//创建了paper对象之后，就可以调用socket对象的receive方法接受数据。
socket.receive(paper);

//接受到数据之后，可以通过paper对象的下面几个方法获得相关信息：

paper.getSocketAddress() //获得发送者的地址。可以理解为获得发送传真的对方的号码，等一会儿回传真的时候，就可以用这个地址。
paper.getLength() //获得发送的数据的长度。
//当两边完成通信之后，应当关闭socket。

/**
* 服务器端
*/

import java.io.*;
import java.net.*;
public class UCPServer {
	public static void main(String[] args) throws Exception {
		//创建socket
		DatagramSocket socket = new DatagramSocket(9000);
		//收数据
		byte[] buf = new byte[100];
		DatagramPacket paper = new DatagramPacket(buf, 0, buf.length);
		socket.receive(paper);
		String str = new String(buf, 0, paper.getLength());
		System.out.println(str);
		
		//发数据
		byte[] data = "hello client".getByes();
		DatagramPacket packet = new DatagramPacket(data, 0, data.length, paper.getSocketAddress());
		socket.send(packet);
		
		//关闭socket
		socket.close();
	}
}


/**
* 客户端
*/

import java.io.*;
import java.net.*;
public class UCPClient {
	public static void main(String[] args) throws Exception {
		DatagramSocket socket = new DatagramSocket();
		String str = "hello server";
		byte[] data = str.getsBytes();
		DatagramPacket packet = new DatagramPacket(data, 0, data.length, new InetSocketAddress("150.236.56.101", 9000));
		socket.send(packet);
		
		byte[] buf = new byte[100];
		DatagramPacket paper = new DatagramPacket(buf, 0, buf.length);
		socket.receive(paper);
		String smg = new String(buf, 0, paper.getLength());
		System.out.println(smg);
		
		socket.close();
	}
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;

public class URLTest {
	public static void main(String[] args) throws MalformedURLException, IOException {
		URLConnection conn = new URL("http://www.sina.com.cn").openConnection();
		InputStream is = conn.getInputStream();
		
		BufferedReader br = new BufferedReader(new InputStreamReader(is));
		String line = null;
		while ((line=br.readLine()) != null) {
			System.out.println(line);
		}
		br.close();
	}
}