本文实例为大家分享了java+socket实现简易局域网聊天室的具体代码，供大家参考，具体内容如下
服务器端 【java+socket实现简易局域网聊天室】ServerFrame.java

package com.eze.chatroom.server; import java.awt.EventQueue; import javax.swing.JFrame; import javax.swing.JPanel; import javax.swing.border.EmptyBorder; import javax.swing.JLabel; import java.awt.Color; import java.awt.Font; import javax.swing.JTextField; import javax.swing.JButton; import javax.swing.JOptionPane; import javax.swing.JTextArea; import javax.swing.JScrollPane; import java.awt.event.KeyAdapter; import java.awt.event.KeyEvent; import java.awt.event.MouseAdapter; import java.awt.event.MouseEvent; public class ServerFrame extends JFrame {/*** */private static final long serialVersionUID = 1L; private JPanel contentPane; private JTextField txtPort; private JLabel lblOnlineCount; private JTextArea txtAreaInfo; private Server server; private JTextArea txtAreaPals; /*** Launch the application.*/public static void main(String[] args) {EventQueue.invokeLater(new Runnable() {public void run() {try {ServerFrame frame = new ServerFrame(); frame.setVisible(true); } catch (Exception e) {e.printStackTrace(); }}}); }/*** Create the frame.*/public ServerFrame() {this.setTitle("server"); this.setResizable(false); setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setBounds(100, 100, 658, 428); contentPane = new JPanel(); contentPane.setForeground(Color.DARK_GRAY); contentPane.setBorder(new EmptyBorder(5, 5, 5, 5)); setContentPane(contentPane); contentPane.setLayout(null); JLabel lblPort = new JLabel("port :"); lblPort.setFont(new Font("宋体", Font.PLAIN, 18)); lblPort.setBounds(14, 13, 72, 31); contentPane.add(lblPort); txtPort = new JTextField(); txtPort.addKeyListener(new KeyAdapter() {@Overridepublic void keyTyped(KeyEvent e) {int c = e.getKeyChar(); if(!(c > KeyEvent.VK_0 && c < KeyEvent.VK_9)){e.consume(); }}}); txtPort.setFont(new Font("宋体", Font.PLAIN, 20)); txtPort.setBounds(89, 18, 138, 24); contentPane.add(txtPort); txtPort.setColumns(10); JScrollPane scrollPane = new JScrollPane(); scrollPane.setBounds(245, 103, 378, 272); contentPane.add(scrollPane); txtAreaInfo = new JTextArea(); scrollPane.setViewportView(txtAreaInfo); txtAreaInfo.setFont(new Font("Monospaced", Font.PLAIN, 20)); JButton btnChange = new JButton("start"); btnChange.addMouseListener(new MouseAdapter() {private boolean flag = true; @Overridepublic void mouseClicked(MouseEvent e) {String portStr = txtPort.getText().trim(); boolean isvalid = false; int port = 9999; if(!(portStr.startsWith("0") || portStr.equals(""))){port = Integer.valueOf(portStr); if(port >= 1024 && port <= 65535)isvalid = true; }if(!isvalid){JOptionPane.showMessageDialog(ServerFrame.this, "invalid port that is expected to put into the range of 1024~65535"); return; }if(flag){btnChange.setText("stop"); txtAreaInfo.append("server started\n"); flag = false; ServerFrame.this.server = new Server(ServerFrame.this, ServerFrame.this.getTitle(), port); Thread thdServer = new Thread(new Runnable() {@Overridepublic void run() {ServerFrame.this.server.start(); }}); thdServer.start(); }else{btnChange.setText("start"); ServerFrame.this.server.stop(); txtAreaInfo.append("server stopped\n"); flag = true; }}}); btnChange.setFont(new Font("宋体", Font.PLAIN, 19)); btnChange.setBackground(new Color(240, 255, 240)); btnChange.setForeground(new Color(178, 34, 34)); btnChange.setBounds(270, 17, 113, 27); contentPane.add(btnChange); JLabel lblPalsOnline = new JLabel("pals online:"); lblPalsOnline.setBounds(18, 73, 113, 18); contentPane.add(lblPalsOnline); JLabel lblLogInfo = new JLabel("log info"); lblLogInfo.setBounds(285, 73, 72, 18); contentPane.add(lblLogInfo); lblOnlineCount = new JLabel("0"); lblOnlineCount.setBounds(123, 75, 72, 18); contentPane.add(lblOnlineCount); JScrollPane scrollPane_1 = new JScrollPane(); scrollPane_1.setBounds(14, 111, 213, 264); contentPane.add(scrollPane_1); txtAreaPals = new JTextArea(); scrollPane_1.setViewportView(txtAreaPals); }public JLabel getLblOnlineCount() {return lblOnlineCount; }public JTextArea getTxtAreaPals() {return txtAreaPals; }public JTextArea getTxtAreaInfo() {return txtAreaInfo; }}

