App下載

基于UDP協(xié)議開發(fā)Java聊天系統(tǒng) 附詳細代碼實例

若木曜子 2021-08-09 16:21:08 瀏覽數(shù) (2256)
反饋

UDP,即用戶數(shù)據(jù)報協(xié)議(User Datagram Protocol),為用戶提供了無需連接就可以發(fā)送封裝的IP數(shù)據(jù)包的方法。下面,將基于UDP協(xié)議,使用Java相關技術實現(xiàn)簡單的聊天系統(tǒng)。

這是一篇我的學習記錄,這學期加入了JAVA 的學習,所以自己把教科書看了一下,然后嘗試地寫了一個UDP協(xié)議的聊天系統(tǒng),并且含GUI。因為對JAVA和網絡的了解還不夠深,所以代碼還有許多地方需要完善。

代碼展示

下面展示一些 Client類

/**-------------------
 * 發(fā)送端
 **---------------------*/
class Client extends Thread{
    private static String content;       //發(fā)送內容
    private static int port;             //發(fā)送端口
    private static int target;           //目標端口
    private static byte[] addr;          //目標ip地址
        /**-------------------
         *構造函數(shù)
         **---------------------*/
    public Client(String content,int port,int target,byte[] addr){
        this.content=content;
        this.port=port;
        this.target=target;
        this.addr=addr;
    }
        /**-------------------
         *發(fā)送端函數(shù)
         **---------------------*/
    public void run(){
        DatagramSocket client= null;
        try {
            //定義發(fā)送端端口為 port 的DatagramSocket對象
            client = new DatagramSocket(port);
        } catch (SocketException e) {
            e.printStackTrace();
        }
        String str=content;

        DatagramPacket packet= null;
        try {
            //定義DatagramPacket對象,用于封裝發(fā)送的數(shù)據(jù)以及目標地址 target
            packet = new DatagramPacket(str.getBytes(),str.getBytes().length,
                    InetAddress.getByAddress(addr),target);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
        try {
            //發(fā)送數(shù)據(jù)
            client.send(packet);
        } catch (IOException e) {
            e.printStackTrace();
        }
        //關閉釋放資源
        client.close();
    }
}

    /**-------------------
     *接收端
     **---------------------*/
class Server extends Thread{
    private static JTextArea jt;           //對話框
    private static int target;             //目標端口
        /*-------------------
              構造函數(shù)
        ---------------------*/
    public  Server(JTextArea jt,int target){
        this.jt=jt;
        this.target=target;
    }

下面展示一些 Server類

    /*-------------------
    接收端
    ---------------------*/
class Server extends Thread{
    private static JTextArea jt;           //對話框
    private static int target;             //目標端口
        /*-------------------
              構造函數(shù)
        ---------------------*/
    public  Server(JTextArea jt,int target){
        this.jt=jt;
        this.target=target;
    }

