第基于Java實現(xiàn)簡易的局域網(wǎng)對話系統(tǒng)privatevoidhandle(InputStreaminput,OutputStreamoutput)throwsIOException{

BufferedWriterwriter=newBufferedWriter(newOutputStreamWriter(output,StandardCharsets.UTF_8));

BufferedReaderreader=newBufferedReader(newInputStreamReader(input,StandardCharsets.UTF_8));

this.writer=writer;

this.reader=reader;

intinde=Server.index;

Server.index++;

Server.userRead[inde]=reader;

Server.userWrite[inde]=writer;

MapString,Stringmessage=newHashMapString,String

message.put("messageclass","synId");//普通消息

message.put("userId",userId);

message.put("userIndex",String.valueOf(inde));

Stringto=message.toString();

writer.write(to+'\n');

writer.flush();

for(;;){

Strings=reader.readLine();

if(s==null){

continue;

//System.out.print(s);

//synMessages(s);

MapString,Stringmess=Client.mapStringToMap(s);

////System.out.print(s);

if(mess.get("messageclass").toString().equals("normally"))

System.out.print("irieowmxn");

synMessage(mess);

continue;

}elseif(mess.get("messageclass").toString().equals("synUserName")){

System.out.println("nowsynuser");

Stringid=mess.get("userId");

System.out.println(mess.toString());

username=mess.get("user");

intindex=Integer.parseInt(mess.get("userIndex"));

Server.userName[index]=username;

//同步在線用戶

MapString,Stringsynuser=newHashMapString,String

synuser.put("messageclass","addUser");//普通消息

synuser.put("userName",username);

synMessage(synuser);

//同步所以已在線用戶，有新用戶登錄

//其實我們還需要回復(fù)該用戶，現(xiàn)在有哪些在線以便于后來登錄的人用戶列表無法更新

synUserList(message,id);

continue;

}elseif(mess.get("messageclass").toString().equals("userClose")){

MapString,Stringsynuser=newHashMapString,String

synuser.put("messageclass","userClose");//普通消息

synuser.put("userName",username);

synMessage(synuser);

intiin=Integer.parseInt(mess.get("userIndex"));

Server.userWrite[iin]=null;

if(s.equals("bye")){

writer.write("bye\n");

writer.flush();

break;

客戶端：

packagexcvcvcx;

importjava.awt.BorderLayout;

importjava.awt.FlowLayout;

importjava.awt.GridLayout;

importjava.awt.event.ActionEvent;

importjava.awt.event.ActionListener;

importjava.awt.event.ItemEvent;

importjava.awt.event.ItemListener;

importjava.io.BufferedReader;

importjava.io.BufferedWriter;

importjava.io.IOException;

importjava.io.InputStream;

importjava.io.InputStreamReader;

importjava.io.OutputStream;

importjava.io.OutputStreamWriter;

import.Socket;

import.SocketAddress;

importjava.nio.charset.StandardCharsets;

importjava.text.SimpleDateFormat;

importjava.util.Date;

importjava.util.HashMap;

importjava.util.Map;

importjava.util.Scanner;

importjavax.swing.JButton;

importjavax.swing.JComboBox;

importjavax.swing.JFrame;

importjavax.swing.JLabel;

importjavax.swing.JPanel;

importjavax.swing.JScrollPane;

importjavax.swi