Server.java

package com.eze.chatroom.server; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.net.SocketException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.swing.JTextArea; public class Server {private ServerSocket server; private List clients; private Map pals; @SuppressWarnings("unused")private String name; private int port; private ServerFrame frame; public Server(ServerFrame frame, String name, int port){this.frame = frame; this.name = name; this.port = port; this.clients = new ArrayList<>(); this.pals = new HashMap<>(); }public void start(){try {this.server = new ServerSocket(port); System.out.println("server start at port "+port); while(true){Socket client = server.accept(); Thread thdHandConn = new Thread(new HandleConnection(client, clients, pals, frame)); thdHandConn.start(); }}catch(SocketException e){System.out.println("server stop"); }catch (IOException e) {e.printStackTrace(); }}public void stop(){try {for(Socket sock : clients){sock.close(); }server.close(); } catch (IOException e) {e.printStackTrace(); }}public static void autoRoll(JTextArea area){area.setCaretPosition(area.getText().length()); }}

HandleConnnection.java

package com.eze.chatroom.server; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.Socket; import java.net.SocketException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.util.Map; public class HandleConnection implements Runnable {private Socket client; private List clients; private Map pals; private ServerFrame frame; public HandleConnection(Socket client, List clients, Map pals, ServerFrame frame){this.client = client; this.clients = clients; this.pals = pals; this.frame = frame; }@Overridepublic void run() {String username = null; SimpleDateFormat formatDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); try {DataInputStream dataInput = new DataInputStream(client.getInputStream()); DataOutputStream dataOutput = new DataOutputStream(client.getOutputStream()); String totalFirst = dataInput.readUTF(); username = totalFirst.split("_")[0]; if(username.equals("")){dataOutput.writeUTF("no"); client.close(); return; }dataOutput.writeUTF("ok"); String hello = formatDate.format(new Date())+"\n"+client.getRemoteSocketAddress().toString()+username+" join romm\n"; frame.getTxtAreaInfo().append(hello); Server.autoRoll(frame.getTxtAreaInfo()); this.forwardMsg(hello); clients.add(client); pals.put(client.getRemoteSocketAddress().toString(), username); this.updatePalsList(); while(true){String word = dataInput.readUTF(); String date = formatDate.format(new Date()); String msg = date+" "+username+"\n"+word; frame.getTxtAreaInfo().append(msg+"\n"); Server.autoRoll(frame.getTxtAreaInfo()); this.forwardMsg(msg); }}catch (SocketException e) {clients.remove(client); pals.remove(client.getRemoteSocketAddress().toString(), username); this.updatePalsList(); String leaveMsg = formatDate.format(new Date())+"\n"+username+" leaved room\n"; this.frame.getTxtAreaInfo().append(leaveMsg); Server.autoRoll(frame.getTxtAreaInfo()); this.forwardMsg(leaveMsg); }catch (IOException e) {e.printStackTrace(); }}protected void updatePalsList(){this.frame.getLblOnlineCount().setText(String.valueOf(clients.size())); this.frame.getTxtAreaPals().setText(""); for(Map.Entry entry : pals.entrySet()){this.frame.getTxtAreaPals().append(entry.getKey()+" "+entry.getValue()+"\n"); }}protected void forwardMsg(String msg){try {for(Socket sock : clients){if(sock != client){DataOutputStream dataOutput = new DataOutputStream(sock.getOutputStream()); dataOutput.writeUTF(msg); }}} catch (IOException e) {e.printStackTrace(); }}}

