「java聊天室内容摘要」java聊天室流程图

博主:adminadmin 2023-03-19 21:42:08 218

今天给各位分享java聊天室内容摘要的知识,其中也会对java聊天室流程图进行解释,如果能碰巧解决你现在面临的问题,别忘了关注本站,现在开始吧!

本文目录一览:

求java网络聊天室(B/S模式)程序代码

共四个java文件,源代码如下:

import java.awt.*;

import java.net.*;

import java.awt.event.*;

import java.io.*;

import java.util.Hashtable;

public class ChatArea extends Panel implements ActionListener,Runnable

{

Socket socket=null;

DataInputStream in=null;

DataOutputStream out=null;

Thread threadMessage=null;

TextArea 谈话显示区,私聊显示区=null;

TextField 送出信息=null;

Button 确定,刷新谈话区,刷新私聊区;

Label 提示条=null;

String name=null;

Hashtable listTable;

List listComponent=null;

Choice privateChatList;

int width,height;

public ChatArea(String name,Hashtable listTable,int width,int height)

{

setLayout(null);

setBackground(Color.orange);

this.width=width;

this.height=height;

setSize(width,height);

this.listTable=listTable;

this.name=name;

threadMessage=new Thread(this);

谈话显示区=new TextArea(10,10);

私聊显示区=new TextArea(10,10);

确定=new Button("送出信息到:");

刷新谈话区=new Button("刷新谈话区");

刷新私聊区=new Button("刷新私聊区");

提示条=new Label("双击聊天者可私聊",Label.CENTER);

送出信息=new TextField(28);

确定.addActionListener(this);

送出信息.addActionListener(this);

刷新谈话区.addActionListener(this);

刷新私聊区.addActionListener(this);

listComponent=new List();

listComponent.addActionListener(this);

privateChatList=new Choice();

privateChatList.add("大家(*)");

privateChatList.select(0);

add(谈话显示区);

谈话显示区.setBounds(10,10,(width-120)/2,(height-120));

add(私聊显示区);

私聊显示区.setBounds(10+(width-120)/2,10,(width-120)/2,(height-120));

add(listComponent);

listComponent.setBounds(10+(width-120),10,100,(height-160));

add(提示条);

提示条.setBounds(10+(width-120),10+(height-160),110,40);

Panel pSouth=new Panel();

pSouth.add(送出信息);

pSouth.add(确定);

pSouth.add(privateChatList);

pSouth.add(刷新谈话区);

pSouth.add(刷新私聊区);

add(pSouth);

pSouth.setBounds(10,20+(height-120),width-20,60);

}

public void setName(String s)

{

name=s;

}

public void setSocketConnection(Socket socket,DataInputStream in,DataOutputStream out)

{

this.socket=socket;

this.in=in;

this.out=out;

try

{

threadMessage.start();

}

catch(Exception e)

{

}

}

public void actionPerformed(ActionEvent e)

{

if(e.getSource()==确定||e.getSource()==送出信息)

{

String message="";

String people=privateChatList.getSelectedItem();

people=people.substring(0,people.indexOf("("));

message=送出信息.getText();

if(message.length()0)

{

try {

if(people.equals("大家"))

{

out.writeUTF("公共聊天内容:"+name+"说:"+message);

}

else

{

out.writeUTF("私人聊天内容:"+name+"悄悄地说:"+message+"#"+people);

}

}

catch(IOException event)

{

}

}

}

else if(e.getSource()==listComponent)

{

privateChatList.insert(listComponent.getSelectedItem(),0);

privateChatList.repaint();

}

else if(e.getSource()==刷新谈话区)

{

谈话显示区.setText(null);

}

else if(e.getSource()==刷新私聊区)

{

私聊显示区.setText(null);

}

}

public void run()

{

while(true)

{

String s=null;

try

{

s=in.readUTF();

if(s.startsWith("聊天内容:"))

{

String content=s.substring(s.indexOf(":")+1);

谈话显示区.append("\n"+content);

}

if(s.startsWith("私人聊天内容:"))

{

String content=s.substring(s.indexOf(":")+1);

私聊显示区.append("\n"+content);

}

else if(s.startsWith("聊天者:"))

{

String people=s.substring(s.indexOf(":")+1,s.indexOf("性别"));

String sex=s.substring(s.indexOf("性别")+2);

listTable.put(people,people+"("+sex+")");

listComponent.add((String)listTable.get(people));

listComponent.repaint();

}

else if(s.startsWith("用户离线:"))

{

String awayPeopleName=s.substring(s.indexOf(":")+1);

listComponent.remove((String)listTable.get(awayPeopleName));

listComponent.repaint();

谈话显示区.append("\n"+(String)listTable.get(awayPeopleName)+"离线");

listTable.remove(awayPeopleName);

}

Thread.sleep(5);

}

catch(IOException e)

{

listComponent.removeAll();

listComponent.repaint();

listTable.clear();

谈话显示区.setText("和服务器的连接已中断\n必须刷新浏览器才能再次聊天");

break;

}

catch(InterruptedException e)

{

}

}

}

}

