基于TCP/IP在同一局域网下的数据传输

1.TCP/IP网络编程

    在开发网络应用程序的时候，会遇到Socket这个概念。一个应用程序通过一个Socket来建立远程连接，而Socket内部通过TCP/IP协议把数据传输到网络。

    TCP/IP是传输控制协议和网络协议的简称，它定义设备如何连入因特网，以及数据如何在他们之间传输的标准。TCP/IP不是一个协议，而是一个协议族的统称，里面包括了IP协议、ICMP协议、TCP协议、以及http、ftp、pop3协议等，网络计算机都采用这套协议族进行互联。

2.数据传输

  使用Socket进行网络编程时，本质上就是进行俩个进程之间的网络通信。其中一个进程必须充当服务器端，它会主动去监听某个指定位置的端口，列一个必须充当客户端，它必须主动与连接服务器端的IP地址和指定端口，如果连接成功，服务器端与客户端就成功的建立了一个TCP协议，双方后续就可以随时发送和接收数据。

  对服务器端来说，它的Socket是指定的IP地址和指定的端口号。

  对客户端来说，它的Socket是它所在的计算机的IP地址和一个操作系统分配的随机端口号。

3.服务器端

Java标准库提供了ServerSocket来实现对指定IP的指定端口的监听。实现程序如下：

public class Server {
    public static void main(String[] args) throws IOException {

        ServerSocket ss = new ServerSocket(6666); // 监听指定端口
        System.out.println("server is running...");
        //使用while循环来让服务器一直保持接收的状态
        while (true) {
            Socket sock = ss.accept();
            
            // 使用Socket流进行网络通信
            // ...
            
            System.out.println("connected from " + sock.getRemoteSocketAddress());
        }
    }
}

 需要注意的是：

（1）使用try-catch块来抛出异常

（2）使用while循环来让服务器一直保持接收状态。

（3）一定要指定服务器端的监听端口。

4.客户端

      客户端通过如下代码来连接到服务器端，而且一定要指定服务器的端口，否则会无法正确的进行数据传输。

public class Client {
    public static void main(String[] args) throws IOException {
        // 连接指定服务器和端口
        Socket sock = new Socket("localhost", 6666); 
        
       // 使用Socket流进行网络通信
       // ...
        
        // 关闭
        sock.close();
        System.out.println("disconnected.");
    }
}

5.参考示例：（服务器·与客户端在同一局域网下的聊天）

服务器端：

public static void main(String[] args) {

		Scanner input = new Scanner(System.in);
		try (DatagramSocket socket = new DatagramSocket(8888)) {
			DatagramPacket sendPacket = new DatagramPacket(new byte[1024], 1024,
					new InetSocketAddress("192.168.254.177", 9999));
			DatagramPacket receivePacket = new DatagramPacket(new byte[1024], 1024);

			while (true) {

				socket.receive(receivePacket);
				String receiveContent = new String(receivePacket.getData(), receivePacket.getOffset(),
						receivePacket.getLength());
				if (receiveContent.equals("over")) {
					System.out.println("对方退出聊天......");
					break;
				}
				System.out.println("它说" + receiveContent);

				System.out.print("你说：");
				String sendContent = input.nextLine();
				sendPacket.setData(sendContent.getBytes());
				socket.send(sendPacket);
				if (sendContent.equals("over")) {
					System.out.println("你退出聊天...");
					return;
				}

			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

客户端：

public static void main(String[] args) {
		Scanner input = new Scanner(System.in);
		
		while(true) {
			
			
			try (Socket cilent = new Socket("192.168.254.159", 8888);
                
				 BufferedWriter writer = new BufferedWriter(new 
                     OutputStreamWriter(cilent.getOutputStream()));
				 BufferedReader reader = new BufferedReader(new 
                     InputStreamReader(cilent.getInputStream()))
				) {
				//获取控制台的输入
				String question = input.nextLine();
				if(question.equals("over")) {
					break;
				}

				// 发送消息至服务器
				writer.write(question);
				writer.flush();
				
				//暂时结束本次输出
				cilent.shutdownOutput();
				
				//获取来自服务器的回答
				String answer = reader.readLine();
				System.out.println("【客户端】来自服务器的回答" + answer);
				

			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		System.out.println("本次聊天结束！!");
	}