客户端 ClientLoginViewer.java

package com.eze.chatroom.client; import java.awt.EventQueue; import javax.swing.JFrame; import javax.swing.JPanel; import javax.swing.border.EmptyBorder; import javax.swing.JLabel; import javax.swing.JOptionPane; import javax.swing.JTextField; import javax.swing.JButton; import java.awt.Font; import java.awt.event.MouseAdapter; import java.awt.event.MouseEvent; import java.awt.event.KeyAdapter; import java.awt.event.KeyEvent; import java.awt.event.ActionListener; import java.awt.event.ActionEvent; public class ClientLoginViewer extends JFrame {/*** */private static final long serialVersionUID = 1L; private JPanel contentPane; private ClientWin win; private JTextField txtUsername; private JTextField txtServer; private JLabel lblPort; private JTextField txtPort; private Client client; /*** Launch the application.*/public static void main(String[] args) {EventQueue.invokeLater(new Runnable() {public void run() {try {ClientLoginViewer frame = new ClientLoginViewer(); frame.setVisible(true); } catch (Exception e) {e.printStackTrace(); }}}); }/*** Create the frame.*/public ClientLoginViewer() {setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setBounds(100, 100, 603, 366); contentPane = new JPanel(); contentPane.setBorder(new EmptyBorder(5, 5, 5, 5)); setContentPane(contentPane); contentPane.setLayout(null); JLabel lblNewLabel = new JLabel("username:"); lblNewLabel.setFont(new Font("宋体", Font.PLAIN, 20)); lblNewLabel.setBounds(71, 41, 113, 18); contentPane.add(lblNewLabel); txtUsername = new JTextField(); txtUsername.setText("admin"); txtUsername.setBounds(209, 38, 235, 24); contentPane.add(txtUsername); txtUsername.setColumns(10); JLabel lblServer = new JLabel("server:"); lblServer.setFont(new Font("宋体", Font.PLAIN, 20)); lblServer.setBounds(71, 93, 90, 18); contentPane.add(lblServer); txtServer = new JTextField(); txtServer.setText("localhost"); txtServer.setColumns(10); txtServer.setBounds(209, 92, 235, 24); contentPane.add(txtServer); lblPort = new JLabel("port:"); lblPort.setFont(new Font("宋体", Font.PLAIN, 20)); lblPort.setBounds(71, 149, 90, 18); contentPane.add(lblPort); txtPort = new JTextField(); txtPort.setText("2222"); txtPort.addKeyListener(new KeyAdapter() {@Overridepublic void keyTyped(KeyEvent e) {int c = e.getKeyChar(); if(c < KeyEvent.VK_0 || c > KeyEvent.VK_9){e.consume(); }}}); txtPort.setBounds(209, 148, 235, 24); contentPane.add(txtPort); txtPort.setColumns(10); JButton btnLogin = new JButton("login"); btnLogin.addActionListener(new ActionListener() {public void actionPerformed(ActionEvent e) {}}); btnLogin.addMouseListener(new MouseAdapter() {@Overridepublic void mouseClicked(MouseEvent e) {String username = txtUsername.getText(); String server = txtServer.getText(); String portStr = txtPort.getText(); if(!this.argsValid(username, server, portStr)){String error = "please input valid arguments which username, password, server, port"+ " are not allowed be empty and port should be in the range of 1024~65535"; JOptionPane.showMessageDialog(ClientLoginViewer.this, error); return; }client = new Client(username, server, Integer.valueOf(portStr), ClientLoginViewer.this.win); if(ClientLoginViewer.this.client.login()){ClientLoginViewer.this.setVisible(false); ClientLoginViewer.this.win.setVisible(true); win.setClient(client); }else{JOptionPane.showMessageDialog(ClientLoginViewer.this, "login falied"); }}protected boolean argsValid(String username, String server, String portStr){if(username.equals("") || server.equals("") || portStr.equals(""))return false; int port = Integer.valueOf(portStr); if(port < 1024 || port > 65535)return false; return true; }}); btnLogin.setFont(new Font("宋体", Font.PLAIN, 20)); btnLogin.setBounds(213, 222, 113, 27); contentPane.add(btnLogin); this.initOther(); }protected void initOther(){this.win = new ClientWin(); this.setResizable(false); }}

