话不多说，先上图
即时通信系统:可以完成群聊、私人聊天，实时发送和显示聊天信息，完成好友列表,进一步可以带表情，附件发送，聊天信息的传送，等 系统的主要技术socket通信技术，多线程技术，数据库技术。
本系统实现的功能有:1.用户名字登录 2.用户之间的群聊和查看群聊记录3.用户之间的私聊和私聊记录4.动态刷新并显示好友列表5.显示在线人数 6.服务器可以显示用户在线状态 7.能够退出处理。
该程序可以实现局域网的聊天，只要把ip改为局域网ip即可。该系统ui中有许多没实现的功能，比如添加好友（通过验证成为好友），发布说说到空间，然后可以进行点赞和评论等。
有兴趣的可进行拓展。。系统视频效果观看链接http://m.v.qq.com/play.html?cid=&vid=f3241h0cgfo&vuid24=7dp8aai1y0ypjr%2fiswf3dq%3d%3d&url_from=share&second_share=0&share_from=copy&pgid=page_detail&mod_id=mod_toolbar_new
下载链接
gitee下载链接
注册，下面是数据库的关键代码，主要用于验证账号的唯一性和昵称的唯一性，主要用到了二重判断，先是判断账号的唯一，然后再判断昵称的唯一，当有一条件不足则注册失败，下边代码主要是数据库的查询功能，先是查询数据库中有没有该账号，然后查数据库中有没该昵称，最后把注册信息存储进数据库，不过下面只展示了查询的代码，储存信息代码类似这里不做展示。
connectionlain c = new connectionlain();
connection conn = c.getconnect();
preparedstatement ps = null;
resultset rs = null;
try {
ps = conn.preparestatement("select *from userlist where name=?");
ps.setstring(1, textloginname.gettext());
rs = ps.executequery();
if (rs.next()) {
joptionpane.showmessagedialog(this, "该昵称已存在,请重新填写昵称");
} else {
save();
}
} catch (sqlexception e1) {
// todo auto-generated catch block
//e1.printstacktrace();
}
finally{
try {
rs.close();
ps.close();
// ct.close();
} catch (sqlexception e1) {
e1.printstacktrace();
}
}
联系人页面，主要用到了数据库的读取功能，对已登录的用户账号进行读取，还用到了jlist列表，把已登录的用户账号显示在好友列。
下面展示关键代码：
list = new jlist(listmodel);
list.setselectionmode(listselectionmodel.single_selection);// 设置单 一选择模式（每次只能有一个元素被选中）
list.setcellrenderer(new mycellrenderer(icons));//使用自己的cellrenderer，使用图片功能
listscroller = new jscrollpane(list);
listscroller.setbounds(20,300,465,350);//添加带滚动条的list
//list.setbounds(20,300,450,350);
listscroller.setbackground(new color(30, 144, 255));
listscroller.setopaque(false);
listscroller.setborder(null);
//this.add(listscroller,borderlayout.center);//添加带滚动条的list
//this.add(list);
this.add(listscroller);
listmodel = new defaultlistmodel();
try {
class.forname("com.mysql.jdbc.driver");
//(2)获取数据库连接
connection ct=drivermanager.getconnection("jdbc:mysql://127.0.0.1:3306/check?useun icode=true&characterencoding=utf_8","root", "123");
//（3）创建sql语句对象
statement ps=ct.createstatement();
//(4)执行查询，返回结果集
resultset rs=ps.executequery("select * from userlist2");
string []data1=new string [1];
while(rs.next()){
//if(rs.next()){
//rowdata可以存放多行
string st1=rs.getstring(1);
data1[0] =rs.getstring(1);
for(int i=0;i<data1.length;i++){
listmodel.add(i, data1[i]);//添加登录的用户到列表框
}
system.out.println(data1[0]);
}} catch (exception e1) {
e1.printstacktrace();
} finally{
try {
if(rs!=null){
rs.close();
}
if(ps!=null){
ps.close();
}
if(ct!=null){
ct.close();
}
} catch (sqlexception e1) {
e1.printstacktrace();
}
因为群聊和私聊的代码相似，只展示私聊关键代码；下面展示关键代码：
string serverip="127.0.0.1";
int serverport=8000;
//连接服务器，获取套接字io流
socket=new socket(serverip,serverport);
dis=new datainputstream(socket.getinputstream());
dos=new dataoutputstream(socket.getoutputstream());
//获取用户名，构建，发送登陆报文
string id2="好友"+id1;
string msglogin="login#"+id2;
dos.writeutf(msglogin);
dos.flush();
//读取服务器返回的信息，判断是否登录成功
string response=dis.readutf();
//登陆失败
if(response.equals("fail")){
addmsg("登陆失败");
system.out.println("登陆失败");
socket.close();
return;
}
//登陆成功
if(response.equals("success")){
addmsg("登陆成功");
islogged=true;
btnsend.setenabled(true);
}
}
public void run(){
//连接服务器并登录
try{
login();
}catch(ioexception e){
//addmsg("连接服务器时出现异常");
e.printstacktrace();
system.out.println("连接服务器时出现异常");
return;
}
while(islogged){
try{
string msg=dis.readutf();
string[] parts=msg.split("#");
//处理服务器发送过来的报文
if(parts[0].equals("userlist")){
for(int i=1;i<parts.length;i++){
}
}
if(parts[0].equals("login")){
addmsg(parts[1]+"上线了");
}
if(parts[0].equals("logout")){
}
if(parts[0].equals("talkto_all")){
addmsg(parts[1]+"跟所有人说:"+parts[2]);
}
if(parts[0].equals("talkto")){
addmsg(parts[1]+"跟我说:"+parts[2]);
}
}catch(ioexception e){
islogged=false;
e.printstacktrace();
}
}
}
}
//启动线程
private void start(){
clientthread=new clientthread();
clientthread.start();
}
private void addmsg(string msg)
textarearecord.append(msg+"\n");
//自动滚动到文本区的最后一行
textarearecord.setcaretposition(textarearecord.gettext().length());
new save();
}
private void addmsg2(string msg){
textarearecord.append("\t"+"\t"+"\t"+"\t"+msg+":"+"用户"+id1+"\n");
//自动滚动到文本区的最后一行
textarearecord.setcaretposition(textarearecord.gettext().length());
new save()；
}
class save{
public save(){
try {
// 注册mysql驱动程序
class.forname("com.mysql.jdbc.driver");//driver
system.out.println("找到mysql数据库驱动程序");
} catch (exception e1) {
system.out.println("在类路径上找不到mysql驱动程序，" + "请检查类路径上是否加载mysql的jar包!");
}
// (3)获取数据库连接
connection conn = null;// 同时按下ctrl+shift+o
try {
conn = drivermanager.getconnection(
"jdbc:mysql://127.0.0.1:3306/check?charcterencoding=utf-8", "root", "123");//(url,username,password)
system.out.println("建立数据库连接成功");
} catch (exception e1) {
e1.printstacktrace();
system.out.println("创建数据库连接失败！");
}
// （4）创建一个sql语句执行（需要在java执行sql语句）
statement stmt = null;
try {
// 通过conn对象创建sql语句对象
stmt = conn.createstatement();
} catch (exception e1) {
e1.printstacktrace();
}
string sql = "insert into usermessage2 (message2) values('"+textarearecord.gettext()+"')";
try {
// 执行sql语句
stmt.executeupdate(sql);
// joptionpane op7=new joptionpane();
// op7.showmessagedialog(null, "注册成功");
system.out.println("数据插入成功");
// joptionpane.showmessagedialog(this, "注册成功");
} catch (exception e1) {
e1.printstacktrace();
system.out.println("插入失败");
}
//(6)关闭资源
try {
stmt.close();
conn.close();
} catch (exception e1) {
e1.printstacktrace();
服务器 主要用到了网络通信和多线程的功能
try{
//获取serverip和serverpoet
string serverip=textserverip.gettext();
int serverport=integer.parseint(textport.gettext());
//创建套接字地址
socketaddress socketaddress=new inetsocketaddress(serverip,serverport);
//创建serversocket，绑定套接字地址
server=new serversocket();
server.bind(socketaddress);
//修改判断服务器是否运行的标识变量
isrunning=true;
btnstart.setenabled(false);
btnstop.setenabled(true);
addmsg("服务器启动成功");
system.out.println("服务器启动成功");
}catch(ioexception e){
system.out.println("服务器启动失败");
e.printstacktrace();
isrunning=false;
}
}
public void run(){
startserver();
//当服务器处于运行状态时，循环监听客户端的连接请求
while(isrunning){
try{
socket socket=server.accept();
//创建与客户端交互的线程
thread thread=new thread(new clienthandler(socket));
thread.start();
}catch(ioexception e){
system.out.println("还没连接");
}
}
}
}
class clienthandler implements runnable{
private socket socket;
private datainputstream dis;
private dataoutputstream dos;
private boolean isconnected;
private string username;
public clienthandler(socket socket){
this.socket=socket;
try{
this.dis=new datainputstream(socket.getinputstream());
this.dos=new dataoutputstream(socket.getoutputstream());
isconnected=true;
}catch(ioexception e){
isconnected=false;
e.printstacktrace();
}
}
public void run(){
while(isrunning&&isconnected){
try{
//读取客户端发送的报文
string msg=dis.readutf();
string[] parts=msg.split("#");
if(parts[0].equals("login")){
string loginusername=parts[1];
date date3=new date();
simpledateformat f2=new simpledateformat("yyyy-mm-dd hh:mm:ss");
string d3=f2.format(date3);
string q="用户:"+parts[1]+""+"已登录"+"\t"+d3;
addmsg(q);
//如果该用户已登录，则返回失败报文，否则返回成功报文
if(clienthandlermap.containskey(loginusername)){
dos.writeutf("fail");
}else{
dos.writeutf("success");
//将此客户端处理线程的信息添加到clienthandlermap中
clienthandlermap.put(loginusername, this);
//将现有用户的信息发给新用户
stringbuffer msguserlist=new stringbuffer();
msguserlist.append("userlist");
for(string username : clienthandlermap.keyset()){
msguserlist.append(username +"#");
}
dos.writeutf(msguserlist.tostring());
//将新登录的用户信息发给其他用户
string msglogin="login#"+loginusername;
broadcastmsg(loginusername,msglogin);
//存储登录的用户名
this.username=loginusername;
}
}
if(parts[0].equals("logout")){
clienthandlermap.remove(username);
string msglogout="logout#"+username;
//broadcastmsg(username,msglogout);
isconnected=false;
socket.close();
}
if(parts[0].equals("talkto_all")){
string msgtalktoall="talkto_all#"+username+"#"+parts[1]; date date3=new date();
simpledateformat f2=new simpledateformat("yyyy-mm-dd hh:mm:ss");
string d3=f2.format(date3);
string p="用户 "+username+"对所有人说"+parts[1]+"\t"+d3;
addmsg2(p);
broadcastmsg(username,msgtalktoall);}
if(parts[0].equals("talkto")){
clienthandler clienthandler=clienthandlermap.get(parts[1]);
if(null!=clienthandler){
string msgtalkto="talkto#"+username+"#"+parts[2];
date date3=new date();
simpledateformat f2=new simpledateformat("yyyy-mm-dd hh:mm:ss");
string d3=f2.format(date3);
string p2="用户 "+clienthandler+" 对"+username+"说: "+parts[2]+"\t"+d3;
addmsg2(p2);
clienthandler.dos.writeutf(msgtalkto);
clienthandler.dos.flush();
}
}
}catch(ioexception e){
isconnected=false;
e.printstacktrace();
}
}
}
/**
* 将某个用户发来的信息广播个其他用户
*/
private void broadcastmsg(string fromusername,string msg) throws ioexception{
for(string tousername : clienthandlermap.keyset()){
if(fromusername.equals(tousername)==false){
dataoutputstream dos=clienthandlermap.get(tousername).dos;
dos.writeutf(msg);
dos.flush();
}
}
}
}
/**
* 添加消息到文本框
*/
private void addmsg(string msg){
//在文本区添加一条消息，并加上换行
textarearecord.append(msg+"\n");
textarearecord.setcaretposition(textarearecord.gettext().length());
到此这篇关于java仿qq微信聊天室的文章就介绍到这了,更多相关java聊天室内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com！
黄山市民网：https://www.huangshanshimin.com/