ChatServer.java

import java.io.*;

import java.net.*;

import java.util.*;

public class ChatServer

{

public static void main(String args[])

{

ServerSocket server=null;

Socket you=null;

Hashtable peopleList;

peopleList=new Hashtable();

while(true)

{

try

{

server=new ServerSocket(6666);

}

catch(IOException e1)

{

System.out.println("正在监听");

}

try {

you=server.accept();

InetAddress address=you.getInetAddress();

System.out.println("用户的IP:"+address);

}

catch (IOException e)

{

}

if(you!=null)

{

Server_thread peopleThread=new Server_thread(you,peopleList);

peopleThread.start();

}

else {

continue;

}

}

}

}

class Server_thread extends Thread

{

String name=null,sex=null;

Socket socket=null;

File file=null;

DataOutputStream out=null;

DataInputStream in=null;

Hashtable peopleList=null;

Server_thread(Socket t,Hashtable list)

{

peopleList=list;

socket=t;

try {

in=new DataInputStream(socket.getInputStream());

out=new DataOutputStream(socket.getOutputStream());

}

catch (IOException e)

{

}

}

public void run()

{

while(true)

{ String s=null;

try

{

s=in.readUTF();

if(s.startsWith("姓名:"))

{

name=s.substring(s.indexOf(":")+1,s.indexOf("性别"));

sex=s.substring(s.lastIndexOf(":")+1);

boolean boo=peopleList.containsKey(name);

if(boo==false)

{

peopleList.put(name,this);

out.writeUTF("可以聊天:");

Enumeration enum=peopleList.elements();

while(enum.hasMoreElements())

{

Server_thread th=(Server_thread)enum.nextElement();

th.out.writeUTF("聊天者:"+name+"性别"+sex);

if(th!=this)

{

out.writeUTF("聊天者:"+th.name+"性别"+th.sex);

}

}

}

else

{

out.writeUTF("不可以聊天:");

}

}

else if(s.startsWith("公共聊天内容:"))

{

String message=s.substring(s.indexOf(":")+1);

Enumeration enum=peopleList.elements();

while(enum.hasMoreElements())

{

((Server_thread)enum.nextElement()).out.writeUTF("聊天内容:"+message);

}

}

else if(s.startsWith("用户离开:"))

{

Enumeration enum=peopleList.elements();

while(enum.hasMoreElements())

{ try

{

Server_thread th=(Server_thread)enum.nextElement();

if(th!=thisth.isAlive())

{

th.out.writeUTF("用户离线:"+name);

}

}

catch(IOException eee)

{

}

}

peopleList.remove(name);

socket.close();

System.out.println(name+"用户离开了");

break;

}

else if(s.startsWith("私人聊天内容:"))

{

String 悄悄话=s.substring(s.indexOf(":")+1,s.indexOf("#"));

String toPeople=s.substring(s.indexOf("#")+1);

Server_thread toThread=(Server_thread)peopleList.get(toPeople);

if(toThread!=null)

{

toThread.out.writeUTF("私人聊天内容:"+悄悄话);

}

else

{

out.writeUTF("私人聊天内容:"+toPeople+"已经离线");

}

}

}

catch(IOException ee)

{

Enumeration enum=peopleList.elements();

while(enum.hasMoreElements())

{ try

{

Server_thread th=(Server_thread)enum.nextElement();

if(th!=thisth.isAlive())

{

th.out.writeUTF("用户离线:"+name);

}

}

catch(IOException eee)

{

}

}

peopleList.remove(name);

try

{

socket.close();

}

catch(IOException eee)

{

}

System.out.println(name+"用户离开了");

break;

}

}

}

}