        /*-------------------
              接收端函數(shù)
        ---------------------*/
    public void run(){
        String str;
        DatagramSocket server= null;

        try {
            //定義一個端口號為 target 的接收端DatagramSocket對象
            server = new DatagramSocket(target);
        } catch (SocketException e) {
            e.printStackTrace();
        }
        byte[] buf=new byte[1024];
        //定義一個DatagramPacket數(shù)據(jù)報對象,用于封裝接收數(shù)據(jù)
        DatagramPacket packet=new DatagramPacket(buf, buf.length);

        while (true){
            try {
                //等待接收數(shù)據(jù),在數(shù)據(jù)沒有被接收到之前會被堵塞
                server.receive(packet);
            } catch (IOException e) {
                e.printStackTrace();
            }
            //使用DatagramPacket的方法獲得接收到的信息,并轉為字符串類型
            str=new String(packet.getData(),
                    0,packet.getLength());
            //將接收到的信息打印到對話框
            jt.append("接收到:"+str+"
");
        }
    }
}

下面展示一些 Main類

public class Main {
    public static int port;
    public static int target;
    public static byte[] addr;
    public static void Login(){
        System.out.print("請輸入端口號:");
        Scanner ScPort=new Scanner(System.in);
        port=ScPort.nextInt();

        System.out.print("請輸入目標端口號1:");
        Scanner ScTarget=new Scanner(System.in);
        target=ScTarget.nextInt();

        System.out.print("請輸入目標端口號2:");
        Scanner ScTarget2=new Scanner(System.in);
        int target2=ScTarget2.nextInt();

        System.out.print("請輸入目標IP地址:");
        Scanner Scaddr=new Scanner(System.in);
        /*---------------------
        將目標IP存儲到數(shù)組中
        -----------------------*/
        String ip=Scaddr.nextLine();
        /*---------------------
        public String[] split(String regex):
             根據(jù)給定正則表達式的匹配拆分此字符串
         ----------------------*/
        String[] ii=ip.split("\.");
        /*---------------------
        我們現(xiàn)在使用的IPv4是用一個32位的二進制數(shù)來存儲的,為了方便記憶,
        會將其分成4個8位的二進制數(shù)(4個一字節(jié)的二進制數(shù)),每8位之間用圓點隔開。
        而每8位二進制數(shù)可以轉換為一個0~255的十進制數(shù),例如103.42.176.244,
        這種寫法被稱為點數(shù)表示法
         ----------------------*/
        byte[] addr=new byte[4];
        for(int i=0;i<4;i++){
            addr[i]=(byte)(Integer.parseInt(ii[i]));
        }

        System.out.println("窗口啟動中....");
        new Thread(new Server(CreateAndShowGUI(port,target,addr),target2),"接收服務").start();
    }
    /*-------------------
    GUI界面
    ---------------------*/
    public static JTextArea CreateAndShowGUI(int port,int target,byte[] addr){
        /*---------------------
        創(chuàng)建界面
         ----------------------*/
        JFrame jf=new JFrame("聊天界面");
        jf.setLocation(400,200);
        jf.setSize(400,300);
        /*---------------------
        設置布局
         ----------------------*/
        jf.setLayout(new BorderLayout());
        jf.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        /*---------------------
        創(chuàng)建聊天窗口
         ----------------------*/
        JTextArea jt=new JTextArea(14,34);
        JScrollPane scrollPane=new JScrollPane(jt);
        jt.setEditable(false);
        /*---------------------
        創(chuàng)建發(fā)送窗口
         ----------------------*/
        JTextField jte=new JTextField(20);

        JButton jb=new JButton("發(fā)送");
        jb.addActionListener(e->{
            String content=jte.getText();
            /*---------------------
            為發(fā)送按鈕創(chuàng)建動作
             ----------------------*/
            if (content!=null&&!content.trim().equals("")){
                /*-------------------
                判斷信息是否為空
                若為空,在在對話框提示 你輸入的內容為空
                反之發(fā)送
                 --------------------*/
                jt.append("輸入信息為:"+content+"
");
                /*--------------
                將發(fā)送框信息發(fā)送到目標對話框
                傳入Client方法的參數(shù)分別為
                “發(fā)送內容,發(fā)送端口,目標端口,目標IP地址”
                ----------------*/
                try {
                    new Thread(new Client(content,port,target,addr),"發(fā)送服務").start();
                } catch (Exception exception) {
                    exception.printStackTrace();
                }
            }else{
                jt.append("你輸入的內容為空");
            }
            jte.setText("");      //信息發(fā)送后,將發(fā)送框重置
        });

        JPanel jp=new JPanel();
        JLabel jl=new JLabel("聊天信息");

        jp.add(jl);
        jp.add(jte);
        jp.add(jb);
        jf.add(jt,BorderLayout.PAGE_START);
        jf.add(jp,BorderLayout.PAGE_END);
        //顯示GUI界面
        jf.setVisible(true);
        return jt;
    }

    public static void main(String[] args) throws Exception{
        Login();
    }
}

運行截圖

登錄界面(一)

2021420114859806

登錄界面(二)

2021420114914866

聊天界面(一)

2021420114926261

聊天界面(二)

2021420114943445

總結

UDP協(xié)議是無連接通信,即在數(shù)據(jù)傳輸時,數(shù)據(jù)的發(fā)送端和接收端不建立邏輯鏈接。也就是,當一臺計算機想另外一臺計算機發(fā)送消息時,發(fā)送端不會確定接收端是否存在,就會發(fā)送數(shù)據(jù)。同樣,接收端在接收到消息后也不會反饋發(fā)送端是否受到數(shù)據(jù)。但UDP消耗資源小、通訊效率高、延遲小。所以,雖然UDP是一個不可靠的協(xié)議,但它是分發(fā)信息的一個理想協(xié)議。

以上就是關于Java基于UDP協(xié)議實現(xiàn)聊天系統(tǒng)完整代碼的全部內容,希望對大家的學習有所幫助,也希望大家多多支持W3Cschool。

0 人點贊