ClientWin.java

package com.eze.chatroom.client; import javax.swing.JFrame; import javax.swing.JPanel; import javax.swing.border.EmptyBorder; import com.eze.chatroom.server.Server; import javax.swing.JTextField; import javax.swing.JScrollPane; import javax.swing.JButton; import java.awt.Font; import javax.swing.JTextArea; import java.awt.event.MouseAdapter; import java.awt.event.MouseEvent; import java.io.DataOutputStream; import java.io.IOException; import java.text.SimpleDateFormat; import java.util.Date; public class ClientWin extends JFrame {/*** */private static final long serialVersionUID = 1L; private JPanel contentPane; private JTextField txtSendMsg; private JTextArea txtAreaShowMsg; @SuppressWarnings("unused")private Client client; private DataOutputStream dataOutput; private JScrollPane scrollPane; /*** Create the frame.*/public ClientWin() {setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setBounds(100, 100, 631, 467); contentPane = new JPanel(); contentPane.setBorder(new EmptyBorder(5, 5, 5, 5)); setContentPane(contentPane); contentPane.setLayout(null); scrollPane = new JScrollPane(); scrollPane.setBounds(7, 7, 595, 351); contentPane.add(scrollPane); txtAreaShowMsg = new JTextArea(); txtAreaShowMsg.setFont(new Font("Monospaced", Font.PLAIN, 20)); scrollPane.setViewportView(txtAreaShowMsg); txtSendMsg = new JTextField(); txtSendMsg.setBounds(14, 371, 265, 41); txtSendMsg.setFont(new Font("宋体", Font.PLAIN, 20)); contentPane.add(txtSendMsg); txtSendMsg.setColumns(10); JButton btnPost = new JButton("post"); btnPost.addMouseListener(new MouseAdapter() {private SimpleDateFormat dateFormate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); @Overridepublic void mouseClicked(MouseEvent e) {String sendMsg = txtSendMsg.getText(); if(!sendMsg.equals("")){try {String date = dateFormate.format(new Date()); dataOutput.writeUTF(sendMsg); ClientWin.this.getTxtAreaShowMsg().append(date+" you\n"+sendMsg+"\n"); Server.autoRoll(ClientWin.this.getTxtAreaShowMsg()); ClientWin.this.txtSendMsg.setText(""); } catch (IOException e1) {e1.printStackTrace(); }}}}); btnPost.setBounds(377, 378, 113, 27); btnPost.setFont(new Font("宋体", Font.PLAIN, 20)); contentPane.add(btnPost); this.initOther(); }protected void initOther(){this.setResizable(false); }public void setClient(Client client) {this.client = client; try {this.dataOutput = new DataOutputStream(client.getClient().getOutputStream()); } catch (IOException e) {e.printStackTrace(); }}public JTextArea getTxtAreaShowMsg() {return txtAreaShowMsg; }public void setTxtSendMsg(JTextField txtSendMsg) {this.txtSendMsg = txtSendMsg; }}

Client.java

