この記事では、参照のために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をもっとサポートすることを願っています。