久久福利_99r_国产日韩在线视频_直接看av的网站_中文欧美日韩_久久一

您的位置:首頁技術(shù)文章
文章詳情頁

基于Java網(wǎng)絡(luò)編程和多線程的多對多聊天系統(tǒng)

瀏覽:71日期:2022-08-14 11:10:13
1.前言

程序?qū)崿F(xiàn)基于星型結(jié)構(gòu)(服務(wù)器接收來自各個客戶端發(fā)送的信息,然后將信息傳遞給其他客戶端界面并在其他客戶端界面顯示發(fā)送的信息)

基于Java網(wǎng)絡(luò)編程和多線程的多對多聊天系統(tǒng)

2.類圖

基于Java網(wǎng)絡(luò)編程和多線程的多對多聊天系統(tǒng)

3.代碼

客戶端代碼:

package netProgram;import java.io.IOException;import java.net.Socket;import java.net.SocketAddress;public class Client implements ScreenInputInterface{ private SocketHandler socketHandler; public void start(){new Thread(new ScreenInputRunIns(this)).start();try { socketHandler = new SocketHandler(new Socket('127.0.0.1',666),null); new Thread(socketHandler).start();} catch (IOException e) { e.printStackTrace();} } @Override public void send(String msg) {socketHandler.sendMsg(msg); } /* @Override public void send(String msg, SocketAddress address) {socketHandler.sendMsg(msg); }*/}

服務(wù)端代碼:

package netProgram;import java.io.IOException;import java.net.ServerSocket;import java.net.SocketAddress;import java.util.ArrayList;import java.util.List;public class Server implements ScreenInputInterface{ private List<SocketHandler> clients = new ArrayList<>(); private ServerSocket serverSocket; public void start(){//new Thread(new ScreenInputRunIns(this)).start();try { serverSocket = new ServerSocket(666); while (true){SocketHandler socketHandler = new SocketHandler(serverSocket.accept(),this);clients.add(socketHandler);System.out.println(socketHandler.getSocket().getRemoteSocketAddress()+'進入聊天系統(tǒng)');new Thread(socketHandler).start(); }} catch (IOException e) { e.printStackTrace();} } @Override public void send(String msg) {for (SocketHandler s:clients) { s.sendMsg(msg);} } /* @Override public void send(String msg, SocketAddress address) {for (SocketHandler s:clients) { if (s.getSocket().getRemoteSocketAddress().equals(address)){continue; } s.sendMsg(msg);} }*/ public static void main(String[] args) {new Server().start(); }}

屏幕輸入信息接口:

package netProgram;import java.net.SocketAddress;public interface ScreenInputInterface { void send(String msg);// void send(String msg, SocketAddress address);}

用于各個端口輸入信息的創(chuàng)建的線程對象:

package netProgram;import java.util.Scanner;public class ScreenInputRunIns implements Runnable{ private ScreenInputInterface screenInputInterface; private Scanner input = new Scanner(System.in); public ScreenInputRunIns(ScreenInputInterface screenInputInterface) {this.screenInputInterface = screenInputInterface; } @Override public void run() {//屏幕實時輸入while (true){ String msg = input.nextLine();// screenInputInterface.send(msg,null); screenInputInterface.send(msg);} }}

套接字處理器(用于傳輸數(shù)據(jù):實際發(fā)送信息到輸出流并實時監(jiān)聽各個端口的輸入且負責(zé)顯示):

package netProgram;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintWriter;import java.net.Socket;public class SocketHandler implements Runnable{ private String clientName; private Socket socket; private PrintWriter writer; private Server server; public SocketHandler(Socket socket,Server server) throws IOException {this.socket = socket;this.server = server;clientName = '<'+socket.getLocalSocketAddress()+'>';writer = new PrintWriter(this.socket.getOutputStream()); } public Socket getSocket() {return socket; } public void sendMsg(String msg){if (server!=null) writer.println(msg);else writer.println(clientName+':'+msg);writer.flush(); } @Override public void run() {while(true){//監(jiān)聽輸入流的輸入 try {BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));String receiveMsg = null;System.out.println();if ((receiveMsg = reader.readLine())!=null&&!(receiveMsg.equals(''))){ if (server!=null){//server.send(receiveMsg,socket.getRemoteSocketAddress());server.send(receiveMsg); }else {System.out.println(receiveMsg); }} } catch (IOException e) {e.printStackTrace(); }} }}

負責(zé)啟動的各個端口的客戶端代碼:

package netProgram;public class ClientLinked { public static void main(String[] args) {new Client().start(); }}

package netProgram;public class ClientLinked1 { public static void main(String[] args) {new Client().start(); }}

package netProgram;public class ClientLinked2 { public static void main(String[] args) {new Client().start(); }}

服務(wù)端啟動代碼在服務(wù)端類的main方法中。

到此這篇關(guān)于基于Java網(wǎng)絡(luò)編程和多線程的多對多聊天系統(tǒng)的文章就介紹到這了,更多相關(guān)java實現(xiàn)多對多聊天系統(tǒng)內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!

標簽: Java
相關(guān)文章:
主站蜘蛛池模板: 日韩在线不卡 | 国产主播一区 | 日韩在线观看成人 | 性免费网站 | 性视频黄色 | 求av网址 | 91精品中文字幕一区二区三区 | 精品不卡| 亚洲 欧美 精品 | 国产精品1区2区 | 日本免费一区二区三区 | 天天干天天插 | 91精品一区二区三区久久久久久 | 亚洲成人一区二区三区 | 日本福利在线观看 | 日韩在线观看 | 久久久久久国产免费视网址 | 伊人影院久久 | 成人影院一区二区三区 | 国产99精品视频 | 91视频一区二区 | 91社影院在线观看 | 91在线| 在线一区二区三区视频 | 国产成人无遮挡在线视频 | 日韩成人精品 | 成人a视频在线观看 | av一区二区在线观看 | 日日操操| 日韩精品成人 | 午夜黄色影院 | 自拍偷拍视频网站 | 精品国产影院 | 中文字幕日韩欧美一区二区三区 | 国产精品久久九九 | 国产精品一区二区在线 | 成人免费毛片高清视频 | 中文一区 | 6080亚洲精品一区二区 | 伊人网国产 | 六月丁香在线观看 |