話不多說，先上圖
即時通信系統:可以完成群聊、私人聊天，實時發送和顯示聊天資訊，完成好友串列,進一步可以帶表情，附件發送，聊天資訊的傳送，等 系統的主要技術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
下載鏈接https://download.csdn.net/download/qq_44716544/12352588
gitee下載鏈接https://gitee.com/c-xiaobai-c/java-chat-system.git
注冊，下面是資料庫的關鍵代碼，主要用于驗證賬號的唯一性和昵稱的唯一性，主要用到了二重判斷，先是判斷賬號的唯一，然后再判斷昵稱的唯一，當有一條件不足則注冊失敗，下邊代碼主要是資料庫的查詢功能，先是查詢資料庫中有沒有該賬號，然后查資料庫中有沒該昵稱，最后把注冊資訊存盤進資料庫，不過下面只展示了查詢的代碼，儲存資訊代碼類似這里不做展示，
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());
轉載請註明出處，本文鏈接：https://www.uj5u.com/ruanti/280243.html
標籤：其他
上一篇：第七章 青蛙跳臺階和漢諾塔問題
下一篇：寫給Java 工程師們一封信