java+jdbc+mysql+socket搭建局域網(wǎng)聊天室

2024-07-14 08:43:30

字體：大中小

供稿：網(wǎng)友

本文實現(xiàn)思路：利用UDP協(xié)議進(jìn)行局域網(wǎng)信息傳輸，建立點對點的聊天網(wǎng)絡(luò)，每個端用戶有自己的一個mysql數(shù)據(jù)庫，所以需要獲取其數(shù)據(jù)庫用戶名和密碼，然后通過該數(shù)據(jù)庫內(nèi)容發(fā)送信息，接收消息則沒有限制，

步驟：

建立數(shù)據(jù)表存儲主機(jī)ip，接收信息端口port，nickname
向所有用戶發(fā)送信息
接收信息
小部件（添加好友，刪除好友）

一、建立數(shù)據(jù)表存儲主機(jī)ip，接收信息端口port，nickname

在mysql數(shù)據(jù)庫里建立chatusr數(shù)據(jù)表，表的格式為：

java,jdbc,mysql,socket,局域網(wǎng)聊天室

檢測表是否存在和建立數(shù)據(jù)表的代碼如下：

 void linkdb() {    try {      Class.forName("com.mysql.jdbc.Driver");      conn = DriverManager.getConnection(url,user,password);      DatabaseMetaData dbmd=conn.getMetaData();      ResultSet tableRS = dbmd.getTables(null, null, "chatusr", null );      if (tableRS.next())        System.out.println(" the table is exsited");      else {        String sql = "CREATE TABLE chatusr(";          sql+= " ip char(15),";          sql+= " port int(6),";          sql+= " name char(255),";        sql+="PRIMARY KEY(ip))";        pst=conn.prepareStatement(sql);        pst.executeUpdate();      }    } catch (SQLException e) {      // TODO 自動生成的 catch 塊      e.printStackTrace();    } catch (ClassNotFoundException e) {      // TODO 自動生成的 catch 塊      e.printStackTrace();    }    System.out.println("連接數(shù)據(jù)庫成功");  }

二、向所有用戶發(fā)送信息

向所有數(shù)據(jù)庫中成員和自己發(fā)送消息；

【問題一】：string在存儲中文字符時和byte[]轉(zhuǎn)換時長度不一樣和亂碼問題
【解決方法】：用GBK標(biāo)準(zhǔn)進(jìn)行轉(zhuǎn)換以解決中文亂碼問題，GBK標(biāo)準(zhǔn)下一個中文字符為兩個char，因此可以用一個函數(shù)先計算出string轉(zhuǎn)換成byte[]后的長度，再按照這個長度進(jìn)行傳輸數(shù)據(jù)即可
【問題二】：由于UDP協(xié)議中的數(shù)據(jù)報不包含用戶自定義的接收信息端口，因此，我把UDP傳輸?shù)臄?shù)據(jù)前四位設(shè)置成端口位置，每次發(fā)送信息時都會把自己的接受信息的端口加在頭部，這樣就能實現(xiàn)，當(dāng)一個未知主機(jī)向我發(fā)送信息時，還能回復(fù)其信息。

public int getlength(byte[] conf) {    int c=0,i;    for(i=0;i<250;++i)      if(conf[i]==10)//'/0'的編碼為10，表示數(shù)組結(jié)尾        break;    return i+1;  }public void send(String message) {      String string=m_port;       //string+=sendcontent.getText();      string+=message;      byte[] databyte = new byte[250];      try {        databyte=string.getBytes("GBK");      } catch (UnsupportedEncodingException e1) {        // TODO 自動生成的 catch 塊        e1.printStackTrace();      }      //string.getBytes(0, string.length(), databyte, 0);      int len=getlength(databyte);    //發(fā)送給自己    try {      DatagramPacket sendPacket = new DatagramPacket(databyte,len, java.net.InetAddress.getByName(m_ip), Integer.parseInt(m_port));      sendSocket=new DatagramSocket();      sendSocket.send(sendPacket);    } catch (IOException ioe) {      record.append("網(wǎng)絡(luò)通信出現(xiàn)錯誤，問題在于" + ioe.toString());    }    //發(fā)送給其他人    for(int ti=0;ti<num;++ti) {      try {        DatagramPacket sendPacket = new DatagramPacket(databyte, len, java.net.InetAddress.getByName(ip[ti]), Integer.parseInt(port[ti]));        sendSocket=new DatagramSocket();        sendSocket.send(sendPacket);      } catch (IOException e) {        // TODO 自動生成的 catch 塊        e.printStackTrace();      }    }  }

三、接收信息

接收消息時將信息和端口信息分開，若為陌生人，可以將其主機(jī)ip和端口加到數(shù)據(jù)庫里，

public void run() {    // TODO 自動生成的方法存根    while (true) {      try {        byte buf[] = new byte[250];        receivePacket = new DatagramPacket(buf, buf.length);        receiveSocket.receive(receivePacket);        String t_ip = receivePacket.getAddress().toString().trim();        t_ip=t_ip.substring(1);//獲取ip        String t_name="unname";        Date date=new Date();        byte[] data = receivePacket.getData();        String receivedString = new String(data, "GBK");        String t_port = receivedString.substring(0,4);//獲取端口        receivedString=receivedString.substring(4);        if(t_ip.equals(m_ip)) {          t_name=m_name;          record.append("來自本機(jī)://" + t_ip + "/n端口:" + receivePacket.getPort()+"/n時間:"+ date.toString());          record.append("/n"+t_name+":/t");        }        else {          int ti=0;          for(ti=0;ti<num;++ti) {            if(t_ip.equals(ip[ti])) {              break;            }          }          if(ti==num) {            mysql="Insert Into chatusr Values ('"+t_ip+"','"+Integer.parseInt(t_port)+"','"+t_name+"')";            if(mm.add(mysql))              System.out.println("插入成功");            t_name="unnamed";          }          else {            t_name=name[ti];          }          record.append("/n來自主機(jī)://" + t_ip + "/n端口:" + receivePacket.getPort()+"/n時間:"+ date.toString());          record.append("/n"+t_name+":/t");        }        record.append(receivedString+"/n");      } catch (IOException e) {        record.append("網(wǎng)絡(luò)通信出現(xiàn)錯誤,問題在于" + e.toString());      }      record.selectAll();    }  }

四、小部件

1、添加好友、刪除好友
2、顯示當(dāng)前群聊信息