大家有簡(jiǎn)單的聊天室的代碼我參考一下嗎
那個(gè)，我想做一個(gè)簡(jiǎn)單的通信，我用了多線程，但是我輸入一句話然后點(diǎn)擊回車，然后服務(wù)器沒有輸出這句話，直到我輸入結(jié)束標(biāo)志over然后才打印，然后是把全部的打印出來，請(qǐng)問怎么解決
進(jìn)擊的猿
2017-04-09
4 回答
舉報(bào)
0/150
提交
取消
2017-04-11
//服務(wù)器端 package?Main; import?java.io.BufferedReader; import?java.io.IOException; import?java.io.InputStreamReader; import?java.io.PrintWriter; import?java.net.ServerSocket; import?java.net.Socket; import?java.util.Scanner; public?class?TCPServer?{ public?static?void?main(String[]?args)?throws?IOException?{ ServerSocket?server?=?new?ServerSocket(8899); Socket?socket?=?server.accept(); System.out.println("鏈接成功。"); Speak?speak?=?new?Speak(socket); speak.start(); Listen?listen?=?new?Listen(socket); listen.start(); } } class?Speak?extends?Thread?{ Socket?socket?=?null; PrintWriter?speak?=?null; String?Data?=?null; Scanner?hand?=?new?Scanner(System.in); public?Speak(Socket?socket)?throws?IOException?{ this.socket?=?socket; this.speak?=?new?PrintWriter(socket.getOutputStream(),?true); } public?void?run(){ while(true){ Data?=?hand.next(); speak.println(Data); } } } class?Listen?extends?Thread?{ Socket?socket?=?null; BufferedReader?reader?=?null; public?Listen(Socket?socket)?throws?IOException{ this.socket?=?socket; this.reader?=?new?BufferedReader(new?InputStreamReader(socket.getInputStream())); } public?void?run(){ while(true){ try?{ System.out.println(reader.readLine()); }?catch?(IOException?e)?{ //?TODO?Auto-generated?catch?block e.printStackTrace(); } } } } //客戶端 package?Main; import?java.io.IOException; import?java.net.Socket; import?java.net.UnknownHostException; public?class?TCPClient?{ public?static?void?main(String[]?args)?throws?UnknownHostException,?IOException?{ //?TODO?Auto-generated?method?stub Socket?socket?=?new?Socket("127.0.0.1",?8899); System.out.println("鏈接成功。。"); Speak?speak?=?new?Speak(socket); speak.start(); Listen?listen?=?new?Listen(socket); listen.start(); } }2019-02-05
非常感謝啊
2017-06-11
服務(wù)器端： package?QiYanhui; import?java.net.*; import?java.io.*; import?java.util.*; /** ?*?@author?聊天軟件的服務(wù)器端程序 ?*/ public?class?TalkServer?{ ????public?static?ArrayList<Client>?allclient?=?new?ArrayList<Client>();?//存放所有通信線程 ????public?static?int?clientnum?=?0;??//統(tǒng)計(jì)客戶連接的計(jì)數(shù)變量 ???? ????public?static?void?main(String?args[]){ ????????try?{ ????????????ServerSocket?s?=?new?ServerSocket(5432); ????????????while(true){ ????????????????Socket?s1?=?s.accept();??//等待客戶連接 ????????????????DataOutputStream?dos?=?new?DataOutputStream(s1.getOutputStream()); ????????????????DataInputStream?din?=?new?DataInputStream(s1.getInputStream()); ????????????????Client?x?=?new?Client(clientnum,?dos,?din);??//創(chuàng)建與客戶對(duì)應(yīng)的通信線程 ????????????????allclient.add(x);??//將線程加入ArrayList中 ????????????????x.start(); ????????????????clientnum++; ????????????} ????????}?catch?(IOException?e)?{?} ????} } //通信線程處理與對(duì)應(yīng)的客戶通信，將來自客戶數(shù)據(jù)發(fā)往其他客戶 class?Client?extends?Thread?{ ????int?id;???//客戶的標(biāo)識(shí) ????DataOutputStream?dos;??//去往客戶的輸出流 ????DataInputStream?din;??//來自客戶的輸入流 ???? ????public?Client(int?id,?DataOutputStream?dos,?DataInputStream?din){ ????????this.id?=?id; ????????this.dos?=?dos; ????????this.din?=?din; ????} ???? ????public?void?run(){????//循環(huán)讀取客戶數(shù)據(jù)轉(zhuǎn)發(fā)給其他客戶 ????????while(true){ ????????????try?{ ????????????????String?message?=?"客戶"?+?id?+?":"?+?din.readUTF();???//讀客戶數(shù)據(jù) ????????????????for(int?i=0;?i<TalkServer.clientnum;?i++){ ????????????????????//將消息轉(zhuǎn)發(fā)給其他客戶 ????????????????????if(i?!=?id){ ????????????????????????TalkServer.allclient.get(i).dos.writeUTF(message); ????????????????????}else{ ????????????????????????String?remessage?=?""; ????????????????????????remessage?=?message.replace("客戶"?+?id,?"自己"); ???????????????????????? ????????????????????????//使自己發(fā)送的信息顯示在屏幕的右邊 ????????????????????????int?aa?=?35?-?remessage.length(); ????????????????????????StringBuffer?space=?new?StringBuffer(); ????????????????????????//輸出指定的空格 ????????????????????????for(int?j=?0;j<(aa-1);j++) ????????????????????????{ ???????????????????????????space.append("?");//這里是空格 ????????????????????????} ????????????????????????TalkServer.allclient.get(id).dos.writeUTF((space.toString())?+?remessage); ????????????????????} ????????????????} ????????????}?catch?(IOException?e)?{} ????????} ????} } 客戶端： package?QiYanhui; import?java.net.*; import?java.io.*; import?java.awt.event.*; import?java.awt.*; public?class?TalkClient?{ ????public?static?void?main(String[]?args)?throws?IOException{ ????????Socket?s1?=?new?Socket("localhost",?5432);????//連接服務(wù)器 ????????DataInputStream?dis?=?new?DataInputStream(s1.getInputStream()); ????????final?DataOutputStream?dos?=?new?DataOutputStream(s1.getOutputStream()); ????????Frame?myframe?=?new?Frame("簡(jiǎn)易聊天室"); ????????Panel?panelx?=?new?Panel(); ????????final?TextField?input?=?new?TextField(35); ????????TextArea?display?=?new?TextArea(19,?35); ????????panelx.add(display); ????????panelx.add(input); ????????myframe.add(panelx); ????????new?receiveThread(dis,?display);????//創(chuàng)建啟動(dòng)接收消息的線程 ????????input.addActionListener(new?ActionListener()?{ ????????????public?void?actionPerformed(ActionEvent?e)?{ ????????????????try?{ ????????????????????dos.writeUTF(input.getText());????//發(fā)送數(shù)據(jù) ????????????????????input.setText("");??//清空輸入框內(nèi)容 ????????????????}?catch?(IOException?e2)?{????} ????????????} ????????}); ???????? ????????myframe.setSize(350,?400); ????????myframe.setVisible(true); ????} } //接收消息線程循環(huán)讀取網(wǎng)絡(luò)消息，顯示在文本域 class?receiveThread?extends?Thread{ ????DataInputStream?dis; ????TextArea?displayarea; ???? ????public?receiveThread(DataInputStream?dis,?TextArea?m){ ????????this.dis?=?dis; ????????displayarea?=?m; ????????this.start(); ????} ???? ????public?void?run(){ ????????for(;;){ ????????????try?{ ????????????????String?str?=?dis.readUTF();???//讀來自服務(wù)器的消息 ????????????????displayarea.append(str?+?"\n");???//將消息添加到文本域顯示 ????????????}?catch?(IOException?e)?{} ????????} ????} } 歡迎交流，謝謝。2017-05-22
run方法里不是死循環(huán)嗎 我怎么有點(diǎn)不懂·