import java.awt.*;

import java.io.*;

import java.net.*;

import java.applet.*;

import java.util.Hashtable;

ClientChat.java

public class ClientChat extends Applet implements Runnable

{

Socket socket=null;

DataInputStream in=null;

DataOutputStream out=null;

InputNameTextField 用户提交昵称界面=null;

ChatArea 用户聊天界面=null;

Hashtable listTable;

Label 提示条;

Panel north, center;

Thread thread;

public void init()

{

int width=getSize().width;

int height=getSize().height;

listTable=new Hashtable();

setLayout(new BorderLayout());

用户提交昵称界面=new InputNameTextField(listTable);

int h=用户提交昵称界面.getSize().height;

用户聊天界面=new ChatArea("",listTable,width,height-(h+5));

用户聊天界面.setVisible(false);

提示条=new Label("正在连接到服务器,请稍等...",Label.CENTER);

提示条.setForeground(Color.red);

north=new Panel(new FlowLayout(FlowLayout.LEFT));

center=new Panel();

north.add(用户提交昵称界面);

north.add(提示条);

center.add(用户聊天界面);

add(north,BorderLayout.NORTH);

add(center,BorderLayout.CENTER);

validate();

}

public void start()

{

if(socket!=nullin!=nullout!=null)

{ try

{

socket.close();

in.close();

out.close();

用户聊天界面.setVisible(false);

}

catch(Exception ee)

{

}

}

try

{

socket = new Socket(this.getCodeBase().getHost(), 6666);

in=new DataInputStream(socket.getInputStream());

out=new DataOutputStream(socket.getOutputStream());

}

catch (IOException ee)

{

提示条.setText("连接失败");

}

if(socket!=null)

{

InetAddress address=socket.getInetAddress();

提示条.setText("连接:"+address+"成功");

用户提交昵称界面.setSocketConnection(socket,in,out);

north.validate();

}

if(thread==null)

{

thread=new Thread(this);

thread.start();

}

}

public void stop()

{

try

{

socket.close();

thread=null;

}

catch(IOException e)

{

this.showStatus(e.toString());

}

}

public void run()

{

while(thread!=null)

{

if(用户提交昵称界面.get能否聊天()==true)

{

用户聊天界面.setVisible(true);

用户聊天界面.setName(用户提交昵称界面.getName());

用户聊天界面.setSocketConnection(socket,in,out);

提示条.setText("祝聊天愉快!");

center.validate();

break;

}

try

{

Thread.sleep(100);

}

catch(Exception e)

{

}

}

}

}

InputNameTextField。java

import java.awt.*;

import java.net.*;

import java.awt.event.*;

import java.io.*;

import java.util.Hashtable;

public class InputNameTextField extends Panel implements ActionListener,Runnable

