Java/網絡編程

基於TCP的客戶端 源代碼

package org.wikibooks.java.socket;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class TalkClient {
	
    public static void main(String[] args) {
    	
        try {
        	
            Socket socket = new Socket("localhost", 4700);
            //向服务器的4700端口发出客户TCP请求
            
            BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));
            //由系统标准输入设备构造BufferedReader对象
            
            PrintWriter os = new PrintWriter(socket.getOutputStream());
            //由Socket对象得到输出流，并构造PrintWriter对象
            
            BufferedReader is = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //由Socket对象得到输入流，并构造相应的BufferedReader对象
            
            String readline = sin.readLine();
            //从系统标准输入读入一字符串
            
            while (!readline.equalsIgnoreCase("bye")) {
                //若从标准输入读入的字符串为 "bye"则停止循环
            	
                os.println(readline);
                //将从系统标准输入读入的字符串输出Server
                
                os.flush();
                //刷新输出流，使Server马上收到该字符串
                
                System.out.println("Client:" + readline);
                //在系统标准输出上打印读入的字符串
                
                System.out.println("Server:" + is.readLine());
                //从Server读入一字符串，并打印到标准输出上
                
                readline = sin.readLine();
                //从系统标准输入读入一字符串
            }
            //继续循环
            
            os.close();
            //关闭Socket输出流
            
            is.close();
            //关闭Socket输入流
            
            socket.close();
            //关闭Socket
            
        } catch(Exception e) {
        	e.printStackTrace();
            //程序运行出错，向控制台输出错误信息
        }
        
    }
    
}

基於TCP服務端 源代碼

package org.wikibooks.java.socket;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class TalkServer {

    public static void main(String[] args) {

        try {

            ServerSocket server = new ServerSocket(4700);
            //创建一个ServerSocket在端口4700监听客户TCP请求　　　　　　　　
            
            Socket socket = server.accept();
            //使用accept()阻塞等待客户请求，有客户请求到来则产生一个Socket对象，并继续执行
            
            String line;
            BufferedReader is = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //由Socket对象得到输入流，并构造相应的BufferedReader对象
            
            PrintWriter os = new PrintWriter(socket.getOutputStream());
            //由Socket对象得到输出流，并构造PrintWriter对象
            
            BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));
            //由系统标准输入设备构造BufferedReader对象
            
            System.out.println("Client:" + is.readLine());
            //在标准输出上打印从客户端读入的字符串
            
            line = sin.readLine();
            //从标准输入读入一字符串
            
            while (!line.equalsIgnoreCase("bye")) {
                //如果该字符串为 "bye"，则停止循环
            	
                os.println(line);
                //向客户端输出该字符串
                
                os.flush();
                //刷新输出流，使Client马上收到该字符串
                
                System.out.println("Server:" + line);
                //在系统标准输出上打印读入的字符串
                
                System.out.println("Client:" + is.readLine());
                //从Client读入一字符串，并打印到标准输出上
                
                line = sin.readLine();
                //从系统标准输入读入一字符串
                
            }
            //继续循环
            os.close();
            //关闭Socket输出流
            
            is.close();
            //关闭Socket输入流
            
            socket.close();
            //关闭Socket
            
            server.close();
            //关闭ServerSocket
            
        } catch(Exception e) {
            e.printStackTrace();
            //程序运行出错，向控制台输出错误信息
        }

    }

}