java实现在线聊天系统

本文实例为大家分享了java实现在线聊天系统的具体代码,供大家参考,具体内容如下

本博客是博主在观看相关视频后写下的代码,希望能够帮助大家掌握java socket的相关知识。

  • 原理介绍
  • 代码展示

原理介绍

一、搭建服务器端

a)、创建ServerSocket对象绑定监听端口。
b)、通过accept()方法监听客户端的请求。
c)、建立连接后,通过输入输出流读取客户端发送的请求信息。
d)、通过输出流向客户端发送请求信息。
e)、关闭相关资源。

二、搭建客户器端

a)、创建Socket对象,指明需要连接的服务器的地址和端口。
b)、建立连接后,通过输出流向服务器发送请求信息。
c)、通过输入流获取服务器的响应信息。
d)、关闭响应资源

代码展示

服务器端代码:

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;

/**
 * 版本三:转发给其他的客户端 1.保存每一个客户端的连接
 *
 */
public class ChatSeverEdition3 {
    // 服务器端是否启动
    boolean started = false;
    ServerSocket serverSocket = null;
    ArrayList<Client> clients = new ArrayList<Client>();

    public static void main(String[] args) {

        new ChatSeverEdition3().start();
    }

    public void start() {

        try {
            serverSocket = new ServerSocket(8888);
            started = true;
        } catch (BindException e) {
            // 多次启动服务器
            System.out.println("端口使用中。。。。");
            System.out.println("请关掉相关程序,并重新运行服务器!");
            System.exit(0);
        } catch (IOException e) {
            e.printStackTrace();
        }

        try {

            while (started) {
                // 客户端是否连接
                Socket socket = serverSocket.accept();
                // main()方法是static方法,不能在其中new动态类Client
                Client client = new Client(socket);
                // 线程启动
                new Thread(client).start();
                // 将当前启动的客户端保存下来
                clients.add(client);
                System.out.println("new Client成功!");
                System.out.println("A Client connected!");

            }

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 
     * 
     *
     */
    class Client implements Runnable {
        private Socket s;
        private DataInputStream dis = null;
        private boolean bConnected = false;
        private DataOutputStream dos;

        public Client(Socket s) {
            this.s = s;

            try {
                dis = new DataInputStream(s.getInputStream());
                dos = new DataOutputStream(s.getOutputStream());
                bConnected = true;
                System.out.println("有一个新的客户端程序在运行");
            } catch (IOException e) {
                e.printStackTrace();
            }
            // 一个客户端连接成功以后,一直在执行该while部分的代码,其他客户端无法连接
            /**
             * 解决方法: 1.异步解决方法:一直监听接收,其他在另外的地方执行 2.使用单独的线程: 线程:接受客户端连接
             * 另外的单独的线程:处理通讯
             */

        }

        public void sendString(String str) {
            try {
                dos.writeUTF(str);
            } catch (IOException e) {
                clients.remove(this);
                System.out.println("对方退出了!!!我从List中去掉了!!!");
            }
        }

        public void run() {
            Client client = null;
            // 注意这部分的包围关系
            try {
                while (bConnected) {
                    String string = dis.readUTF();
                    System.out.println(string);
                    for (int i = 0; i < clients.size(); i++) {
                        client = clients.get(i);
                        client.sendString(string);
                    }
                }
            } catch (EOFException e) {
                System.out.println("Client closed!");
            } catch (IOException e) {
                e.printStackTrace();
                System.exit(0);

            } finally {
                try {
                    if (dis != null) {
                        dis.close();
                    }
                    if (s != null) {
                        s.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

        }

    }
}

客户端代码:

import java.awt.BorderLayout;
import java.awt.Frame;
import java.awt.TextArea;
import java.awt.TextField;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;

/**
 * 可以和ChatServer版本三配套使用
 * 
 * @author Administrator
 *
 */
public class ChatClientEdition3 extends Frame {
    TextField tfText = new TextField();
    TextArea taContent = new TextArea();
    Socket socket = null;
    DataOutputStream dataOutputStream = null;
    DataInputStream dataInputStream = null;
    private boolean bConnected = false;

    public static void main(String[] args) {

        new ChatClientEdition3().launchFrame();
    }

    // 加载窗口
    public void launchFrame() {
        setLocation(400, 300);
        this.setSize(300, 300);
        this.setTitle("在线聊天时--Quiana");
        add(tfText, BorderLayout.SOUTH);
        add(taContent, BorderLayout.NORTH);
        pack();
        // 窗口关闭的时间监听
        this.addWindowListener(new WindowAdapter() {

            @Override
            public void windowClosing(WindowEvent e) {
                disconnect();
                System.exit(0);
            }

        });
        tfText.addActionListener(new TFListener());
        this.setVisible(true);
        connect();
        new Thread(new RecvThread()).start();
    }

    // 文字处理的时间监听
    private class TFListener implements ActionListener {
        // 敲击回车时,文字的变化事件
        @Override
        public void actionPerformed(ActionEvent arg0) {
            String s = tfText.getText().trim(); // 去掉两端的空格
            tfText.setText("");
            try {

                dataOutputStream.writeUTF(s);
                dataOutputStream.flush();
            } catch (IOException e) {
                e.printStackTrace();
            }

        }

    }

    // 连接到服务器
    public void connect() {
        try {
            // 连接到服务器
            socket = new Socket("127.0.0.1", 8888);
            bConnected = true;
            dataOutputStream = new DataOutputStream(socket.getOutputStream());
            dataInputStream = new DataInputStream(socket.getInputStream());
            System.out.println("连接到服务器!!!");
        } catch (BindException e) {
            e.printStackTrace();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 断开连接
    public void disconnect() {
        try {
            dataOutputStream.close();
            System.out.println("dataOutputStream成功关闭");
            socket.close();
            System.out.println("客户端socket成功关闭");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    private class RecvThread implements Runnable {

        public void run() {

            try {
                while (bConnected) {
                    String string = dataInputStream.readUTF();
                    if (taContent.getText().length() == 0) {
                        taContent.setText(string);
                    } else {
                        taContent.setText(taContent.getText() + "\n" + string);
                    }
                }
            } catch (SocketException e) {
                System.out.println("退出了,拜拜!");
            } catch (EOFException e) {
                System.out.println("退出了,拜拜!");
            } catch (IOException e) {
                e.printStackTrace();
            }

        }

    }

}

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

(0)

相关推荐

  • Java实现在线聊天室(层层递进)

    本文实例为大家分享了Java实现在线聊天室的具体代码,供大家参考,具体内容如下 - 本文讲述了从实现单个多个客户的收发信息(基础简易版),到各种实现代码的封装(oop版),实现群聊(群聊过渡版),到最后实现私聊(终极版)的过程- 本文内容是在初步学习网络编程时,练习强化记忆时的学习总结- 主要利用了TCP网络编程和多线程- 如有问题,欢迎指出 综合案例:在线聊天室 需求:使用TCP的Socket实现一个聊天室 服务器端:一个线程专门发送消息,一个线程专门接收消息 客户端:一个线程专门发送消息,一

  • Java中使用websocket实现在线聊天功能

    很早以前为了快速达到效果,使用轮询实现了在线聊天功能,后来无意接触了socket,关于socket我的理解是进程间通信,首先要有服务器跟客户端,服务的启动监听某ip端口定位该进程,客户端开启socket分配ip端口连接服务端ip端口,于是两个进程间便可以通信了.下面简单画个图理解. but,今天还是准备分享websocket的使用,先上效果,再贴代码. 第一步启动socket服务. 然后连接客户端连接服务器,加入聊天室,分别使用googel(白玉京,沈浪),火狐(楚留香),ie(李寻欢)进行测试

  • Java GUI编程实现在线聊天室

    引言 综合应用Java的GUI编程和网络编程,实现一个能够支持多组用户同时使用的聊天室软件.该聊天室具有比较友好的GUI界面,并使用C/S模式,支持多个用户同时使用,用户可以自己选择加入或者创建房间,和房间内的其他用户互发信息(文字和图片) 主要功能 客户端的功能主要包括如下的功能: 选择连上服务端 显示当前房间列表(包括房间号和房间名称) 选择房间进入 多个用户在线群聊 可以发送表情(用本地的,实际上发送只发送表情的代码) 退出房间 选择创建房间 房间里没人(房主退出),导致房间解散 显示系统

  • Java网络编程UDP实现多线程在线聊天

    本文实例为大家分享了Java实现多线程在线聊天的具体代码,供大家参考,具体内容如下 上一篇博客通过UDP实现了聊天,但只能单方面发送消息,这次实现了多线程在线聊天,也就是可以双方互发消息. 发送消息: package com.kuang.chat; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket;

  • java基于UDP实现在线聊天功能

    本文实例为大家分享了java基于UDP实现在线聊天的具体代码,供大家参考,具体内容如下 效果图: 一.学习UDP的简单使用步骤 接收端: DatagramSocket socket = null;         try {             //1.开启自己的端口(客户端连接的端口)             socket = new DatagramSocket(9999);             //2.接收数据             byte[] buffer = new byt

  • Java使用TCP实现在线聊天的示例代码

    客户端的代码: package tcp.http; import java.io.*; import java.net.*; import java.util.Scanner; public class Client{ public static void main(String[] args) throws IOException{ Scanner scanner=new Scanner(System.in); //1.创建Socket Socket tcpClientSocket=new S

  • Java实现在线聊天功能

    本文实例为大家分享了Java实现在线聊天功能的具体代码,供大家参考,具体内容如下 效果 关键代码 创建Client.java import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; /**  * @author Lete  * @乐特的程序永无BUG  * @createDate 2020- 07-04 22:13  *  * 1. SendThread 发送消息线程  *

  • Java网络编程实例——简单模拟在线聊天

    1.前提知识 需要知道简单的IO流操作,以及简单的UDP发送数据包的原理. 需要用到的类:DatagramSocket.DatagramPacket UDP数据包基于DatagramSocket发送和接收,DatagramPacket用于封装数据包 看下案例: 客户端发送消息: 正常情况下从控制台读信息,封装到DatagramPacket之中,再由DatagramSocket的send方法发出 读取到bye的时候退出聊天 public class UdpOnlineClient { public

  • 网页版在线聊天java Socket实现

    本文为大家分享了一个满足在线网页交流需求的实例,由于java Socket实现的网页版在线聊天功能,供大家参考,具体内容如下 实现步骤: 1.使用awt组件和socket实现简单的单客户端向服务端持续发送消息: 2.结合线程,实现多客户端连接服务端发送消息: 3.实现服务端转发客户端消息至所有客户端,同时在客户端显示: 4.把awt组件生成的窗口界面改成前端jsp或者html展示的界面,java socket实现的客户端改为前端技术实现. 这里首先实现第一步的简单功能,难点在于: 1.没有用过a

  • 基于Java Socket实现一个简易在线聊天功能(一)

    最近做了一个项目,其中有一个在线网页交流的需求,好久没写代码了,手都生疏了,于是先写demo练练手,分享到我们平台,以此做个记录,方便自己和大家使用. 先给大家说下实现步骤分这样几大步: 1.使用awt组件和socket实现简单的单客户端向服务端持续发送消息: 2.结合线程,实现多客户端连接服务端发送消息: 3.实现服务端转发客户端消息至所有客户端,同时在客户端显示: 4.把awt组件生成的窗口界面改成前端jsp或者html展示的界面,java socket实现的客户端改为前端技术实现. 这里首

随机推荐