この記事では、参照のためにJavaソケットチャットルーム機能の特定のコードを共有しています。特定のコンテンツは次のとおりです
client.java
java.io.*をインポートします。 java.net。*; Java.util。*をインポートします。パブリッククラスクライアント{public int port = 8083;ソケットソケット= null; public static void main(string [] args){new Client(); //実行を開始} public client(){try {socket = new Socket( "127.0.0.1"、port); new cthread()。start(); BufferedReader BR = new BufferedReader(new inputStreamReader(socket.getInputStream()));文字列msg1; while((msg1 = br.readline())!= null){system.out.println(msg1); }} catch(Exception e){}} class cthread extends thread {public void run(){try {bufferedreader re = new inputStreamReader(system.in)); printwriter pw = new PrintWriter(socket.getOutputStream()、true);文字列msg2; while(true){msg2 = re.readline(); pw.println(msg2); }} catch(例外e){e.printstacktrace(); }}}}server.java
java.net。*; java.io.*をインポートします。 Java.util。*をインポートします。パブリッククラスサーバー{int port;リスト<Socket>クライアント;サーバーソケットサーバー。 public server(){try {port = 8083; clients = new arrayList <Socket>(); server = new Serversocket(port); system.out.println( "Server Startain"); int co = 1; while(true){socket socket = server.accept(); clients.add(socket); mythread mythread = new mythread(socket、co); co ++; mythread.start(); }} catch(Exception ex){system.out.println( "vv"); }} public static void main(string [] args){new Server(); } class mythread extends thread {socket ssocket;プライベートインクカウント;プライベートバッファレッドリーダーBR;プライベートプリントライターPW;パブリック文字列msg; public mythread(socket s、int c){ssocket = s; count = c; } public void run(){try {br = new BufferedReader(new inputstreamReader(ssocket.getInputStream()); MSG = "Welcome [" + "Client" + count + "]チャットルームに! sendmsg(); while((msg = br.readline())!= null){msg = "【" + "client" + count + "] Say:" + msg; sendmsg(); }} catch(Exception ex){}} public void sendmsg(){try {system.out.println(msg); for(int i = clients.size() - 1; i> = 0; i-){pw = new printwriter(clients.get(i).getOutputStream()、true); pw.println(msg); pw.flush(); }} catch(例外Ex){}}}}実行結果:
上記はこの記事のすべての内容です。みんなの学習に役立つことを願っています。誰もがwulin.comをもっとサポートすることを願っています。