{

TextField nameFile=null;

String name=null;

Checkbox male=null,female=null;

CheckboxGroup group=null;

Button 进入聊天室=null,退出聊天室=null;

Socket socket=null;

DataInputStream in=null;

DataOutputStream out=null;

Thread thread=null;

boolean 能否聊天=false;

Hashtable listTable;

public InputNameTextField(Hashtable listTable)

{

this.listTable=listTable;

nameFile=new TextField(10);

group=new CheckboxGroup();

male=new Checkbox("男",true,group);

female=new Checkbox("女",false,group);

进入聊天室=new Button("进入");

退出聊天室=new Button("退出");

进入聊天室.addActionListener(this);

退出聊天室.addActionListener(this);

thread=new Thread(this);

add(new Label("昵称:"));

add(nameFile);

add(male);

add(female);

add(进入聊天室);

add(退出聊天室);

退出聊天室.setEnabled(false);

}

public void set能否聊天(boolean b)

{

能否聊天=b;

}

public boolean get能否聊天()

{

return 能否聊天;

}

public String getName()

{

return name;

}

public void setName(String s)

{

name=s;

}

public void setSocketConnection(Socket socket,DataInputStream in,DataOutputStream out)

{

this.socket=socket;

this.in=in;

this.out=out;

try{

thread.start();

}

catch(Exception e)

{

nameFile.setText(""+e);

}

}

public Socket getSocket()

{

return socket;

}

public void actionPerformed(ActionEvent e)

{

if(e.getSource()==进入聊天室)

{

退出聊天室.setEnabled(true);

if(能否聊天==true)

{

nameFile.setText("您正在聊天:"+name);

}

else

{

this.setName(nameFile.getText());

String sex=group.getSelectedCheckbox().getLabel();

if(socket!=nullname!=null)

{

try{

out.writeUTF("姓名:"+name+"性别:"+sex);

}

catch(IOException ee)

{

nameFile.setText("没有连通服务器"+ee);

}

}

}

}

if(e.getSource()==退出聊天室)

{

try

{

out.writeUTF("用户离开:");

}

catch(IOException ee)

{

}

}

}

public void run()

{

String message=null;

while(true)

{

if(in!=null)

{

try

{

message=in.readUTF();

}

catch(IOException e)

{

nameFile.setText("和服务器断开"+e);

}

}

if(message.startsWith("可以聊天:"))

{

能否聊天=true;

break;

}

else if(message.startsWith("聊天者:"))

{

String people=message.substring(message.indexOf(":")+1);

listTable.put(people,people);

}

else if(message.startsWith("不可以聊天:"))

{

能否聊天=false;

nameFile.setText("该昵称已被占用");

}

}

}

}

为java聊天室代码加详细注释,并说明设计思路。好的加100分。

import java.io.*;

import java.net.*;

import java.awt.*;

import javax.swing.*;

import java.awt.event.*;//引入包。

