快捷導(dǎo)航

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

更新時(shí)間：2022年05月19日 17:04:58 作者：ziv404

這篇文章主要為大家詳細(xì)介紹了java+jdbc+mysql+socket搭建局域網(wǎng)聊天室，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

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

步驟：

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

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

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

檢測(cè)表是否存在和建立數(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 自動(dòng)生成的 catch 塊
      e.printStackTrace();
    } catch (ClassNotFoundException e) {
      // TODO 自動(dòng)生成的 catch 塊
      e.printStackTrace();
    }
    System.out.println("連接數(shù)據(jù)庫成功");
  }

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

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

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

三、接收信息

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

public void run() {
    // TODO 自動(dòng)生成的方法存根
    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時(shí)間:"+ 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時(shí)間:"+ date.toString());
          record.append("\n"+t_name+":\t");
        }
        record.append(receivedString+"\n");
      } catch (IOException e) {
        record.append("網(wǎng)絡(luò)通信出現(xiàn)錯(cuò)誤,問題在于" + e.toString());
      }
      record.selectAll();
    }
  }

四、小部件

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