【Java網絡編程】基於 UDP 的聊天通信

使用 udp 協議，寫一個基於命令行的聊天軟件；客戶端跟服務端分別在命令行啟動之后，客戶端和服務器端可以互相發送數據。

代碼實現如下：

一、創建線程 sendThread 和 receiveThread

package com.fhcq.chat;

//雙工的聊天程序
//可以發送數據，同時也可以等待接收數據
//需要使用多線程來實現

public class QICQDemo {

    public static void main(String[] args) {
        // TODO Auto-generated method stub

        Send send = new Send();
        Receive receive = new Receive();

        Thread sendThread = new Thread(send);
        Thread receiveThread = new Thread(receive);

        sendThread.start();
        receiveThread.start();
    }
}

 

二、利用線程 sendThread 實現信息的發送

package com.fhcq.chat;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Scanner;

public class Send implements Runnable {

    @Override
    public void run() {
        // TODO Auto-generated method stub

        try {
            DatagramSocket datagramSocket = new DatagramSocket();
            InetAddress inetAddress = InetAddress.getByName("congkick");
            Scanner scanner = new Scanner(System.in);
            while(true){
                // 阻塞
                String nextLine = scanner.nextLine();
              byte[] bytes = nextLine.getBytes();
              DatagramPacket datagramPacket = new DatagramPacket
                     (bytes,bytes.length,inetAddress,10019);
                datagramSocket.send(datagramPacket);
                if (nextLine.equals("886")) {
                    break;
                }
            }
        } catch (SocketException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

 

三、利用線程 receiveThread 實現信息的接收

package com.fhcq.chat;

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

public class Receive implements Runnable {

    @Override
    public void run() {
        // TODO Auto-generated method stub

        // 新建datagramSocket
        try {
            DatagramSocket datagramSocket = new DatagramSocket(10010);
            byte[] buf = new byte[1024];
            // 阻塞式方法
            DatagramPacket datagramPacket = new DatagramPacket(buf, 1024);
            while(true){
                datagramSocket.receive(datagramPacket);
                byte[] data = datagramPacket.getData();
                int length = datagramPacket.getLength();
                String string = new String(data,0,length);
                System.out.println(string);
                if (string.equals("886")) {
                    break;
                }
            }
        } catch (SocketException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}