public class ChatClient {

public static void main(String[] args) {

ChatClient cc = new ChatClient();

cc.receive();

}

JTextField jtf; // 文本条

JTextArea jta; //文本域。

Socket s; //客户端

PrintWriter out; //输出流

BufferedReader in; //输入流

public ChatClient() {

JFrame frame = new JFrame("ChatClient");//窗口

frame.setSize(400, 300); //大小

jta = new JTextArea(); //文本域

jta.setEditable(false); //不可编辑

jtf = new JTextField();//文件条

jtf.addActionListener(new ActionListener() { //添加监听。

public void actionPerformed(ActionEvent arg0) {

send(); //调用send()方法

}

});

frame.getContentPane().add(new JScrollPane(jta)); //添加滚动条

frame.getContentPane().add(jtf, "South"); //添加文本条

frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); //关闭窗口。

frame.setVisible(true); //可显示的。

try {

s = new Socket("127.0.0.1", 9000); //连接服务端 socket("主机名",端口号);

in = new BufferedReader(new InputStreamReader(s.getInputStream())); //建立输入流

out = new PrintWriter(s.getOutputStream());//输出流

} catch (UnknownHostException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public void receive() { //接受服务端发来别的客户端的信息。

while (true) {

try {

String text = in.readLine(); //读一行

this.jta.append(text + "\n"); //jta 添加上读入的。

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

return;

}

}

}

public void send() { //发送消息

String text = this.jtf.getText(); //得到你输入的消息

this.jtf.setText(""); //在文本域中显示你输入的消息。

out.println(text); //打印出。

out.flush(); //清空

}

}

Server端

import java.net.*;

import java.io.*;

import java.util.*;//引入包

public class ChatServer {

public static void main(String[] args) throws Exception {

ServerSocket ss = new ServerSocket(9000); //建立服务端,端口号为9000

List list = new ArrayList(); //创建个List集合。

while (true) {

Socket s = ss.accept(); //等待客户端的请求。

list.add(s); //把每一个client都add到集合中去。

Thread t = new ServerThread(s, list); //线程。

t.start(); //启动。

}

}

}

class ServerThread extends Thread {

Socket s;

List list;

BufferedReader in;

PrintWriter out;

public ServerThread(Socket s, List list) { //构造。传入socket和list。

this.s = s;

this.list = list;

try {

in = new BufferedReader(new InputStreamReader(s.getInputStream())); //输入流

out = new PrintWriter(s.getOutputStream()); //输出流

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public void run() { //必须实现其run()方法。

while (true) {

try {

String str = in.readLine(); //得到client端的message。

if (str == null) //如果没有消息就返回。

return;

Iterator it = list.iterator(); //遍历list。

while (it.hasNext()) { //如果list有下一个

Socket socket = (Socket) (it.next()); //因为list中都是存的socket

PrintWriter o = new PrintWriter(socket.getOutputStream()); //输出流

o.println(str); //输出

o.flush(); //清空

}

} catch (IOException e) {

// TODO Auto-generated catch block

// e.printStackTrace();

return;

}

}

}

}

你好,你有用java编写的聊天室的代码吗,基于c/s架构的

服务端 用户名 y 密码 1 客户端代码在我的评论里,这敲不了那么多字,没办法。

登陆实现类:class Login

package com.server;

import java.awt.Color;

import java.awt.Font;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.awt.event.WindowAdapter;

import java.awt.event.WindowEvent;

import javax.swing.JButton;

import javax.swing.JFrame;

import javax.swing.JLabel;

import javax.swing.JPasswordField;

import javax.swing.JTextField;

public class Login {

boolean f=false;//按登录时设置的一个标志

private JFrame frame = new JFrame("Welcome To MLDN") ;

//设置窗体

private JButton submit = new JButton("登陆");//设置登录按钮

private JButton reset = new JButton("重置");//设置重置按钮

private JLabel nameLab = new JLabel("服务器:") ;//标签实例化

private JLabel passLab = new JLabel("密 码:"); //标签实例化

private JLabel infoLab = new JLabel("服务器登陆系统"); //标签实例化

private JTextField nameText = new JTextField(10);//单行文本输入条

private JPasswordField passText = new JPasswordField() ;//单行密码文本输入条

public Login(){//登录窗口构造方法

Font fnt = new Font("Serief",Font.ITALIC + Font.BOLD,12); //设置字体

infoLab.setFont(fnt) ; // 设置标签的显示文字

submit.addActionListener(new ActionListener(){ //采用内部匿名类

public void actionPerformed(ActionEvent e){

if(e.getSource()==submit){ //判断触发器源是否是提交按钮

String tname = nameText.getText() ; //得到输入的用户名

String tpass = new String(passText.getPassword()) ;//得到输入的密码,此时通过getPassageword()方法返回的是字符数组

LoginCheck log = new LoginCheck(tname,tpass) ;//实例化LoginCheck对象,传入输入的用户名和密码

if(log.validate()){//对用户名和密码进行验证

try{ //线程异常处理try

Thread.sleep(2000); //2秒后打开聊天窗口

f=true; //登录成功后的表示项为true

frame.dispose(); //关闭本窗口

}catch(Exception e1){//异常获取

e1.printStackTrace();

}

}else{

infoLab.setText("登陆失败,错误的用户名或密码!") ;//登录失败

}

}

}

});

reset.addActionListener(new ActionListener(){ //采用内部匿名类

public void actionPerformed(ActionEvent e){

if(e.getSource()==reset){ //判断触发器源是否是提交按钮

nameText.setText(""); //设置文本框中的内容

passText.setText(""); //设置文本框中的内容

infoLab.setText("服务器登陆系统"); //恢复标签显示

}

}

});

frame.addWindowListener(new WindowAdapter(){//加入窗口监听

public void windowClosing(WindowEvent e){ }

}); // 加入事件

frame.setLayout(null); //使用绝对定位

nameLab.setBounds(5,5,60,20); //设置标签的位置及大小

passLab.setBounds(5,30,60,20); //设置标签的位置及大小

infoLab.setBounds(5,65,220,30); //设置标签的位置及大小

nameText.setBounds(65,5,100,20); //设置文本域的位置及大小

passText.setBounds(65,30,100,20); //设置密码域的位置及大小

submit.setBounds(165,5,60,20); //设置按钮的位置及大小

reset.setBounds(165,30,60,20); //设置按钮的位置及大小

frame.add(nameLab); //向窗体加入标签

frame.add(passLab); //向窗体加入标签

frame.add(infoLab); //向窗体加入标签

frame.add(nameText); //向窗体加入文本框

frame.add(passText); //向窗体加入密码框

frame.add(submit); //向窗体加入按钮

frame.add(reset) ;//向窗体加入按钮

frame.setSize(280,130); //设置窗体大小

frame.getContentPane().setBackground(Color.green) ;//设置窗体的背景颜色

frame.setLocation(300,200) ;//设置窗体在电脑桌面上的位置

frame.setVisible(true); //显示窗口

while(f==false){ //当登录失败时,一直循环运行,

}

new MyServer();//显示窗体页面

}

}

验证登陆实现类 class LoginCheck

package com.server;

public class LoginCheck {

private String name ;//用户名

private String password ;//密码

//构造方法

public LoginCheck(String name,String password){

this.name = name ;//传递用户名

this.password = password ;//传递密码

}

//验证用户名和密码

public boolean validate(){

//验证方法

if("y".equals(name)"1".equals(password)){ //判断用户名和密码是否正确

return true; //返回true

}else{

return false ;//返回false

}

}

}

package com.server;

import java.awt.*;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

import java.text.DateFormat;

import java.util.Date;

import javax.swing.*;

聊天实现类 class MyServer

public class MyServer {

protected JLabel lab10;

// 全体变量,做传递的一个组件

String s = "已经成功连接";

// 初始字符串,在两个聊天窗口链接成功时输出,同时作为两个窗口传递字符的一个变量

// 构造方法

public MyServer(){

try{//异常处理

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

//设置窗体

frame.setLayout(null);

//让布局管理器为空,使用绝对定位

Font fnt=new Font("Serief",Font.PLAIN,40);//字体设置

Font fnt1=new Font("Serief",Font.PLAIN,20);//字体设置

//我的用户名显示

JLabel lab1=new JLabel("服务器名:",JLabel.LEFT);

//标签实例化,文本左对齐

lab1.setBounds(8, 10, 100, 20);

//设置组件位置及大小

frame.add(lab1);

//添加组件

JTextField text2=new JTextField(30); //单行文本输入组件

text2.setBounds(150, 10, 200, 20);//设置组件位置及大小

text2.setEnabled(false);//文本条不可编辑

text2.setText("笑笑聊天室");//输入内容

text2.setFont(fnt1);//设置字体

frame.add(text2);//添加组件

//服务器IP显示

JLabel lab2=new JLabel("当前服务器IP:",JLabel.LEFT);

//标签实例化,文本左对齐

lab2.setBounds(8, 45, 100, 20);//设置组件位置及大小

frame.add(lab2);//添加组件

JTextField text3=new JTextField(30);//单行文本输入组件

text3.setBounds(150, 45, 200, 20);//设置组件位置及大小

text3.setEnabled(false);

//文本不可编辑

text3.setText("127.0.0.1");//输入内容

text3.setFont(fnt1);//设置字体

frame.add(text3);

//添加组件

//服务器端口显示

JLabel lab3=new JLabel("当前服务器端口:",JLabel.LEFT);

//标签实例化,文本左对齐

lab3.setBounds(8, 80, 100, 20);//设置组件位置及大小

frame.add(lab3);//添加组件

JTextField text4=new JTextField(30);//单行文本输入组件

text4.setBounds(150, 80, 200, 20);//设置组件位置及大小

text4.setEnabled(false);//文本不可编辑

text4.setText("8888");//输入内容

text4.setFont(fnt1);//设置字体

frame.add(text4);//添加组件

//聊天记录显示

JLabel lab4=new JLabel("聊天记录如下:",JLabel.LEFT);

//标签实例化 文本左对齐

lab4.setBounds(8, 115, 100, 20);//设置组件位置及大小

frame.add(lab4);//添加组件

final JTextArea text1=new JTextArea();//多行文本输入组件

text1.setEnabled(false);//文本不可编辑

text1.setLineWrap(true);//自动换行

JScrollPane scr=new JScrollPane(text1,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS); //设置滚动条,水平和垂直滚动条始终显示

scr.setBounds(8, 150, 450, 350);//设置组件位置及大小

frame.add(scr);//添加组件

//聊天输入窗口及确定

JLabel lab5=new JLabel("请输入聊天内容:",JLabel.LEFT); //标签实例化,文本左对齐

lab5.setBounds(8, 500, 100, 20);//设置组件位置及大小

frame.add(lab5);//添加组件

final JTextArea text5=new JTextArea();//多行文本输入组件

text5.setLineWrap(true);//自动换行

JScrollPane scr2=new JScrollPane(text5,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);//设置滚动条,水平和垂直滚动条始终显示

scr2.setBounds(150, 500, 300, 50);//设置组件位置及大小

frame.add(scr2);//添加组件

final JButton but=new JButton("确定");//设置确定按钮

but.setFont(fnt);//添加字体设置

but.setBounds(480, 500, 200, 50);//设置组件位置及大小

but.addActionListener(

new ActionListener(){ //采用内部匿名类

public void actionPerformed(ActionEvent e){

if(e.getSource()==but){ //判断触发器源是否是提交按钮

text1.append("笑笑: "+lab10.getText()+"\n ");//在聊天记录上添加文本

text1.append(text5.getText()+"\n"); //将输入的聊天内容输出在聊天记录上

s=text5.getText(); //得到聊天内容

text5.setText(""); // 将聊天窗口内容设置为空

}

}

});

frame.add(but);//添加组件

//当前时间显示

JLabel lab7=new JLabel("时间显示:",JLabel.LEFT);//标签实例化,文本左对齐

lab7.setBounds(450, 20, 100, 20);//设置组件位置及大小

frame.add(lab7);//添加组件

DateFormat df=DateFormat.getDateTimeInstance();//取得系统时间

String df2= df.format(new Date()); //将时间转换成字符串

JLabel lab8=new JLabel(df2,JLabel.LEFT);//标签实例化,文本左对齐

lab8.setBounds(520, 20, 130, 20);//设置组件位置及大小

frame.add(lab8);//添加组件

lab10=lab8; //传递时间显示,以便能在聊天记录上显示记录时间

new Time(lab8); //使时间动态显示

//用户列表显示

JLabel lab6=new JLabel("用户列表:",JLabel.LEFT);//标签实例化,文本左对齐

lab6.setBounds(500, 40, 100, 20);//设置组件位置及大小

frame.add(lab6);//添加组件

JTextArea text6=new JTextArea();//标签实例化,文本左对齐

text6.setEnabled(false);//文本不可编辑

text6.setLineWrap(true);//自动换行

JScrollPane scr3=new JScrollPane(text6,JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);//设置滚动条,水平和垂直滚动条始终显示

scr3.setBounds(460, 70, 220, 420);//设置组件位置及大小

frame.add(scr3);//添加组件

//窗口的属性

frame.setSize(700,600);//窗口大小

frame.getContentPane().setBackground(Color.pink);//窗口的背景颜色

frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//关闭窗口时关闭程序

frame.setLocation(100,50);//在电脑桌面上出现的位置

frame.setVisible(true);//显示窗口

//连个窗口连接

//建立Server Socket并等待连接请求

ServerSocket server =new ServerSocket(8889);

Socket socket=server.accept();

//连接建立,通过Socket获取连接上的输入/输出流

BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));

final PrintWriter out =new PrintWriter(socket.getOutputStream());

//先读取Client发送的数据,然后从标准输入读取数据发送给Client当接收到bye时关闭连接

String s1="",s2="";

//标志字符串,作为传递字符串使用

//得到其他窗口传递的字符串,并判断是否结束

while(!(s1=in.readLine()).equals("bye")){

text6.setText("可可在线"); //当连接成功是在用户列表中 输出用户名字

if(!s1.equals("")){ //如果传递的字符串不为 空

text1.append("可可: "+lab10.getText()+"\n ");//在聊天记录上添加文本

text1.append(s1+"\n"); //将输入的聊天内容输出在聊天记录上

}

s2=s;//将在聊天窗口中得到的字符串传递给输出字符串

for(;s2.equals("")||s2.equals(null);s2=s){//当传递的字符串为空时等待用户输入聊天内容

}

s="";//将在聊天窗口中得到的字符串设为空

if(!s2.equals("")!s2.equals(null)){// s2不为空时做

out.println(s2); //向其他窗口输出字符串

}

out.flush();//输出聊天内容

}

//关闭连接

in.close();

out.close();

socket.close();

server.close();

}catch(Exception e){

}

}

//main函数

public static void main(String args[]){

new Login();//登录实现 } }

}

}

时间类 class Time

package com.server;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.text.SimpleDateFormat;

import java.util.Date;

import javax.swing.JLabel;

import javax.swing.Timer; //时间类

public class Time {

public Time(JLabel time){

//构造方法 this.setTimer(time);

//设置时间

}

public void setTimer(JLabel time){

//设置时间方法

final JLabel varTime = time;

//传递组件

Timer timeAction = new Timer(1000, new ActionListener() {

//时间监听

public void actionPerformed(ActionEvent e) {

long timemillis = System.currentTimeMillis();//得到系统时间

SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//转换日期显示格式

varTime.setText(df.format(new Date(timemillis)));//输出得到的时间

}

});

timeAction.start(); //开启线程

}

}

java实现聊天室是怎么做到的?

Java 实现聊天室可以分为以下几个步骤:

建立服务器端

首先需要建立一个服务器端,负责接收客户端的连接请求并处理客户端发送过来的消息。

建立客户端

然后需要建立客户端,客户端通过网络连接到服务器端,并向服务器端发送消息。

实现通信协议

为了实现聊天室功能,需要定义一个通信协议,规定客户端和服务器端之间的通信格式,例如消息的头部和内容等。

实现多线程处理

聊天室通常会有多个用户同时在线,因此需要使用多线程来处理多个客户端的连接请求和消息传递。

实现GUI界面(可选)

为了方便用户使用,可以实现一个GUI界面,让用户可以方便地发送和接收消息。

以下是一个简单的 Java 聊天室的代码示例:

java

Copy code

// 服务器端代码

public class Server {

public static void main(String[] args) {

try {

ServerSocket serverSocket = new ServerSocket(8888);

while (true) {

Socket socket = serverSocket.accept();

new Thread(new ServerThread(socket)).start();

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

class ServerThread implements Runnable {

private Socket socket;

private BufferedReader reader;

private PrintWriter writer;

public ServerThread(Socket socket) {

this.socket = socket;

try {

reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

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

} catch (IOException e) {

e.printStackTrace();

}

}

public void run() {

try {

String msg;

while ((msg = reader.readLine()) != null) {

// 处理客户端发送过来的消息

System.out.println("接收到消息:" + msg);

// 将消息发送给所有客户端

for (Socket s : ServerThreadList.getList()) {

if (s != socket) {

PrintWriter w = new PrintWriter(s.getOutputStream());

w.println(msg);

w.flush();

}

}

}

// 关闭连接

socket.close();

ServerThreadList.removeThread(this);

} catch (IOException e) {

e.printStackTrace();

}

}

}

class ServerThreadList {

private static List

list = new ArrayList();

public static void addThread(ServerThread thread) {

list.add(thread);

}

public static void removeThread(ServerThread thread) {

list.remove(thread);

}

public static List

getList() {

return list;

}

}

// 客户端代码

public class Client {

public static void main(String[] args) {

try {

Socket socket = new Socket("localhost", 8888);

new Thread(new ClientThread(socket)).start();

BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

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

while (true) {

String msg = reader.readLine();

writer.println(msg);

writer.flush();

}

} catch (IOException e) {

e.printStackTrace();

}

}

}

class ClientThread implements Runnable {

private Socket socket;

private BufferedReader reader;

public ClientThread(Socket socket) {

this.socket = socket;

try {

reader

关于java聊天室内容摘要和java聊天室流程图的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站。