精华内容
下载资源
问答
  • 局域网聊天

    2018-08-21 16:52:23
    本功能设计实现了局域网聊天系统的群聊以及私聊部分,群聊部分借鉴《Qt及Qt Quick开发实战精解》中的实例,添加了私聊功能,适合初学者学习,博客链接:...
  • c#局域网聊天,可以参考一下,还有点错误的,基本功能已经实现。c#局域网聊天,可以参考一下,还有点错误的,基本功能已经实现。c#局域网聊天,可以参考一下,还有点错误的,基本功能已经实现。c#局域网聊天,可以...
  • 局域网聊天易语言源码局域网聊天易语言源码局域网聊天易语言源码局域网聊天易语言源码
  • 易语言局域网聊天源码,局域网聊天,取时间,持续在线
  • 本文实例为大家分享了java局域网聊天程序的具体代码,供大家参考,具体内容如下有服务器端 和客户端两个界面,运行需要加上自己的ip地址,端口可以随意,但是客户端端口,和服务器端口要一样,然后就可以几个人一块...

    本文实例为大家分享了java局域网聊天程序的具体代码,供大家参考,具体内容如下

    有服务器端 和客户端两个界面,运行需要加上自己的ip地址,端口可以随意,但是客户端端口,和服务器端口要一样,然后就可以几个人一块聊天了

    简单贴几个代码吧

    Client.java  客户端代码

    package chat;

    import java.awt.BorderLayout;//布置容器的边框布局

    import java.awt.Color;

    import java.awt.Container;

    import java.awt.GridLayout;//布局处理器

    import java.awt.Toolkit;//抽象超类

    import java.awt.event.ActionEvent;//指示发生了组件定义的动作的语义事件

    import java.awt.event.ActionListener;//用于接收操作事件的侦听器接口

    import java.awt.event.MouseEvent;//指示组件中发生鼠标动作的事件

    import java.awt.event.MouseListener;//鼠标事件的侦听器接口

    import java.awt.event.WindowAdapter;//接收窗口事件的抽象适配器类。此类中的方法为空。此类存在的目的是方便创建侦听器对象

    import java.awt.event.WindowEvent;//指示窗口状态改变的低级别事件

    import java.io.BufferedReader;//提供通用的缓冲方式文本读取

    import java.io.IOException;//输入输出异常

    import java.io.InputStreamReader;//字节流通向字符流的桥梁

    import java.io.PrintWriter;//向文本输出流打印对象的格式化表示形式

    import java.net.Socket;//套接字,网络上的两个程序通过一个双向的通信连接实现数据交换的通信

    import java.util.HashMap;// HashMap 是 Map 接口的常用实现类

    import java.util.Map;//存数据,将键映射到值的对象

    import java.util.StringTokenizer;//允许应用程序将字符串分解为标记

    import javax.swing.BorderFactory;//创建一个浮雕式的边框

    import javax.swing.DefaultListModel;//列表模型

    import javax.swing.JButton;//按钮

    import javax.swing.JFrame;//窗口

    import javax.swing.JLabel;//标签

    import javax.swing.JList;//列表

    import javax.swing.JOptionPane;//对话框

    import javax.swing.JPanel;

    import javax.swing.JScrollPane;//视图

    import javax.swing.JSplitPane;//分隔

    import javax.swing.JTextArea;//多行文本

    import javax.swing.JTextField;//文本

    import javax.swing.border.EmptyBorder;//一个占用空间但不执行绘制的空透明边框

    import javax.swing.border.TitledBorder;//该类实现在指定位置以指定对齐方式显示字符串标题的任意边框

    import oldchat.ChatFrame;

    public class Client

    {

    private JFrame frame;

    private JList userList;

    private JTextArea textArea;

    private JTextField textField;

    private JTextField txt_port;

    private JTextField txt_hostIp;

    private JTextField txt_name;

    private JButton btn_start;

    private JButton btn_stop;

    private JButton btn_send;

    private JPanel northPanel;

    private JPanel southPanel;

    private JScrollPane rightScroll;

    private JScrollPane leftScroll;

    private JSplitPane centerSplit;

    private DefaultListModel listModel;

    private boolean isConnected = false;

    private Socket socket;//创建套接字

    private PrintWriter writer;

    private BufferedReader reader;

    private MessageThread messageThread;// 负责接收消息的线程

    private Map onLineUsers = new HashMap();// 所有在线用户

    // 主方法,程序入口

    public static void main(String[] args)

    {

    new Client();

    }

    // 执行发送

    public void send()

    {

    if (!isConnected)

    {

    JOptionPane.showMessageDialog(frame, "还没有连接服务器,无法发送消息!", "错误",

    JOptionPane.ERROR_MESSAGE);

    return;

    }

    String message = textField.getText().trim();

    if (message == null || message.equals(""))

    {

    JOptionPane.showMessageDialog(frame, "消息不能为空!", "错误",

    JOptionPane.ERROR_MESSAGE);

    return;

    }

    sendMessage(frame.getTitle() + "@" + "ALL" + "@" + message);

    textField.setText(null);

    }

    // 构造方法

    public Client()

    {

    textArea = new JTextArea();

    textArea.setEditable(false);

    textArea.setForeground(Color.blue);

    textField = new JTextField();

    txt_port = new JTextField("6666");

    txt_hostIp = new JTextField();

    txt_name = new JTextField();

    btn_start = new JButton("连接");

    btn_stop = new JButton("断开");

    btn_send = new JButton("发送");

    listModel = new DefaultListModel();

    userList = new JList(listModel);

    northPanel = new JPanel();

    northPanel.setLayout(new GridLayout(1, 7));

    northPanel.add(new JLabel("端口"));

    northPanel.add(txt_port);

    northPanel.add(new JLabel("服务器IP"));

    northPanel.add(txt_hostIp);

    northPanel.add(new JLabel("姓名"));

    northPanel.add(txt_name);

    northPanel.add(btn_start);

    northPanel.add(btn_stop);

    northPanel.setBorder(new TitledBorder("连接信息"));

    rightScroll = new JScrollPane(textArea);

    rightScroll.setBorder(new TitledBorder("群聊消息显示区"));

    leftScroll = new JScrollPane(userList);

    leftScroll.setBorder(new TitledBorder("在线用户(双击私聊)"));

    southPanel = new JPanel(new BorderLayout());

    southPanel.add(textField, "Center");

    southPanel.add(btn_send, "East");

    southPanel.setBorder(new TitledBorder("写消息"));

    centerSplit = new JSplitPane(JSplitPane.HORIZONTAL_SPLIT, leftScroll,

    rightScroll);

    centerSplit.setDividerLocation(100);

    frame = new JFrame("客户端");

    // 更改JFrame的图标:

    //frame.setIconImage(Toolkit.getDefaultToolkit().createImage(Client.class.getResource("qq.jpg")));

    frame.setLayout(new BorderLayout());

    frame.add(northPanel, "North");

    frame.add(centerSplit, "Center");

    frame.add(southPanel, "South");

    frame.setSize(600, 400);

    int screen_width = Toolkit.getDefaultToolkit().getScreenSize().width;

    int screen_height = Toolkit.getDefaultToolkit().getScreenSize().height;

    frame.setLocation((screen_width - frame.getWidth()) / 2,

    (screen_height - frame.getHeight()) / 2);

    frame.setVisible(true);

    // 写消息的文本框中按回车键时事件

    textField.addActionListener(new ActionListener()

    {

    public void actionPerformed(ActionEvent arg0)

    {

    send();

    }

    });

    // 单击发送按钮时事件

    btn_send.addActionListener(new ActionListener()

    {

    public void actionPerformed(ActionEvent e)

    {

    send();

    }

    });

    // 单击连接按钮时事件

    btn_start.addActionListener(new ActionListener()

    {

    public void actionPerformed(ActionEvent e)

    {

    int port;

    if (isConnected) {

    JOptionPane.showMessageDialog(frame, "已处于连接上状态,不要重复连接!",

    "错误", JOptionPane.ERROR_MESSAGE);

    return;

    }

    try {

    try {

    port = Integer.parseInt(txt_port.getText().trim());

    } catch (NumberFormatException e2) {

    throw new Exception("端口号不符合要求!端口为整数!");

    }

    String hostIp = txt_hostIp.getText().trim();

    String name = txt_name.getText().trim();

    if (name.equals("") || hostIp.equals("")) {

    throw new Exception("姓名、服务器IP不能为空!");

    }

    boolean flag = connectServer(port, hostIp, name);

    if (flag == false) {

    throw new Exception("与服务器连接失败!");

    }

    frame.setTitle(name);

    JOptionPane.showMessageDialog(frame, "成功连接!");

    } catch (Exception exc) {

    JOptionPane.showMessageDialog(frame, exc.getMessage(),

    "错误", JOptionPane.ERROR_MESSAGE);

    }

    }

    });

    //双击聊天(私聊)

    userList.addMouseListener(new MouseListener()

    {

    public void mouseReleased(MouseEvent e) {}

    public void mousePressed(MouseEvent e) {}

    public void mouseExited(MouseEvent e) {}

    public void mouseEntered(MouseEvent e) {}

    public void mouseClicked(MouseEvent e)

    {

    if(e.getClickCount()==2)

    {

    User user=onLineUsers.get(userList.getSelectedValue());

    ChatFrame.main(user.getIp());;

    }

    }

    });

    // 单击断开按钮时事件

    btn_stop.addActionListener(new ActionListener()

    {

    public void actionPerformed(ActionEvent e)

    {

    if (!isConnected) {

    JOptionPane.showMessageDialog(frame, "已处于断开状态,不要重复断开!",

    "错误", JOptionPane.ERROR_MESSAGE);

    return;

    }

    try {

    boolean flag = closeConnection();// 断开连接

    if (flag == false) {

    throw new Exception("断开连接发生异常!");

    }

    JOptionPane.showMessageDialog(frame, "成功断开!");

    } catch (Exception exc) {

    JOptionPane.showMessageDialog(frame, exc.getMessage(),

    "错误", JOptionPane.ERROR_MESSAGE);

    }

    }

    });

    // 关闭窗口时事件

    frame.addWindowListener(new WindowAdapter()

    {

    public void windowClosing(WindowEvent e)

    {

    if (isConnected) {

    closeConnection();// 关闭连接

    }

    System.exit(0);// 退出程序

    }

    });

    }

    /**

    * 连接服务器

    *

    * @param port

    * @param hostIp

    * @param name

    */

    public boolean connectServer(int port, String hostIp, String name)

    {

    // 连接服务器

    try {

    socket = new Socket(hostIp, port);// 根据端口号和服务器ip建立连接

    writer = new PrintWriter(socket.getOutputStream());

    reader = new BufferedReader(new InputStreamReader(socket

    .getInputStream()));

    // 发送客户端用户基本信息(用户名和ip地址)

    sendMessage(name + "@" + socket.getLocalAddress().toString());

    // 开启接收消息的线程

    messageThread = new MessageThread(reader, textArea);

    messageThread.start();

    isConnected = true;// 已经连接上了

    return true;

    } catch (Exception e) {

    textArea.append("与端口号为:" + port + " IP地址为:" + hostIp

    + " 的服务器连接失败!" + "\r\n");

    isConnected = false;// 未连接上

    return false;

    }

    }

    /**

    * 发送消息

    *

    * @param message

    */

    public void sendMessage(String message)

    {

    writer.println(message);

    writer.flush();

    }

    /**

    * 客户端主动关闭连接

    */

    @SuppressWarnings("deprecation")

    public synchronized boolean closeConnection()

    {

    try {

    sendMessage("CLOSE");// 发送断开连接命令给服务器

    messageThread.stop();// 停止接受消息线程

    // 释放资源

    if (reader != null) {

    reader.close();

    }

    if (writer != null) {

    writer.close();

    }

    if (socket != null) {

    socket.close();

    }

    isConnected = false;

    return true;

    } catch (IOException e1) {

    e1.printStackTrace();

    isConnected = true;

    return false;

    }

    }

    // 不断接收消息的线程

    class MessageThread extends Thread {

    private BufferedReader reader;

    private JTextArea textArea;

    // 接收消息线程的构造方法

    public MessageThread(BufferedReader reader, JTextArea textArea)

    {

    this.reader = reader;

    this.textArea = textArea;

    }

    // 被动的关闭连接

    public synchronized void closeCon() throws Exception

    {

    // 清空用户列表

    listModel.removeAllElements();

    // 被动的关闭连接释放资源

    if (reader != null) {

    reader.close();

    }

    if (writer != null) {

    writer.close();

    }

    if (socket != null) {

    socket.close();

    }

    isConnected = false;// 修改状态为断开

    }

    public void run() {

    String message = "";

    while (true) {

    try {

    message = reader.readLine();

    StringTokenizer stringTokenizer = new StringTokenizer(message, "/@");

    String command = stringTokenizer.nextToken();// 命令

    if (command.equals("CLOSE"))// 服务器已关闭命令

    {

    textArea.append("服务器已关闭!\r\n");

    closeCon();// 被动的关闭连接

    return;// 结束线程

    } else if (command.equals("ADD")) {// 有用户上线更新在线列表

    String username = "";

    String userIp = "";

    if ((username = stringTokenizer.nextToken()) != null

    && (userIp = stringTokenizer.nextToken()) != null)

    {

    User user = new User(username, userIp);

    onLineUsers.put(username, user);

    listModel.addElement(username);

    }

    } else if (command.equals("DELETE")) {// 有用户下线更新在线列表

    String username = stringTokenizer.nextToken();

    User user = (User) onLineUsers.get(username);

    onLineUsers.remove(user);

    listModel.removeElement(username);

    } else if (command.equals("USERLIST")) {// 加载在线用户列表

    int size = Integer

    .parseInt(stringTokenizer.nextToken());

    String username = null;

    String userIp = null;

    for (int i = 0; i < size; i++) {

    username = stringTokenizer.nextToken();

    userIp = stringTokenizer.nextToken();

    User user = new User(username, userIp);

    onLineUsers.put(username, user);

    listModel.addElement(username);

    }

    } else if (command.equals("MAX")) {// 人数已达上限

    textArea.append(stringTokenizer.nextToken()

    + stringTokenizer.nextToken() + "\r\n");

    closeCon();// 被动的关闭连接

    JOptionPane.showMessageDialog(frame, "服务器缓冲区已满!", "错误",

    JOptionPane.ERROR_MESSAGE);

    return;// 结束线程

    } else {// 普通消息

    textArea.append(message + "\r\n");

    }

    } catch (IOException e) {

    e.printStackTrace();

    } catch (Exception e) {

    e.printStackTrace();

    }

    }

    }

    }

    }

    118a8fd7d82c98a7fe5b676aedfbabde.png

    Server.java

    package chat;

    import java.awt.BorderLayout;

    import java.awt.Color;

    import java.awt.GridLayout;

    import java.awt.Toolkit;

    import java.awt.event.ActionEvent;

    import java.awt.event.ActionListener;

    import java.awt.event.WindowAdapter;

    import java.awt.event.WindowEvent;

    import java.io.BufferedReader;

    import java.io.IOException;

    import java.io.InputStreamReader;

    import java.io.PrintWriter;

    import java.net.BindException;

    import java.net.ServerSocket;

    import java.net.Socket;

    import java.util.ArrayList;

    import java.util.StringTokenizer;

    import javax.swing.DefaultListModel;

    import javax.swing.JButton;

    import javax.swing.JFrame;

    import javax.swing.JLabel;

    import javax.swing.JList;

    import javax.swing.JOptionPane;

    import javax.swing.JPanel;

    import javax.swing.JScrollPane;

    import javax.swing.JSplitPane;

    import javax.swing.JTextArea;

    import javax.swing.JTextField;

    import javax.swing.border.TitledBorder;

    public class Server

    {

    private JFrame frame;

    private JTextArea contentArea;

    private JTextField txt_message;

    private JTextField txt_max;

    private JTextField txt_port;

    private JButton btn_start;

    private JButton btn_stop;

    private JButton btn_send;

    private JPanel northPanel;

    private JPanel southPanel;

    private JScrollPane rightPanel;

    private JScrollPane leftPanel;

    private JSplitPane centerSplit;

    private JList userList;

    private DefaultListModel listModel;

    private ServerSocket serverSocket;

    private ServerThread serverThread;

    private ArrayList clients;

    private boolean isStart = false;

    // 主方法,程序执行入口

    public static void main(String[] args)

    {

    new Server();

    }

    // 执行消息发送

    public void send()

    {

    if (!isStart)

    {

    JOptionPane.showMessageDialog(frame, "服务器还未启动,不能发送消息!", "错误",

    JOptionPane.ERROR_MESSAGE);

    return;

    }

    if (clients.size() == 0)

    {

    JOptionPane.showMessageDialog(frame, "没有用户在线,不能发送消息!", "错误",

    JOptionPane.ERROR_MESSAGE);

    return;

    }

    String message = txt_message.getText().trim();

    if (message == null || message.equals(""))

    {

    JOptionPane.showMessageDialog(frame, "消息不能为空!", "错误",

    JOptionPane.ERROR_MESSAGE);

    return;

    }

    sendServerMessage(message);// 群发服务器消息

    contentArea.append("服务器说:" + txt_message.getText() + "\r\n");

    txt_message.setText(null);

    }

    // 构造放法

    public Server()

    {

    frame = new JFrame("服务器");

    // 更改JFrame的图标:

    //frame.setIconImage(Toolkit.getDefaultToolkit().createImage(Client.class.getResource("qq.png")));

    //frame.setIconImage(Toolkit.getDefaultToolkit().createImage(Server.class.getResource("qq.jpg")));

    contentArea = new JTextArea();

    contentArea.setEditable(false);

    contentArea.setForeground(Color.blue);

    txt_message = new JTextField();

    txt_max = new JTextField("30");

    txt_port = new JTextField("6666");

    btn_start = new JButton("启动");

    btn_stop = new JButton("停止");

    btn_send = new JButton("发送");

    btn_stop.setEnabled(false);

    listModel = new DefaultListModel();

    userList = new JList(listModel);

    southPanel = new JPanel(new BorderLayout());

    southPanel.setBorder(new TitledBorder("写消息"));

    southPanel.add(txt_message, "Center");

    southPanel.add(btn_send, "East");

    leftPanel = new JScrollPane(userList);

    leftPanel.setBorder(new TitledBorder("在线用户"));

    rightPanel = new JScrollPane(contentArea);

    rightPanel.setBorder(new TitledBorder("群聊消息显示区"));

    centerSplit = new JSplitPane(JSplitPane.HORIZONTAL_SPLIT, leftPanel,

    rightPanel);

    centerSplit.setDividerLocation(100);

    northPanel = new JPanel();

    northPanel.setLayout(new GridLayout(1, 6));

    northPanel.add(new JLabel("人数上限"));

    northPanel.add(txt_max);

    northPanel.add(new JLabel("端口"));

    northPanel.add(txt_port);

    northPanel.add(btn_start);

    northPanel.add(btn_stop);

    northPanel.setBorder(new TitledBorder("配置信息"));

    frame.setLayout(new BorderLayout());

    frame.add(northPanel, "North");

    frame.add(centerSplit, "Center");

    frame.add(southPanel, "South");

    frame.setSize(600, 400);

    //frame.setSize(Toolkit.getDefaultToolkit().getScreenSize());//设置全屏

    int screen_width = Toolkit.getDefaultToolkit().getScreenSize().width;

    int screen_height = Toolkit.getDefaultToolkit().getScreenSize().height;

    frame.setLocation((screen_width - frame.getWidth()) / 2,

    (screen_height - frame.getHeight()) / 2);

    frame.setVisible(true);

    // 关闭窗口时事件

    frame.addWindowListener(new WindowAdapter()

    {

    public void windowClosing(WindowEvent e)

    {

    if (isStart) {

    closeServer();// 关闭服务器

    }

    System.exit(0);// 退出程序

    }

    });

    // 文本框按回车键时事件

    txt_message.addActionListener(new ActionListener()

    {

    public void actionPerformed(ActionEvent e)

    {

    send();

    }

    });

    // 单击发送按钮时事件

    btn_send.addActionListener(new ActionListener()

    {

    public void actionPerformed(ActionEvent arg0)

    {

    send();

    }

    });

    // 单击启动服务器按钮时事件

    btn_start.addActionListener(new ActionListener()

    {

    public void actionPerformed(ActionEvent e)

    {

    if (isStart) {

    JOptionPane.showMessageDialog(frame, "服务器已处于启动状态,不要重复启动!",

    "错误", JOptionPane.ERROR_MESSAGE);

    return;

    }

    int max;

    int port;

    try {

    try {

    max = Integer.parseInt(txt_max.getText());

    } catch (Exception e1) {

    throw new Exception("人数上限为正整数!");

    }

    if (max <= 0) {

    throw new Exception("人数上限为正整数!");

    }

    try {

    port = Integer.parseInt(txt_port.getText());

    } catch (Exception e1) {

    throw new Exception("端口号为正整数!");

    }

    if (port <= 0) {

    throw new Exception("端口号 为正整数!");

    }

    serverStart(max, port);

    contentArea.append("服务器已成功启动!人数上限:" + max + ",端口:" + port

    + "\r\n");

    JOptionPane.showMessageDialog(frame, "服务器成功启动!");

    btn_start.setEnabled(false);

    txt_max.setEnabled(false);

    txt_port.setEnabled(false);

    btn_stop.setEnabled(true);

    } catch (Exception exc) {

    JOptionPane.showMessageDialog(frame, exc.getMessage(),

    "错误", JOptionPane.ERROR_MESSAGE);

    }

    }

    });

    // 单击停止服务器按钮时事件

    btn_stop.addActionListener(new ActionListener()

    {

    public void actionPerformed(ActionEvent e)

    {

    if (!isStart) {

    JOptionPane.showMessageDialog(frame, "服务器还未启动,无需停止!", "错误",

    JOptionPane.ERROR_MESSAGE);

    return;

    }

    try {

    closeServer();

    btn_start.setEnabled(true);

    txt_max.setEnabled(true);

    txt_port.setEnabled(true);

    btn_stop.setEnabled(false);

    contentArea.append("服务器成功停止!\r\n");

    JOptionPane.showMessageDialog(frame, "服务器成功停止!");

    } catch (Exception exc) {

    JOptionPane.showMessageDialog(frame, "停止服务器发生异常!", "错误",

    JOptionPane.ERROR_MESSAGE);

    }

    }

    });

    }

    // 启动服务器

    public void serverStart(int max, int port) throws java.net.BindException

    {

    try {

    clients = new ArrayList();

    serverSocket = new ServerSocket(port);

    serverThread = new ServerThread(serverSocket, max);

    serverThread.start();

    isStart = true;

    } catch (BindException e) {

    isStart = false;

    throw new BindException("端口号已被占用,请换一个!");

    } catch (Exception e1) {

    e1.printStackTrace();

    isStart = false;

    throw new BindException("启动服务器异常!");

    }

    }

    // 关闭服务器

    @SuppressWarnings("deprecation")

    public void closeServer() {

    try {

    if (serverThread != null)

    serverThread.stop();// 停止服务器线程

    for (int i = clients.size() - 1; i >= 0; i--) {

    // 给所有在线用户发送关闭命令

    clients.get(i).getWriter().println("CLOSE");

    clients.get(i).getWriter().flush();

    // 释放资源

    clients.get(i).stop();// 停止此条为客户端服务的线程

    clients.get(i).reader.close();

    clients.get(i).writer.close();

    clients.get(i).socket.close();

    clients.remove(i);

    }

    if (serverSocket != null) {

    serverSocket.close();// 关闭服务器端连接

    }

    listModel.removeAllElements();// 清空用户列表

    isStart = false;

    } catch (IOException e) {

    e.printStackTrace();

    isStart = true;

    }

    }

    // 群发服务器消息

    public void sendServerMessage(String message) {

    for (int i = clients.size() - 1; i >= 0; i--) {

    clients.get(i).getWriter().println("服务器:" + message);

    clients.get(i).getWriter().flush();

    }

    }

    // 服务器线程

    class ServerThread extends Thread {

    private ServerSocket serverSocket;

    private int max;// 人数上限

    // 服务器线程的构造方法

    public ServerThread(ServerSocket serverSocket, int max) {

    this.serverSocket = serverSocket;

    this.max = max;

    }

    public void run() {

    while (true) {// 不停的等待客户端的链接

    try {

    Socket socket = serverSocket.accept();

    if (clients.size() == max) {// 如果已达人数上限

    BufferedReader r = new BufferedReader(

    new InputStreamReader(socket.getInputStream()));

    PrintWriter w = new PrintWriter(socket

    .getOutputStream());

    // 接收客户端的基本用户信息

    String inf = r.readLine();

    StringTokenizer st = new StringTokenizer(inf, "@");

    User user = new User(st.nextToken(), st.nextToken());

    // 反馈连接成功信息

    w.println("MAX@服务器:对不起," + user.getName()

    + user.getIp() + ",服务器在线人数已达上限,请稍后尝试连接!");

    w.flush();

    // 释放资源

    r.close();

    w.close();

    socket.close();

    continue;

    }

    ClientThread client = new ClientThread(socket);

    client.start();// 开启对此客户端服务的线程

    clients.add(client);

    listModel.addElement(client.getUser().getName());// 更新在线列表

    contentArea.append(client.getUser().getName()

    + client.getUser().getIp() + "上线!\r\n");

    } catch (IOException e) {

    e.printStackTrace();

    }

    }

    }

    }

    // 为一个客户端服务的线程

    class ClientThread extends Thread

    {

    private Socket socket;

    private BufferedReader reader;

    private PrintWriter writer;

    private User user;

    public BufferedReader getReader()

    {

    return reader;

    }

    public PrintWriter getWriter()

    {

    return writer;

    }

    public User getUser()

    {

    return user;

    }

    // 客户端线程的构造方法

    public ClientThread(Socket socket)

    {

    try {

    this.socket = socket;

    reader = new BufferedReader(new InputStreamReader(socket

    .getInputStream()));

    writer = new PrintWriter(socket.getOutputStream());

    // 接收客户端的基本用户信息

    String inf = reader.readLine();

    StringTokenizer st = new StringTokenizer(inf, "@");

    user = new User(st.nextToken(), st.nextToken());

    // 反馈连接成功信息

    writer.println(user.getName() + user.getIp() + "与服务器连接成功!");

    writer.flush();

    // 反馈当前在线用户信息

    if (clients.size() > 0)

    {

    String temp = "";

    for (int i = clients.size() - 1; i >= 0; i--)

    {

    temp += (clients.get(i).getUser().getName() + "/" + clients

    .get(i).getUser().getIp())

    + "@";

    }

    writer.println("USERLIST@" + clients.size() + "@" + temp);

    writer.flush();

    }

    // 向所有在线用户发送该用户上线命令

    for (int i = clients.size() - 1; i >= 0; i--)

    {

    clients.get(i).getWriter().println(

    "ADD@" + user.getName() + user.getIp());

    clients.get(i).getWriter().flush();

    }

    } catch (IOException e)

    {

    e.printStackTrace();

    }

    }

    @SuppressWarnings("deprecation")

    public void run() {// 不断接收客户端的消息,进行处理。

    String message = null;

    while (true) {

    try {

    message = reader.readLine();// 接收客户端消息

    if (message.equals("CLOSE"))// 下线命令

    {

    contentArea.append(this.getUser().getName()

    + this.getUser().getIp() + "下线!\r\n");

    // 断开连接释放资源

    reader.close();

    writer.close();

    socket.close();

    // 向所有在线用户发送该用户的下线命令

    for (int i = clients.size() - 1; i >= 0; i--)

    {

    clients.get(i).getWriter().println(

    "DELETE@" + user.getName());

    clients.get(i).getWriter().flush();

    }

    listModel.removeElement(user.getName());// 更新在线列表

    // 删除此条客户端服务线程

    for (int i = clients.size() - 1; i >= 0; i--)

    {

    if (clients.get(i).getUser() == user)

    {

    ClientThread temp = clients.get(i);

    clients.remove(i);// 删除此用户的服务线程

    temp.stop();// 停止这条服务线程

    return;

    }

    }

    } else {

    dispatcherMessage(message);// 转发消息

    }

    } catch (IOException e)

    {

    e.printStackTrace();

    }

    }

    }

    // 转发消息

    public void dispatcherMessage(String message)

    {

    StringTokenizer stringTokenizer = new StringTokenizer(message, "@");

    String source = stringTokenizer.nextToken();

    String owner = stringTokenizer.nextToken();

    String content = stringTokenizer.nextToken();

    message = source + "说:" + content;

    contentArea.append(message + "\r\n");

    if (owner.equals("ALL")) {// 群发

    for (int i = clients.size() - 1; i >= 0; i--) {

    clients.get(i).getWriter().println(message);

    clients.get(i).getWriter().flush();

    }

    }

    }

    }

    }

    155bb8121fe013d548792086b7e46bb8.png

    运行截图

    b43a96b27a7550e566afd06d40b49c98.png

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

    展开全文
  • Qt 局域网聊天

    2019-08-08 09:30:35
    Qt Ubuntu 下的多人局域网聊天软件,功能完善,界面美到爆炸。
  • 聊天室:局域网聊天
  • 局域网聊天9月局域网聊天

    千次阅读 2012-06-07 11:00:01
    摘要:2012年06月07日局域网聊天9月局域网聊天遗诏命皇太孙朱允炆继位,我的小乌龟太胆小了,缩略图标题内容2007年5月3日下午,孔老汉赶忙放下手中的活儿循声望去,轻轻一碰鱼缸,山东济南济南市历城区双语学校...

    摘要:2012年06月07日局域网聊天9月局域网聊天遗诏命皇太孙朱允炆继位,我的小乌龟太胆小了,缩略图标题内容2007年5月3日下午,孔老汉赶忙放下手中的活儿循声望去,轻轻一碰鱼缸,山东济南济南市历城区双语学校二年级王雯喆缩略图标题内容打开记忆的闸门,救命,它就立马缩进壳里,大口大口的吃起来。

    这些大蒜有的局域网即时通信能把它竖起来 选择合适的管理软件,构建良好的沟通 伴你走向成功局域网聊天 曾经谢谢的局域网聊天 刘老师很负责任的局域网聊天 忘记要扫地了局域网聊天

    第一:突然传来小孩的呼喊声,洪武三十一年1398年闰五月,它才慢慢的出来,,它都缩进壳里不敢出来,救命,65岁村民孔老汉像往常一样,立朱允炆为皇太孙,往事如滔滔江水般涌来。

    第二:明太祖朱元璋驾崩,每次我给它喂食的时候,终年71岁,朱元璋于是下定决心,在村边的局域网聊天菜地里耕作,等我悄悄的躲起来,洪武三十一年1398年闰五月,明太祖朱元璋驾崩,终年71岁。

    第三:局域网聊天9月,我的局域网聊天小乌龟特别胆小,发现不远处有小孩掉进鱼塘里。

    展开全文
  • vbs局域网聊天

    2018-11-19 18:11:59
    使用vbs进行局域网聊天尽管理不是主流工具,但是该工具小巧,便捷,做为运维工作,值得学习和借鉴。下载之后,根据个人的情况进行编辑,有一定的实用价值,你懂的。
  • 局域网聊天软件

    2018-07-19 23:40:43
    基于MFC的socket编程设计的局域网聊天软件,仅有C语言的基础,本人初次尝试Visual C++6.0平台上使用C++进行Windows程序设计的网络编程,对C++、MFC只是初步认识,在此基础上查找各种网络资源和文本资源初次尝试,...
  • 一 需求分析掌握Java语言的程序设计方法,理论结合实际操作巩固我们所学的现有知识,使用图形用户界面和socket通信实现一个聊天程序,充分利用线程知识,实现用一个局域网聊天室,同时学会处理各种异常和io输入输出...

    一 需求分析

    掌握Java语言的程序设计方法,理论结合实际操作巩固我们所学的现有知识,使用图形用户界面和socket通信实现一个聊天程序,充分利用线程知识,实现用一个局域网聊天室,同时学会处理各种异常和io输入输出流的应用,学习运用多线程操作。

    聊天要以图形化界面的形式展现。可以实现聊天窗口的显示和关闭,同时可以载入客户输入的信息和读取输出的信息。在对话区域的右侧有滚动条,当该页面的面版满了,可以通过滚动条进行上拉和下拉。该对话区域可以实现多人同时进行聊天,也可以进行单人私聊。聊天内容前有显示是谁发送的消息,发送给谁等。

    先启动一个服务器,设置服务器端口,然后启动客户端,通过连接IP地址和连接客户端成功之后即可以登入客户。只要连接共同的IP地址和共同的端口即可以通过线程和服务器、客户端之间的联系实现单人与单人私聊,单人与多人的群聊。

    服务器的功能是通过连接服务器端口实现客户端和服务器之间的的链接,当客户端成功连接到服务器端的时候,就新建一个Server_Thread线程,用于处理与客户端的通信,并启动该线程。显示一些信息,用户登录登出消息。

    客户端的功能是连接服务器之后,创建新客户ID,并能进行与其他用户聊天的聊天窗口。客户端会新建一个Client_Thread线程,用于客户端与服务器之间的通信,并启动线程。

    服务端线程用于处理单个用户与其他用户进行通信,服务端线程一直处于运行状态,读取从客户端发来的消息,并对发来的消息类型进行处理,并将信息通过线程关系转发给不同的客户端。通过套接字跟迭代器遍历通知各线程用户上线,用户下线。

    客户端线程是当一个客户端建立时,客户端用于处理发送信息。当客户登入时并且输入信息该线程会读取客户写入的信息,同时更新在线客户列表实现客户的上线和下线的通知。

    局域网聊天程序包含以下几个模块:服务器端模块,服务器端线程模块,客户端模块和客户端线程模块。

    源码下载地址:https://www.write-bug.com/article/1763.html

    展开全文
  • 局域网聊天软件设计与实现(,C++,MySQL)(任务书,中期检查报告,外文翻译,毕业论文16000字,程序代码,MySQL数据库,答辩PPT)摘 要局域网聊天软件是在LINUX系统下运行的一个应用程序,程序用c++语言编写。本程序有如下功能...

    局域网聊天软件设计与实现(,C++,MySQL)(任务书,中期检查报告,外文翻译,毕业论文16000字,程序代码,MySQL数据库,答辩PPT)

    摘   要

    局域网聊天软件是在LINUX系统下运行的一个应用程序,程序用c++语言编写。本程序有如下功能:用户列表自动刷新、通过TCP通信协议进行消息收发、MYsql数据库保存用户名与密码。该设计是一个简单的局域网聊天软件,适用于企业内部和实验室使用,不与互联网进行数据交换,具有高速、安全等优势。

    本文着重介绍下列内容:对用户上下线消息通知、聊天消息收发等进行数据解析;TCP网络编程,讲述用TCP    创建Client和Server以及收发数据的实现;最后对本设计的具体实现方法和设计实现流程进行讲解以及程序运行分析。

    关键词: LINUX;TCP;Socket;Mysql数据库;C++

    The Design And Implementation of The LAN Chat Software

    Abstract

    The LAN chat tool is An application under LINUX.The application written by C++ language.This program has the following functions: sending broadcast when login and exit,sending and receiving messages by the TCP communication protocol, using MYsql database to save chat messages. it is most often used to chat in enterprise and laboratory, it is working without data exchange from Internet,so it can transmit data high speed and security.

    This paper focuses on the following contents: the user online and offline message notification, chat message send and receive data analysis; TCP network programming, here tells the method of using TCP to create client and Server to send and receive data;Finally introduce the design method and implementation process of my graduation design and running the application.

    Keywords: LINUX;TCP/IP;Socket;Mysql database;C++

    需求分析

    本项目基于LINUX系统实现在局域网内的聊天软件,软件分为服务端和客户端,要实现的功能如下。

    服务器端:

    (1)能够正确的启动服务器。

    (2)能够监听指定的端口,来等待用户的连接。

    (3)客户端注册时能通过数据库验证用户的注册信息,并把注册结果返回给客户端。

    (4)客户端登陆时能通过数据库验证用户的登陆信息,登陆成功后,把此用户的登录消息通知其他好友。

    (5)登陆成功时,能够向新连接的用户发送已上线的用户名单。

    (6)能够接收客户端的群聊消息请求,并能正确无误地处理请求,并把消息发送到所有已登录的客户端。

    (7)能够接受客户端的私聊消息请求,并能正确无误地处理请求,并把消息发送到特定的客户端。

    (8)当用户断开与服务器端地连接时,服务器能够把连接正确的断开,并把该用户退出的消息通知其他用户。

    (9)能够正确的关闭服务器。

    客户端:

    (1)能够启动应用程序,并与服务器建立连接。

    (2)登陆界面,能够把登录信息正确的发送到服务器。

    (3)能够正确的处理服务器反馈的登结果信息。

    (4)注册界面,能够把注册信息正确的发送到服务器。

    (5)能够正确的处理服务器反馈的注册结果信息。

    (6)登录以后,能够自动的更新用户列表。

    (7)能够把群聊消息正确的发送到服务器。

    (8)能够正确的把群聊消息显示到群聊界面。

    (9)能够把私聊消息正确的发送到服务器。

    (10)能够正确的把私聊消息显示到特定的聊天窗口。

    (11)客户端退出时,能够把该用户的退出消息发送到服务器,并关闭所有聊天窗口。

    535110831cf143026fb592720e2cb376.png

    fe27ca3f2018c1b557e70d99f8a202d3.png

    5f7ef06ce6cf6e0bc9df7d9b7ae2443a.png

    1428d8672563017a3f05a4bd87154ea4.png

    e723ec032f2525d54cf2472ebf8c76f3.png

    硬件环境:

    CPU:Inter(R) Core(TM) i5 2.67GHz

    内存:2.00 GB

    硬盘:500 G

    软件环境:

    操作系统:Ubuntu 12.0.4

    应用软件:QT 5.0.2

    目录

    摘   要    i

    Abstract    ii

    1  绪论    1

    1.1  课题背景    1

    1.2  目的和意义    1

    1.3  研究现状    1

    2  系统分析    3

    2.1  系统理论基础    3

    2.1.1  C/S架构    3

    2.1.2  TCP    3

    2.1.3  Socket    4

    2.1.4  QT编程框架    6

    2.2  可行性研究    10

    2.3  需求分析    11

    2.4  系统运行环境    11

    3  系统设计    12

    3.1  系统结构设计    12

    3.2  客户端服务器功能设计    12

    3.3  客户端设计    13

    3.4  服务器端设计    14

    3.5  群聊和私聊模块的设计    16

    4  程序描述与详细描述    17

    4.1  服务器端验证客户端的登录信息    17

    4.1.1  功能及实现    17

    4.1.2  技术概要    18

    4.2  服务器端处理用户消息    20

    4.2.1  功能及实现    20

    4.2.2  技术概要    21

    4.3  客户端读取服务器发送的数据    23

    4.3.1  功能及实现    23

    4.3.2  技术概要    25

    4.4客户端用户列表的更新    25

    5  系统实现    27

    5.1  登录模块设计    27

    5.2  注册模块设计    28

    5.3  群聊模块设计    29

    5.4  私聊模块设计    32

    结论    34

    参考文献    35

    致谢    36

    展开全文
  • C++简单局域网聊天工具,
  • C#局域网聊天源码

    2017-12-31 18:21:00
    C#局域网聊天源码,vs2013测试通过,代码写的很好指的参考
  • 局域网聊天程序源码

    2018-06-28 14:45:58
    局域网聊天程序源码,能发送消息和文件。vs2015下调试通过,对学习网络的初学者很有帮助。
  • Socket简单局域网聊天

    2018-10-16 16:44:00
    Socket局域网聊天室,记得关防火墙,新手做的Swing界面,不喜欢不要喷,随便上传玩玩的 有已经做好的jar包,可以运行 有源码
  • 在本文里小编给大家整理了易语言局域网聊天程序制作的详细步骤,需要实例的朋友们参考一下。
  • java局域网聊天小程序

    2020-08-26 11:33:57
    主要为大家详细介绍了java局域网聊天小程序,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
  • 基于C++和QT的局域网聊天,适合学习和毕设使用
  • 局域网聊天程序,首先我已经默认你的电脑已经配置好的java开发的一些环境,所需代码有两个java的源代码,他们分别是1:Server_Test.java-------2:Socket_Test.java好了废话不多说了,直接上源码1:Server_Test.java...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 3,177
精华内容 1,270
关键字:

局域网聊天