package com.eze.chatroom.client; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; import javax.swing.JOptionPane; public class Client {private Socket client; private String username; private String server; private int port; private ClientWin win; public Client(String username, String server, int port, ClientWin win){this.username = username; this.server = server; this.port = port; this.win = win; }public boolean login(){try {client = new Socket(server, port); DataInputStream dataInput = new DataInputStream(client.getInputStream()); DataOutputStream dataOutput = new DataOutputStream(client.getOutputStream()); dataOutput.writeUTF(username+"_"); String ret = dataInput.readUTF(); if(ret.contains("ok")){Thread thdReader = new Thread(new ClientReader(client, win)); thdReader.start(); return true; }} catch (UnknownHostException e) {e.printStackTrace(); JOptionPane.showMessageDialog(win, "unknown host"); } catch (IOException e) {e.printStackTrace(); }return false; }public Socket getClient() {return client; }}

ClientReader.java

package com.eze.chatroom.client; import java.io.DataInputStream; import java.io.IOException; import java.net.Socket; import javax.swing.JOptionPane; import com.eze.chatroom.server.Server; public class ClientReader implements Runnable {private ClientWin win; private Socket client; public ClientReader(Socket client ,ClientWin win){this.client = client; this.win = win; }@Overridepublic void run() {this.doHand(); }protected void doHand(){try {DataInputStream dataInput = new DataInputStream(client.getInputStream()); while(true){String msg = dataInput.readUTF(); win.getTxtAreaShowMsg().append(msg+"\n"); Server.autoRoll(win.getTxtAreaShowMsg()); }} catch (IOException e) {//e.printStackTrace(); try {client.close(); } catch (IOException e1) {e1.printStackTrace(); }System.out.println("client disconnected"); JOptionPane.showMessageDialog(win, "you have been disconnected"); }}}

运行效果

文章图片


文章图片


文章图片


文章图片


文章图片

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

推荐阅读

• 

  Docker容器下快速搭建Hyperf框架在Windows系统的本地开发环境
• 

  u盘启动快捷键u盘启动快捷键
• 

  吃了止痛药能打新冠疫苗吗
• 

  FGO魔伊复刻流程攻略 魔法少女纪行复刻活动流程推荐
• 

  随性写的
• 

  高三学生经商有前途吗？
• 

  让你的打印机重获新生 益普生打印机废墨清零软件下载
• 

  3000元价位手机怎么选好 3000元价位手机怎么选
• 

  安乐什么意思 安乐是什么意思
• 

  王者荣耀狂铁所有皮肤 王者荣耀狂铁战令皮肤怎么样
• 

  代理服务器出了什么问题？ 代理服务器不能怎么回事
• 

  纵向沟通与横向沟通有何不同 横向沟通与纵向沟通各有哪些优缺点
• 

  吃南瓜子能减肥吗
• 

  圆的面积和底面积一样吗? 圆的面积和底面积一样吗
• 

  手机cpu怎么设置最佳性能
• 

  宫腔镜|不知道宫腔镜有何优势？给你列出这3点，可别小瞧了
• 

  急脾气的妈妈怎么对待慢性子的孩子
• 

  粉扑拿回来要洗吗 粉扑用完怎么放置
• 

  的哥马上要交班，却闯祸又丢工作
• 

  mysql查询前三名 mysql查询第三到第五

• 详解Flutter自定义应用程序内键盘的实现方法
• Powershell实现多硬盘的电脑使用SCCM安装系统选择目的盘清单
• HarmonyOS - 实现多设备协同
• JavaSwing项目|基于Eclipse+Java+Swing+Mysql实现旅游管理信息系统
• JDBC从入门到实战|如何通过JDBC访问MySQL数据库（手把手实现登录界面(图解+完整代码)）
• C语言实现井字棋
• 分布式｜redis实现集群的几种方式你都知道了么（）
• 分布式|老板让我实现附近人发现的功能，我用它实现了
• mq从零开始实现 mq-07-负载均衡 load balance
• HMS Core地理围栏能力助你实现指定范围人群的精准消息推送