java 简单的聊天工具 （带界面的）

首先建立一个工程 导入数据库驱动

工程图

解释一下 entity包是 bin目录 Message包下 和 User包下 是对象相关的操作

Message
package com.FakeQQ.entity;

import java.util.Date;

public class Message {

//需要序列化发送，所以要继承Serializable接口
private int id;
private String content;
private int sender;
private int receiver;
private Date sendTime;
private Date receiveTime;
private int state;
private int ip;

public int getIp() {
return ip;
}
public void setIp(int ip) {
this.ip = ip;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
public int getSender() {
return sender;
}
public void setSender(int sender) {
this.sender = sender;
}
public int getReceiver() {
return receiver;
}
public void setReceiver(int receiver) {
this.receiver = receiver;
}
public Date getSendTime() {
return sendTime;
}
public void setSendTime(Date sendTime) {
this.sendTime = sendTime;
}
public Date getReceiveTime() {
return receiveTime;
}
public void setReceiveTime(Date receiveTime) {
this.receiveTime = receiveTime;
}
public int getState() {
return state;
}
public void setState(int state) {
this.state = state;
}
}

User
package com.FakeQQ.entity;

import java.util.Date;

public class User {

//这叫实体bin
private int qqNumber;
private String qqName;
private String qqPassword;
private Date registTime; //注册时间
private String sex;
private String introduce; //个人简介
private String ip;
public int getQqNumber() {
return qqNumber;
}
public void setQqNumber(int qqNumber) {
this.qqNumber = qqNumber;
}
public String getQqName() {
return qqName;
}
public void setQqName(String qqName) {
this.qqName = qqName;
}
public String getQqPassword() {
return qqPassword;
}
public void setQqPassword(String qqPassword) {
this.qqPassword = qqPassword;
}
public Date getRegistTime() {
return registTime;
}
public void setRegistTime(Date registTime) {
this.registTime = registTime;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
public String getIntroduce() {
return introduce;
}
public void setIntroduce(String introduce) {
this.introduce = introduce;
}
public String getIp() {
return ip;
}
public void setIp(String ip) {
this.ip = ip;
}

}

MessageDaoImpl.java

package com.FakeQQ.Message.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;

import com.FakeQQ.entity.Message;
import com.FakeQQ.util.ConnectionUtil;

public class MessageDaoImpl {

public int SaveMessage(Message message) {
Connection con=null;
PreparedStatement pstm=null;
int key=0;
try{
con=ConnectionUtil.getCon();
pstm=con.prepareStatement(
"insert into message(content,sender,receiver,"
+ "sendTime,state)values(?,?,?,?,?)",
Statement.RETURN_GENERATED_KEYS);
pstm.setString(1, message.getContent());//
pstm.setInt(2, message.getSender());
pstm.setInt(3, message.getReceiver());
pstm.setString(4, message.getSendTime().toLocaleString());
pstm.setInt(5, message.getState());
pstm.executeUpdate();
ResultSet rs=pstm.getGeneratedKeys();

if(rs.next())
key = rs.getInt(1);
return key;
} catch (Exception e) {
e.printStackTrace();
return 0;
// TODO: handle exception
}finally{
ConnectionUtil.closeCon(null, pstm, con);
}

}
}

ClientThread.java

package com.FakeQQ.Message.service;

import java.io.OutputStream;
import java.net.Socket;

import com.FakeQQ.entity.Message;
import com.FakeQQ.util.SeralizableUtil;

public class ClientThread implements Runnable {
Message message;
String ip;
public ClientThread(Message message,String ip) {
this.message=message;
this.ip=ip;
}

@Override
public void run() {

try {

Socket socket = new Socket(ip,8888);
OutputStream os = socket.getOutputStream();

byte cache[]= SeralizableUtil.SerializableMessage(message);
os.write(cache);
os.flush();
os.close();
System.out.println(cache.length);
//socket.close();
} catch (Exception e) {
// TODO: handle exception
}
}

}

MessageServiceImpl.java

package com.FakeQQ.Message.service;

import com.FakeQQ.Message.dao.MessageDaoImpl;
import com.FakeQQ.entity.Message;

public class MessageServiceImpl {
public int sendMessage(Message msg){
MessageDaoImpl messageDaoImpl=new MessageDaoImpl();
return messageDaoImpl.SaveMessage(msg);
}
}

ServerThread.java

package com.FakeQQ.Message.service;

import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Iterator;

import com.FakeQQ.Message.view.MessageFrame;
import com.FakeQQ.entity.Message;
import com.FakeQQ.user.view.MainFrame;
import com.FakeQQ.util.SeralizableUtil;
import com.FakeQQ.util.SerializableUtilRe;

public class ServerThread implements Runnable {

MainFrame mainFrame;
public ServerThread(MainFrame mainFrame) {
this.mainFrame=mainFrame;
}
@Override
public void run() {
try {
ServerSocket server = new ServerSocket(8888);
while(true){
Socket socket = server.accept();
InputStream is = socket.getInputStream();
System.out.println("ServerThread已开启");

//System.out.println(is);
//if(true) {
System.out.println(is.available());
byte[] bytes = new byte[is.available()];

is.read(bytes);

//System.out.println(bytes.length);

Message message = SerializableUtilRe.SerializableMessageRe(bytes);

System.out.println(message==null);
System.out.println(message.getContent());
is.close();

System.out.println(message.getSender());
System.out.println(message.getContent());
//  TODO 接受消息并放置到文本框中
Iterator<Integer> i = mainFrame.MessageFrames.keySet().iterator();

boolean isExit = false;
while(i.hasNext()) {
int key = Integer.parseInt(i.next().toString());
if(message.getSender()== key) {

MessageFrame messageFrame = mainFrame.MessageFrames.get(key);
String content = messageFrame.txtList.getText();
messageFrame.txtList.setText(content + messageFrame.another.getQqName()+ ":" + message.getContent() );
isExit=true;
break;
}
//}
if(!isExit) {
MessageFrame messageFrame = new MessageFrame(mainFrame.myself,message.getSender() + "JK ");
mainFrame.MessageFrames.put(message.getSender(),messageFrame);
}

}
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}

BtnListener.java
package com.FakeQQ.Message.view;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.util.Date;

import com.FakeQQ.Message.service.ClientThread;
import com.FakeQQ.Message.service.MessageServiceImpl;
import com.FakeQQ.entity.Message;

public class BtnListener implements ActionListener {
private MessageFrame messageFrame;
public BtnListener(MessageFrame messageFrame) {
this.messageFrame = messageFrame;
}

@Override
public void actionPerformed(ActionEvent e) {

// 获得文本框值
String msg = messageFrame.txtMsg.getText();
//实例化Message对象 并存入数据库
Message message = new Message();
message.setContent(msg);
message.setSender(messageFrame.myself.getQqNumber());
message.setReceiver(messageFrame.another.getQqNumber());
message.setSendTime(new Date());
message.setState(1);

MessageServiceImpl messageServiceImpl = new MessageServiceImpl();
int key = messageServiceImpl.sendMessage(message);
message.setId(key);
//启动线程 发送给对方
new Thread(new ClientThread(message,messageFrame.another.getIp())).start();
messageFrame.txtMsg.setText("");

// 将消息放到本窗口多行文本框

String content=messageFrame.txtList.getText();
int size = messageFrame.txtList.getWidth()/4;
int spaceSize = size-messageFrame.myself.getQqName().length()-1;
if(spaceSize>0) {
for(int i=0;i<spaceSize;i++) {
content += " ";
}
}
content += messageFrame.myself.getQqName()+":"+msg+"\n";
messageFrame.txtList.setText(content);
}

}

MessageFrame.java
package com.FakeQQ.Message.view;

import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.Dimension;
import java.awt.TextArea;
import java.awt.Toolkit;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.border.Border;

import com.FakeQQ.entity.User;
import com.FakeQQ.user.service.UserServiceImpl;

public class MessageFrame extends JFrame{
public User myself;
public User another;

public JTextArea txtList=null;
public JTextField txtMsg=null;
public JButton btn=null;

public MessageFrame(User myself, String other){
this.myself=myself;
String temp[]=other.split(" ");
UserServiceImpl userServiceImpl=new UserServiceImpl();
another=userServiceImpl.listByQqNum(Integer.parseInt(temp[0]));
JPanel panel=new JPanel();
this.getContentPane().add(panel);
panel.setLayout(new BorderLayout());

txtList=new JTextArea(5, 20);
panel.add(txtList, BorderLayout.CENTER);

JPanel txtPanel=new JPanel();
txtMsg=new JTextField(10);
btn=new JButton("发送");

btn.addActionListener(new BtnListener(this));

txtPanel.add(txtMsg);
txtPanel.add(btn);
panel.add(txtPanel, BorderLayout.SOUTH);

this.setTitle(temp[1]);
this.setSize(400,300);
this.setVisible(true);

}
}

“`

UserDaoImpl.java

package com.FakeQQ.user.dao;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.util.ArrayList;

import java.util.List;

import com.FakeQQ.entity.User;

import com.FakeQQ.util.ConnectionUtil;

public class UserDaoImpl {

public User getUser(int qqNum){
User u = new User();
try{
//获取数据库连接
Connection con=ConnectionUtil.getCon();
//创建statement
PreparedStatement pstm=con.prepareStatement(
"select * from user u where u.qqNumber=?");
//设置参数，针对？占位符
pstm.setInt(1, qqNum);
//执行sql语句
ResultSet rs=pstm.executeQuery();

if(rs.next()) {
System.out.println(rs.getInt(1));
u.setQqNumber(rs.getInt(1));
System.out.println(rs.getString(2));
u.setQqName(rs.getString(2));
u.setQqPassword(rs.getString(3));
u.setRegistTime(rs.getDate(4));
u.setSex(rs.getString(5));
u.setIntroduce(rs.getString(6));
u.setIp(rs.getString(7));

}
//关闭连接
ConnectionUtil.closeCon(rs, pstm, con);
return u;
}catch(Exception e){
e.printStackTrace();
return null;
}
}

//用户注册
public boolean saveUser(User u) {
try {
//1,加载驱动类
Class.forName("com.mysql.jdbc.Driver");
//2.获取数据库连接
Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/myqq_db","root","");
//3.数据库实际操作
PreparedStatement pstm = con.prepareStatement(
"insert into user(qqName,qqPassword, registTime,sex,introduce,ip)"
+ " values(?,?,?,?,?,?)" );
pstm.setString(1, u.getQqName());
pstm.setString(2, u.getQqPassword());
pstm.setString(3, u.getRegistTime().toLocaleString());
pstm.setString(4, u.getSex());
pstm.setString(5, u.getIntroduce());
pstm.setString(6,u.getIp());

int count = pstm.executeUpdate(); // 插入之后做更新数据

pstm.close();
con.close();
if (count >0)
return true;
else
return false;
} catch (Exception e) {
e.printStackTrace();
}
return false;
}

// 找到某一账户，返回这个账户的所有资料
public User findByNameAndPassword(int qqNumber,String password) {

User u = new User();
try {

//1,加载驱动类
Class.forName("com.mysql.jdbc.Driver");
//2.获取数据库连接
Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/myqq_db","root","");
//3.数据库具体操作
PreparedStatement pstm = con.prepareStatement(
"select * from user u  where u.qqNumber = ? and u.qqPassword = ? " );

pstm.setInt(1,qqNumber);
pstm.setString(2, password);

ResultSet rs = pstm.executeQuery(); //查找之后返回集合

if(rs.next()) {
u.setQqNumber(rs.getInt(1));
u.setQqName(rs.getString(2));
u.setQqPassword(rs.getString(3));
u.setRegistTime(rs.getDate(4));
u.setSex(rs.getString(5));
u.setIntroduce(rs.getString(6));
u.setIp(rs.getString(7));

}
pstm.close();
con.close();

} catch (Exception e) {
e.printStackTrace();
}

return u;

}

// 通过qq号查找所有好友（默认数据库所有用户都是好友）
public List <User> findAllFriends(int qqNumber) {
ResultSet rs=null;
PreparedStatement pstm = null;
Connection con = null;

List <User> list = new ArrayList <User>();
try {
con = ConnectionUtil.getCon();
pstm = con.prepareStatement(
"select * from user u where u.qqNumber<>?"
);
pstm.setInt(1, qqNumber);
rs = pstm.executeQuery();

while(rs.next()) {
User u = new User();
u.setQqNumber(rs.getInt(1));
u.setQqName(rs.getString(2));
u.setQqPassword(rs.getString(3));
u.setRegistTime(rs.getDate(4));
u.setSex(rs.getString(5));
u.setIntroduce(rs.getString(6));
u.setIp(rs.getString(7));
list.add(u);
}
return list;

} catch (Exception e) {
e.printStackTrace();
return null;
}finally {
ConnectionUtil.closeCon(rs,pstm,con);

}

}

// 对特定的QQ号做密码重置
public boolean updatePassword(int qqNumber,String qqPassword) {
ResultSet rs=null;
PreparedStatement pstm = null;
Connection con = null;

try {
con = ConnectionUtil.getCon();
pstm = con.prepareStatement(
"update user set qqPassword=? where qqNumber=?"
);
pstm.setString(1,qqPassword);
pstm.setInt(2, qqNumber);

int count = pstm.executeUpdate();
if(count>0) {
return true;
}

} catch (Exception e) {
return false;
}finally {
ConnectionUtil.closeCon(rs,pstm,con);
}
return false;
}

// 登录成功后修改IP地址
public void updateIp(int qqNum,String qqIp) {
ResultSet rs=null;
PreparedStatement pstm = null;
Connection con = null;

try {
con = ConnectionUtil.getCon();
pstm = con.prepareStatement(
"update user set ip=? where qqNumber=?"
);
pstm.setString(1,qqIp);
pstm.setInt(2, qqNum);

int count = pstm.executeUpdate();

} catch (Exception e) {

}finally {
ConnectionUtil.closeCon(rs,pstm,con);
}

}

}

UserServiceImpl.java

package com.FakeQQ.user.service;

import java.net.InetAddress;

import java.net.UnknownHostException;

import java.util.Date;

import java.util.List;

import com.FakeQQ.entity.User;

import com.FakeQQ.user.dao.UserDaoImpl;

public class UserServiceImpl {

// 用户注册

public boolean regist(User u) {

u.setRegistTime(new Date());

UserDaoImpl userDaoImpl = new UserDaoImpl();

return userDaoImpl.saveUser(u);

}

// 查找 好友
public List<User> listFriends(int qqNumber) {
UserDaoImpl userDaoImpl = new UserDaoImpl();
return userDaoImpl.findAllFriends(qqNumber);

}

// 用户登录
// 通过qq号码和密码查找 某一用户
public User login(int qqNum, String password){
UserDaoImpl userDaoImpl=new UserDaoImpl();
User u =  userDaoImpl.findByNameAndPassword(qqNum, password);
if(u!=null) {
// 获得 本地 IP
try {
String ip =  InetAddress.getLocalHost().toString();
// 修改 数据库 IP
userDaoImpl.updateIp(qqNum, ip);
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
return u;
}

public User listByQqNum(int qqNum){
UserDaoImpl userDaoImpl=new UserDaoImpl();
return userDaoImpl.getUser(qqNum);
}

}

BtnLoginListener.java

// QQ登录监听函数

package com.FakeQQ.user.view;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import com.FakeQQ.entity.User;

import com.FakeQQ.user.service.UserServiceImpl;

public class BtnLoginListener implements ActionListener{

LoginFrame loginFrame;
public BtnLoginListener(LoginFrame loginFrame) {
this.loginFrame = loginFrame;
}

public void actionPerformed(ActionEvent e){
String values = e.getActionCommand();

if(values.equals("确定")) {
String qqNum = loginFrame.txtqqNum.getText();
String password = new String (loginFrame.txtPassword.getPassword());
UserServiceImpl userServiceImpl = new UserServiceImpl();
User user = new User();
user = userServiceImpl.login(Integer.parseInt(qqNum),password);
if(user!=null) {
//System.out.println("登录成功!");
// new JTree
loginFrame.dispose();
loginFrame=null;
MainFrame mainFrame = new MainFrame(user);
}

}else if(values.equals("取消")) {
System.exit(0);
}

}

}

BtnResigerListener.java

package com.FakeQQ.user.view;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import com.FakeQQ.entity.User;

import com.FakeQQ.user.service.UserServiceImpl;

public class BtnResigerListener implements ActionListener {

private ResigerFrame resigerframe = null;

public BtnResigerListener(ResigerFrame resigerframe) {
this.resigerframe = resigerframe;
}
public void actionPerformed(ActionEvent e) {
User user = new User();
String qqName = resigerframe.txtqqName.getText();
String sex = resigerframe.txtSex.getText();
String qqNum = resigerframe.txtqqNum.getText();
String password = new String (resigerframe.txtPassword.getPassword());
String introduce = resigerframe.txtIntroduce.getText();

user.setQqName(qqName);
user.setSex(sex);

// user.setQqNumber(Integer.parseInt(qqNum));

user.setQqPassword(password);

user.setIntroduce(introduce);

UserServiceImpl userServiceImpl = new UserServiceImpl();

boolean flag = userServiceImpl.regist(user);

if(flag==true) {

// System.out.println(“注册成功！”);

}
}

}

LoginFrame.java

“`package com.FakeQQ.user.view;

import java.awt.Dimension;

import java.awt.Toolkit;

import javax.swing.JButton;

import javax.swing.JFrame;

import javax.swing.JLabel;

import javax.swing.JPasswordField;

import javax.swing.JTextField;

public class LoginFrame extends JFrame {

JLabel lblqqNum;

JLabel lblqqPassword;

JTextField txtqqNum;

JPasswordField txtPassword;

JButton btnLogin;

JButton btnCancle;

JButton btnResiger;

// 构造方法
public LoginFrame() {
lblqqNum = new JLabel("QQ号");
lblqqPassword = new JLabel("密码：");
txtqqNum = new JTextField();
txtPassword = new JPasswordField("");
btnLogin = new JButton("确定");
btnCancle = new JButton("取消");
btnResiger = new JButton("QQ注册");

this.getContentPane().setLayout(null); //布局为自己
this.getContentPane().add(lblqqNum);
lblqqNum.setBounds(20,20,80,20);

this.getContentPane().add(lblqqPassword);
lblqqPassword.setBounds(20,50,80,20);

this.getContentPane().add(txtqqNum);
txtqqNum.setBounds(70,20,140,20);

this.getContentPane().add(txtPassword);
txtPassword.setBounds(70,50,140,20);

this.getContentPane().add(btnLogin);
btnLogin.setBounds(60,80,80,20);

this.getContentPane().add(btnCancle);
btnCancle.setBounds(160,80,80,20);

this.getContentPane().add(btnResiger);
btnResiger.setBounds(100,130,90,20);

BtnLoginListener btnLoginListener = new BtnLoginListener(this);
btnLogin.addActionListener(btnLoginListener); //事件源和事件者关联起来
btnCancle.addActionListener(btnLoginListener);

this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//关闭窗口的时候退出应用程序
//设置窗口居中显示
//定义一个工具包
Toolkit kit = Toolkit.getDefaultToolkit();//获得屏幕大小尺寸
Dimension screenSize = kit.getScreenSize();
int screenWidth = screenSize.width;//获得屏幕宽度
int screenHeight = screenSize.height;//获得屏幕高度;
int i = this.getWidth();//获得当前窗体的宽度
int j = this.getHeight();//获得当前窗体的高度
this.setLocation((screenWidth-i)/2, (screenHeight-j)/2);

this.setTitle("QQ登录");
this.setSize(300,200);
this.setVisible(true); // 可见

}

}

MainFrame.java

package com.FakeQQ.user.view;

import java.util.HashMap;

import java.util.List;

import javax.swing.JFrame;

import javax.swing.JScrollPane;

import javax.swing.JTree;

import javax.swing.tree.DefaultMutableTreeNode;

import javax.swing.tree.DefaultTreeModel;

import javax.swing.tree.TreeSelectionModel;

import com.FakeQQ.Message.service.ServerThread;

import com.FakeQQ.Message.view.MessageFrame;

import com.FakeQQ.entity.User;

import com.FakeQQ.user.dao.UserDaoImpl;

import com.FakeQQ.user.service.UserServiceImpl;

public class MainFrame extends JFrame{

public User myself;

public List friends;

public HashMap