本文实例为大家分享了java实现聊天室的具体代码,供大家参考,具体内容如下
聊天室界面:
源码:
public class ClientFrame extends Frame { private TextField textFieldContent = new TextField(); private TextArea textAreaContent = new TextArea(); private Socket socket = null; private OutputStream out = null; private DataOutputStream dos = null; private InputStream in = null; private DataInputStream dis = null; private boolean flag = false; /** * 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午9:19:51 功能:启动客户端程序 * * @param args */ public static void main(String[] args) { new ClientFrame().init(); } /** * 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午9:20:43 功能:对窗口进行初始化 */ private void init() { this.setSize(300, 300); setLocation(250, 150); setVisible(true); setTitle("WeChatRoom"); // 添加控件 this.add(textAreaContent); this.add(textFieldContent, BorderLayout.SOUTH); textAreaContent.setFocusable(false); pack(); // 关闭事件 addWindowListener(new WindowAdapter() { public void windowClosing(WindowEvent e) { System.out.println("用户试图关闭窗口"); disconnect(); System.exit(0); } }); // textFieldContent添加回车事件 textFieldContent.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { onClickEnter(); } }); // 建立连接 connect(); new Thread(new ReciveMessage()).start(); } private class ReciveMessage implements Runnable { @Override public void run() { flag = true; try { while (flag) { String message = dis.readUTF(); textAreaContent.append(message + "\n"); } } catch (EOFException e) { flag = false; System.out.println("客户端已关闭"); // e.printStackTrace(); } catch (SocketException e) { flag = false; System.out.println("客户端已关闭"); // e.printStackTrace(); } catch (IOException e) { flag = false; System.out.println("接受消息失败"); e.printStackTrace(); } } } /** * 功能:当点击回车时出发的事件 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午9:49:30 */ private void onClickEnter() { String message = textFieldContent.getText().trim(); if (message != null && !message.equals("")) { String time = new SimpleDateFormat("h:m:s").format(new Date()); textAreaContent.append(time + "\n" + message + "\n"); textFieldContent.setText(""); sendMessageToServer(message); } } /** * 功能:给服务器发送消息 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午10:13:48 * * @param message */ private void sendMessageToServer(String message) { try { dos.writeUTF(message); dos.flush(); } catch (IOException e) { System.out.println("发送消息失败"); e.printStackTrace(); } } /** * 功能:申请socket链接 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午10:00:38 */ private void connect() { try { socket = new Socket("localhost", 8888); out = socket.getOutputStream(); dos = new DataOutputStream(out); in = socket.getInputStream(); dis = new DataInputStream(in); } catch (UnknownHostException e) { System.out.println("申请链接失败"); e.printStackTrace(); } catch (IOException e) { System.out.println("申请链接失败"); e.printStackTrace(); } } /** * 功能:关闭流和链接 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午10:01:32 */ private void disconnect() { flag = false; if (dos != null) { try { dos.close(); } catch (IOException e) { System.out.println("dos关闭失败"); e.printStackTrace(); } } if (out != null) { try { out.close(); } catch (IOException e) { System.out.println("dos关闭失败"); e.printStackTrace(); } } if (socket != null) { try { socket.close(); } catch (IOException e) { System.out.println("socket关闭失败"); e.printStackTrace(); } ; } } }
package com.chat; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.EOFException; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.BindException; import java.net.ServerSocket; import java.net.Socket; import java.net.SocketException; import java.util.ArrayList; import java.util.List; public class ChatServer { private List<Client> clients = new ArrayList<>(); /** * 功能:启动ChatSever 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午10:26:41 * * @param args */ public static void main(String[] args) { new ChatServer().init(); } /** * 功能:对chatserver初始化 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午10:27:09 */ private void init() { System.out.println("服务器已开启"); // BindException ServerSocket ss = null; Socket socket = null; try { ss = new ServerSocket(8888); } catch (BindException e) { System.out.println("端口已被占用"); e.printStackTrace(); } catch (IOException e1) { e1.printStackTrace(); } try { Client client = null; while (true) { socket = ss.accept(); System.out.println("客户驾到"); client = new Client(socket); clients.add(client); new Thread(client).start(); } } catch (IOException e) { e.printStackTrace(); } } private class Client implements Runnable { private Socket socket = null; InputStream in = null; DataInputStream din = null; OutputStream out = null; DataOutputStream dos = null; boolean flag = true; public Client(Socket socket) { this.socket = socket; try { in = socket.getInputStream(); din = new DataInputStream(in); } catch (IOException e) { System.out.println("接受消息失败"); e.printStackTrace(); } } public void run() { String message; try { while (flag) { message = din.readUTF(); // System.out.println("客户说:" + message); forwordToAllClients(message); } } catch (SocketException e) { flag = false; System.out.println("客户下线"); clients.remove(this); // e.printStackTrace(); } catch (EOFException e) { flag = false; System.out.println("客户下线"); clients.remove(this); // e.printStackTrace(); } catch (IOException e) { flag = false; System.out.println("接受消息失败"); clients.remove(this); e.printStackTrace(); } if (din != null) { try { din.close(); } catch (IOException e) { System.out.println("din关闭失败"); e.printStackTrace(); } } if (in != null) { try { in.close(); } catch (IOException e) { System.out.println("din关闭失败"); e.printStackTrace(); } } if (socket != null) { try { socket.close(); } catch (IOException e) { System.out.println("din关闭失败"); e.printStackTrace(); } } } /** * 功能:转发给所有客户端 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午11:11:59 * * @param message * @throws IOException */ private void forwordToAllClients(String message) throws IOException { for (Client c : clients) { if (c != this) { out = c.socket.getOutputStream(); dos = new DataOutputStream(out); forwordToClient(message); } } } /** * 功能:发送给一个客户端 学校:山东师范大学 程序员:外力_Victor 日期:2016年5月8日 上午11:16:12 * * @throws IOException */ private void forwordToClient(String message) throws IOException { dos.writeUTF(message); dos.flush(); System.out.println("转发成功!"); } } }
源码下载:java聊天室代码
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持菜鸟教程(cainiaojc.com)。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:notice#cainiaojc.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。