Java網(wǎng)絡(luò)編程--->實(shí)現(xiàn)一個一對一的聊天系統(tǒng)

• 簡紹
• 主類
• 發(fā)送
• 接收
• 效果

簡紹

• 發(fā)送和接受分別對應(yīng)一個線程，每一線程都要可以發(fā)信息和接受信息

主類

import java.net.DatagramSocket; import java.net.SocketException; import java.util.Scanner;public class MainTest {public static void main(String[] args) {Scanner input = new Scanner(System.in);System.out.print("請輸入聊天服務(wù)當(dāng)前啟動的端口:");int serverPort = input.nextInt();System.out.print("請輸入聊天服務(wù)發(fā)送信息對象的端口:");int targetPort = input.nextInt();System.out.println("聊天系統(tǒng)初始化完畢!");try {//創(chuàng)建聊天對象的收發(fā)平臺對象DatagramSocket socket = new DatagramSocket(serverPort);//分別啟動倆個線程對象new Thread(new checkSend(socket, targetPort), "發(fā)送服務(wù)").start();new Thread(new checkRecever(socket), "接收服務(wù)").start();} catch (SocketException e) {e.printStackTrace();}} }

發(fā)送

import java.io.IOException; import java.net.*; import java.util.Scanner;//實(shí)現(xiàn)Runnable接口 public class checkSend implements Runnable {private DatagramSocket socket;private int targetPort;public checkSend(DatagramSocket socket, int targetPort) {this.socket = socket;this.targetPort = targetPort;}@Overridepublic void run() {try {//輸入要傳送的信息Scanner input = new Scanner(System.in);while (true) {String data = input.nextLine();//轉(zhuǎn)換輸入信息的數(shù)據(jù)類型byte[] bytes = data.getBytes();//對數(shù)據(jù)進(jìn)行包裝DatagramPacket packet = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("127.0.0.1"), targetPort);//發(fā)送信息socket.send(packet);}} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}} }

接收

import java.net.DatagramPacket; import java.net.DatagramSocket;public class checkRecever implements Runnable {private DatagramSocket socket;public checkRecever(DatagramSocket socket){this.socket = socket;}@Overridepublic void run() {try{byte [] bytes = new byte[1024];DatagramPacket packet = new DatagramPacket(bytes,bytes.length);while (true){//接收傳過來的信息socket.receive(packet);String str = new String(packet.getData(),0,packet.getLength());System.out.println("收到"+packet.getAddress()+":"+packet.getPort()+"發(fā)送數(shù)據(jù):"+str);}}catch (Exception e){e.printStackTrace();}} }

效果

總結(jié)

以上是生活随笔為你收集整理的【Java-网络编程】一对一聊天系统的实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。