基於TCP協議的Socket編程

1.單向通信實現

傳輸示意圖

客戶端程序

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class clinet {
    
    public static void main(String[] args) throws IOException {
        //創建Socket對象
        Socket clinet = new Socket("127.0.0.1",9999);
        //獲取輸出流
        DataOutputStream dos = new DataOutputStream(clinet.getOutputStream());
        dos.writeUTF("hello word!");
        //獲取輸入流
        DataInputStream dis = new DataInputStream(clinet.getInputStream());
        System.out.println(dis.readUTF());
        //關閉流
        if(dis != null) {
            dis.close();
        }
        if(dos != null) {
            dos.close();
        }
        if(clinet != null) {
            clinet.close();
        }
    }
}

服務器程序

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

    public static void main(String[] args) throws IOException {
        System.out.println("-----------服務器端已啟動----------");
        //創建ServerSocket對象
        ServerSocket server = new ServerSocket(9999);
        //監聽是否有客戶端請求連接
        Socket clinet = server.accept();
        //獲取輸入流
        DataInputStream dis = new DataInputStream(clinet.getInputStream());
        System.out.println(dis.readUTF());
        //獲取輸出流
        DataOutputStream dos = new DataOutputStream(clinet.getOutputStream());
        dos.writeUTF("收到了");
        //關閉流，關閉Socket
        if(dos != null) {
            dos.close();
        }
        if(dis != null) {
            dis.close();
        }
        clinet.close();
    }

}

先啟動服務器，再啟動客戶端

服務器：

客戶端：

 

 

 

 

 

 

2.模擬用戶登陸

服務器

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.plaf.synth.SynthSeparatorUI;

import org.omg.PortableInterceptor.DISCARDING;

public class Server2 {

    public static void main(String[] args) throws IOException, ClassNotFoundException {
        System.out.println("------服務器端已啟動----------");
        //創建ServerSocket對象
        ServerSocket server = new ServerSocket(10000);
        Socket socket = server.accept();
        //獲取輸入流（對象流）
        ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
        //對用戶名和密碼進行驗證
        User user = (User)ois.readObject();
        System.out.println(socket.getInetAddress().getHostAddress()+"請求登陸：用戶名"+user.getUsername()+"\t密碼："+user.getPassword());
        String str = "";
        if("chb".equals(user.getUsername())&&"123456".equals(user.getPassword())) {
            str = "登陸成功";
        }else {
            str = "登陸失敗";
        }
        //獲取輸出流（數據流）
        DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
        dos.writeUTF(str);
        //關閉流
        if(dos != null) {
            dos.close();
        }
        if(ois != null) {
            ois.close();
        }
        socket.close();
    }

}

客戶端

import java.io.DataInputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.Scanner;

public class Clint2 {
    
    public static void main(String[] args) throws IOException {
        //(1)創建Socket對象，用於連接服務器
        Socket clint = new Socket("localhost", 10000);
        //(2)獲取輸出流（對象流）
        ObjectOutputStream oos = new ObjectOutputStream(clint.getOutputStream());
        //(3)創建User對象
        User user = getUser();
        //(4)User對象發生到服務器
        oos.writeObject(user);
        //(5)獲取輸入流（數據流）
        DataInputStream dis = new DataInputStream(clint.getInputStream());
        System.out.println(dis.readUTF());
        if(dis != null) {
            dis.close();
        }
        if(oos != null) {
            oos.close();
        }
        clint.close();
    }
    public static User getUser() {
        Scanner input = new Scanner(System.in);
        System.out.println("請輸入用戶名：");
        String username = input.next();
        System.out.println("請輸入密碼：");
        String password = input.next();
        //封裝成User對象
        return new User(username, password);
    }
}

 

3.UDP 通信_DatagramSocket 實現_客戶咨詢

1) 不需要利用 IO 流實現數據的傳輸

2) 每個數據發送單元被統一封裝成數據包的方式，發送方將數據包發送到網絡中，數據包在網絡中去尋找他的目的地。

3) DatagramSocket：用於發送或接收數據包

4) DatagramPacket：數據包

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class Test1 {
    //接收方
            /** 一收，
             * 一發
             * @throws IOException 
             */
    public static void main(String[] args) throws IOException {
        System.out.println("客服人員");
        DatagramSocket ds=new DatagramSocket(9999);
        //准 備接收數據
        byte [] buf=new byte[1024];
        //准 備數據報接收
        DatagramPacket dp=new DatagramPacket(buf, buf.length);
        
        //接收
        ds.receive(dp);
        
        //查看接收到的數據
        String str=new String(dp.getData(),0,dp.getLength());
        System.out.println("客戶說:"+str);
        
        
        /**回復數據*/
        byte [] buf2="welcome to beijing".getBytes();//發生的內容 長度  地址 端口號
        DatagramPacket dp2=new DatagramPacket(buf2, buf2.length, dp.getAddress(), dp.getPort());
        ds.send(dp2);
        //關閉
        ds.close();
        
            
    }
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.util.Scanner;

public class Test2 {
    //
            /** 一收，
             * 一發
             * @throws IOException 
             */
    public static void main(String[] args) throws IOException {
        Scanner input=new Scanner(System.in);
        System.out.println("客服人員");
        DatagramSocket ds=new DatagramSocket(9999);
        while(true){
            //准 備接收數據
            byte [] buf=new byte[1024];
            //准 備數據報接收
            DatagramPacket dp=new DatagramPacket(buf, buf.length);
            
            //接收
            ds.receive(dp);
            
            //查看接收到的數據
            String str=new String(dp.getData(),0,dp.getLength());
            System.out.println("客戶說:"+str);
            
            String s=input.next();
            /**回復數據*/
            byte [] buf2=s.getBytes();
            DatagramPacket dp2=new DatagramPacket(buf2, buf2.length, dp.getAddress(), dp.getPort());
            ds.send(dp2);
            if("bye".equals(s)){
                break;
            }
        }
        //關閉
            
        ds.close();
        
            
    }
}