Shulou(Shulou.com)06/02 Report--

Based on how to achieve a simple local area network dialogue system based on Java, I believe that many inexperienced people do not know what to do about it. Therefore, this paper summarizes the causes and solutions of the problem. Through this article, I hope you can solve this problem.

First of all,

The writing is really ordinary. Don't spray it.

Why, because of the epidemic, the school does not have enough time for the final exam two weeks ahead of schedule.

Server code:

Package xcvcvcx;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.OutputStreamWriter;import java.net.ServerSocket;import java.net.Socket;import java.nio.charset.StandardCharsets;import java.util.HashMap;import java.util.Map;public class Server {static int index = 0; static BufferedWriter [] userWrite = new BufferedWriter [100]; static BufferedReader [] userRead = new BufferedReader [100] Static Socket [] userSocket = new Socket [100]; static String [] userId = new String [100]; static String [] userName = new String [100]; public static void main (String [] args) throws IOException {ServerSocket ss = new ServerSocket (6666); / / listen on designated port System.out.println ("server is running..."); index = 0; for (;) {Socket sock = ss.accept () String idd = sock.getRemoteSocketAddress (). ToString (); System.out.println ("connected from" + sock.getRemoteSocketAddress ()); userSocket [index] = sock; Thread t = new Handler (sock); ((Handler) t). UserId = idd; userId [index] = ((Handler) t). UserId = idd; t.start ();}} class Handler extends Thread {Socket sock; BufferedWriter writer; BufferedReader reader; String username; String userId Public Handler (Socket sock) {this.sock = sock;} public void synMessage (Map message) throws IOException {BufferedWriter writer; BufferedWriter [] user = Server.userWrite; int isall = 1; String dis = "a"; if (message.get ("messageclass"). ToString (). Equals ("normally") {dis = message.get ("distination"); System.out.println (dis); System.out.println () If (dis.equals ("all") = = false) {System.out.println ("no isall"); isall= 0;}} int len = Server.index; for (int I = 0; I

< len;i++) { if (Server.userWrite[i] == null){ continue; } System.out.println("vf"); if (isall == 0){ // 专门的消息 if (Server.userName[i].equals(dis)){ message.put( "distinationId",Server.userId[i] ); writer = user[i]; writer.write(message.toString() + "\n"); System.out.print("专门消息发送成功"); writer.flush(); return; } continue; } message.put( "distinationId",Server.userId[i] ); if (Server.userWrite[i] == null){ continue; } if ( Server.userId[i].equals(this.userId) == false) { writer = user[i]; writer.write(message.toString() + "\n"); System.out.print("进来了"); writer.flush(); }else { writer = user[i]; writer.write(message.toString() + "\n"); System.out.print("进来了"); writer.flush(); } } } public void synUserList(Map message,String Id){ BufferedWriter writer; BufferedWriter[] user =Server.userWrite; // 封装 用户列表 // 规定用户名不可以有空格 int len = Server.index; String userLis = "here"; for (int i = 0; i< len ; i++) { System.out.println(userLis); if (Server.userWrite[i]!=null){ if (message.get("userId").equals(Server.userId[i])){ continue; }else { if (Server.userName[i] ==null){ continue; } userLis = userLis + " " + Server.userName[i]; } } } message.put( "distinationId",Id); message.put( "userList",userLis); message.put("messageclass","synUserList"); for(int i =0; i< len;i++) { if (Server.userWrite[i] == null){ continue; } if ( Server.userId[i].equals(Id)) { writer = user[i]; try { writer.write(message.toString() + "\n"); writer.flush(); return; } catch (IOException e) { e.printStackTrace(); } } } } @Override public void run() { try (InputStream input = this.sock.getInputStream()) { try (OutputStream output = this.sock.getOutputStream()) { handle(input, output); } } catch (Exception e) { try { this.sock.close(); } catch (IOException ioe) { } System.out.println("client disconnected."); } } private void handle(InputStream input, OutputStream output) throws IOException { BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output, StandardCharsets.UTF_8)); BufferedReader reader = new BufferedReader(new InputStreamReader(input, StandardCharsets.UTF_8)); this.writer = writer; this.reader = reader; int inde = Server.index; Server.index++; Server.userRead[inde] = reader; Server.userWrite[inde] = writer; Map message= new HashMap(); message.put("messageclass", "synId");// 普通 消息 message.put( "userId",userId ); message.put( "userIndex",String.valueOf(inde) ); String to=message.toString(); writer.write(to+'\n'); writer.flush(); for (;;) { String s = reader.readLine(); if (s == null){ continue; }// System.out.print(s);// synMessages(s); Map mess= Client.mapStringToMap(s);//// System.out.print(s); if(mess.get("messageclass").toString().equals("normally")) { System.out.print("irieowmxn"); synMessage(mess); continue; }else if (mess.get("messageclass").toString().equals("synUserName")){ System.out.println("now synuser"); String id = mess.get("userId"); System.out.println(mess.toString()); username = mess.get("user"); int index = Integer.parseInt( mess.get("userIndex") ); Server.userName[index] = username; // 同步 在线用户 Map synuser= new HashMap(); synuser.put("messageclass", "addUser");// 普通 消息 synuser.put( "userName",username ); synMessage(synuser); // 同步所以已在线用户， 有新用户 登录 // 其实 我们还需要 回复 该用户， 现在有哪些在线 以便于 后来登录的人 用户列表 无法更新 synUserList(message,id); continue; }else if ( mess.get("messageclass").toString().equals("userClose") ){ Map synuser= new HashMap(); synuser.put("messageclass", "userClose");// 普通 消息 synuser.put( "userName",username ); synMessage(synuser); int iin = Integer.parseInt(mess.get("userIndex")); Server.userWrite[iin] = null; } if (s.equals("bye")) { writer.write("bye\n"); writer.flush(); break; } } }} 客户端： package xcvcvcx;import java.awt.BorderLayout;import java.awt.FlowLayout;import java.awt.GridLayout;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.awt.event.ItemEvent;import java.awt.event.ItemListener;import java.io.BufferedReader;import java.io.BufferedWriter;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.OutputStreamWriter;import java.net.Socket;import java.net.SocketAddress;import java.nio.charset.StandardCharsets;import java.text.SimpleDateFormat;import java.util.Date;import java.util.HashMap;import java.util.Map;import java.util.Scanner;import javax.swing.JButton;import javax.swing.JComboBox;import javax.swing.JFrame;import javax.swing.JLabel;import javax.swing.JPanel;import javax.swing.JScrollPane;import javax.swing.JTextArea;import javax.swing.JTextField;import javax.swing.WindowConstants;public class Client extends JFrame implements ActionListener ,ItemListener { private String currentt_userName = null; //各种组件 JLabel jLabelSeverIP,jLabelSeverPort,jLabelReceiveData,jLabelSentData; JTextField jTextFieldSeverIP,jTextFieldSeverPort,jTextFieldSentData; JButton jButtonSetupSever,jButtonCloseNetwork,jButtonSent; JTextArea jTextAreaReceiveData; JButton jButtonExit; // 当前在线用户部分 JLabel jLabelOnlinUser; JComboBox jComboBoxOnlineUser; //组件完毕 BufferedReader reader; BufferedWriter writer; // 存储用户信息 JLabel jLabelusername; JTextField jTextFieldusername; String userId ; Socket sock; int userIndex; // 服务连接相关 String ServerAddress ="192.168.43.240" ; // 可以自己设置 int port = 6666; public Client(){ init(); } public void init(){ //初始化 jLabelReceiveData=new JLabel("接受数据:"); jLabelSentData=new JLabel("发送数据:"); jLabelSeverIP=new JLabel("服务器IP"); jLabelSeverPort=new JLabel("服务器端口"); jTextFieldSentData=new JTextField(15); jTextFieldSeverIP=new JTextField(7); jTextFieldSeverPort=new JTextField(7); jButtonCloseNetwork=new JButton("关闭服务"); jButtonSent=new JButton("发送"); jButtonSetupSever=new JButton("开启服务"); jTextAreaReceiveData=new JTextArea(20,15); JScrollPane scroller = new JScrollPane(jTextAreaReceiveData); scroller.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS); jTextAreaReceiveData.setWrapStyleWord(true);//设置单词在一行不足容纳时换行 jTextAreaReceiveData.setLineWrap(true);//设置文本编辑区自动换行默认为true,即会"自动换行" //this.add(editArea,BorderLayout.CENTER);//向窗口添加文本编辑区 jButtonExit = new JButton("退出"); //组件初始化 // 存储 用户信息 jLabelusername = new JLabel("用户名"); jTextFieldusername = new JTextField(10); jLabelOnlinUser = new JLabel("在线用户"); jComboBoxOnlineUser = new JComboBox(); jComboBoxOnlineUser.addItemListener(this::itemStateChanged); jComboBoxOnlineUser.addItem("self"); JPanel panel1=new JPanel(); panel1.setLayout(new FlowLayout()); panel1.add(jLabelSeverIP); panel1.add(jTextFieldSeverIP); panel1.add(jLabelSeverPort); panel1.add(jTextFieldSeverPort); panel1.add(jButtonSetupSever); panel1.add(jButtonCloseNetwork); JPanel panel2=new JPanel(); panel2.add(jLabelReceiveData); JPanel jPaneluserinfor = new JPanel(); jPaneluserinfor.setLayout(new FlowLayout()); jPaneluserinfor.add(jLabelusername); jPaneluserinfor.add((jTextFieldusername)); jPaneluserinfor.add(jLabelOnlinUser); jPaneluserinfor.add(jComboBoxOnlineUser); JPanel jPanel1=new JPanel(); jPanel1.setLayout(new GridLayout(3,1)); jPanel1.add(panel1); jPanel1.add(jPaneluserinfor); jPanel1.add(panel2); JPanel panel3=new JPanel(); panel3.setLayout(new FlowLayout()); panel3.add(jLabelSentData); JPanel panel4=new JPanel(); panel4.setLayout(new FlowLayout()); panel4.add(jTextFieldSentData); panel4.add(jButtonSent); panel4.add(jButtonExit); JPanel jPanel2=new JPanel(); jPanel2.setLayout(new GridLayout(2,1)); jPanel2.add(panel3); jPanel2.add(panel4); JPanel jPanel=new JPanel(); jPanel.setLayout(new BorderLayout()); jPanel.add(jPanel1,BorderLayout.NORTH); jPanel.add(scroller,BorderLayout.CENTER); jPanel.add(jPanel2,BorderLayout.SOUTH); //完成组件组合 jButtonSent.addActionListener(this); jButtonSetupSever.addActionListener(this); jButtonCloseNetwork.addActionListener(this); jButtonExit.addActionListener(this); setSize(600,400); setDefaultCloseOperation(WindowConstants.EXIT_ON_CLOSE); add(jPanel); setVisible(true); //显示 jButtonCloseNetwork.setEnabled(false); jTextFieldSeverIP.setText(ServerAddress); jTextFieldSeverPort.setText(String.valueOf(port)); jTextAreaReceiveData.append("本程序只用于简单演示，\n若要修改服务器地址或端口，请修改指定代码，暂不支持手动指定\n\n\n"); // 连接服务器 try { Socket sock = new Socket(ServerAddress, port); this.sock = sock; try (InputStream input = sock.getInputStream()) { try (OutputStream output = sock.getOutputStream()) { BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output, StandardCharsets.UTF_8)); BufferedReader reader = new BufferedReader(new InputStreamReader(input, StandardCharsets.UTF_8)); SocketAddress id = sock.getRemoteSocketAddress(); userId = sock.getRemoteSocketAddress().toString(); this.writer =writer; this.reader = reader; while(true) for (; ; ) { String resp = reader.readLine(); while (resp == null) { resp = reader.readLine(); } System.out.println("" + str); String[] strs=str.split(","); Map map = new HashMap(); for (String string : strs) { String key=string.split("=")[0]; String value=string.split("=")[1]; value = value.trim(); key = key.trim(); map.put(key, value); } return map; } public static void main(String[] args) throws IOException { Client a = new Client(); } private static void handle(InputStream input, OutputStream output) throws IOException { BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output, StandardCharsets.UTF_8)); BufferedReader reader = new BufferedReader(new InputStreamReader(input, StandardCharsets.UTF_8)); Scanner scanner = new Scanner(System.in); System.out.println("[server] " + reader.readLine()); for (;;) { System.out.print(">

> "); / / print prompt String s = scanner.nextLine (); / / read a line of input writer.write (s); writer.newLine (); writer.flush (); String resp = reader.readLine (); System.out.println ("

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.