用Java實現(xiàn)聊天程序

更新時間：2022年09月15日 14:54:18 作者：GYN1996

這篇文章主要為大家詳細介紹了用Java實現(xiàn)聊天程序，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下

利用Java編寫聊天程序，供大家參考，具體內容如下

首先計算機網(wǎng)絡有兩種傳輸層協(xié)議：TCP（面向連接）,UDP（面向無連接）。今天就介紹基于這兩種協(xié)議的聊天程序。

先查明自己電腦的主機名

右鍵我的電腦-->屬性

一、基于UDP的聊天程序

1.基于UDP的發(fā)送端

package cn.com;

/**
?* 基于UDP
?* 聊天發(fā)送端
?*/
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;

public class Send {

? ? public static void main(String[] args) throws IOException {
? ? ? ? @SuppressWarnings("resource")
? ? ? ? DatagramSocket ds = new DatagramSocket();
? ? ? ? Scanner sc = new Scanner(System.in);
? ? ? ? String line = null;
? ? ? ? while ((line = sc.nextLine()) != null) {
? ? ? ? ? ? byte[] buf = line.getBytes();
? ? ? ? ? ? int length = buf.length;
? ? ? ? ? ? InetAddress address = InetAddress.getByName("1-PC21");//主機名
? ? ? ? ? ? DatagramPacket dp = new DatagramPacket(buf, length, address, 10086); ? //10086為自己設置的端口號
? ? ? ? ? ? ds.send(dp);
? ? ? ? }
? ? ? ? sc.close();
? ? }

}

2.基于UDP的接收端

package cn.com;

/**
?* 基于UDP
?* 聊天接收端
?*/
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class Receive {

? ? public static void main(String[] args) throws IOException {
? ? ? ? @SuppressWarnings("resource")
? ? ? ? DatagramSocket ds = new DatagramSocket(10086);//端口號需一致

? ? ? ? while (true) {
? ? ? ? ? ? byte[] b = new byte[1024 * 1];
? ? ? ? ? ? int length = b.length;
? ? ? ? ? ? DatagramPacket dp = new DatagramPacket(b, length);
? ? ? ? ? ? ds.receive(dp);

? ? ? ? ? ? byte[] data = dp.getData();
? ? ? ? ? ? int length2 = dp.getLength();
? ? ? ? ? ? String hostAddress = dp.getAddress().getHostAddress();
? ? ? ? ? ? String s = new String(data, 0, length2);
? ? ? ? ? ? System.out.println(s + "來自" + hostAddress);
? ? ? ? }

? ? }

}

3.先運行接收端，在運行發(fā)送端

發(fā)送端發(fā)送“Hello World”，“My name is Tom”。

接收端收到信息

二、基于TCP的聊天程序

1.客戶端

package cn.com;
/**
?* 基于TCP
?* 聊天系統(tǒng)客戶端
?*/
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

public class Client {

? ? public static void main(String[] args) throws IOException {
? ? ? ? InetAddress address = InetAddress.getByName("1-PC21");//主機名
? ? ? ? int port = 10089;

? ? ? ? Scanner sc = new Scanner(System.in);
? ? ? ? String line = null;
? ? ? ? while ((line = sc.nextLine()) != null) {
? ? ? ? ? ? @SuppressWarnings("resource")
? ? ? ? ? ? Socket socket = new Socket(address, port); ? //socket要在循環(huán)體中定義
? ? ? ? ? ? OutputStream os = socket.getOutputStream();
? ? ? ? ? ? os.write(line.getBytes());

? ? ? ? ? ? // 客戶端接收服務端返回的消息(輸入流)
? ? ? ? ? ? InputStream is = socket.getInputStream();
? ? ? ? ? ? byte[] b = new byte[1024 * 1];
? ? ? ? ? ? int len = is.read(b);
? ? ? ? ? ? String s = new String(b, 0, len);
? ? ? ? ? ? System.out.println(s);
? ? ? ? }
? ? ? ? sc.close();

? ? }

}

2.服務端

package cn.com;

/**
?* 基于TCP
?* 聊天系統(tǒng)服務端
?*/
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 {
? ? ? ? @SuppressWarnings("resource")
? ? ? ? ServerSocket ss = new ServerSocket(10089);

? ? ? ? while (true) {
? ? ? ? ? ? Socket accept = ss.accept(); ? ?//循環(huán)中用到accept，所以要在循環(huán)中新建定義
? ? ? ? ? ? InputStream is = accept.getInputStream();
? ? ? ? ? ? byte[] b = new byte[1024 * 1];
? ? ? ? ? ? int len = is.read(b);
? ? ? ? ? ? String s = new String(b, 0, len);
? ? ? ? ? ? System.out.println("已接收客戶端內容-->" + s);

? ? ? ? ? ? // 給客戶端返回數(shù)據(jù)
? ? ? ? ? ? OutputStream os = accept.getOutputStream();
? ? ? ? ? ? String content = "客戶端接收成功";
? ? ? ? ? ? os.write(content.getBytes());

? ? ? ? ? ? os.close();
? ? ? ? ? ? is.close();
? ? ? ? ? ? accept.close();
? ? ? ? }

? ? }

}

3.還是先打開服務端，再打開客戶端，發(fā)送信息

客戶端發(fā)送：“今天星期四”，“天氣很好” 兩條信息。