java+jdbc+mysql+socket搭建局域網聊天室的案例

這篇文章將為大家詳細講解有關java+jdbc+mysql+socket搭建局域網聊天室的案例，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

步驟：

• 建立數據表存儲主機ip，接收信息端口port，nickname

• 向所有用戶發送信息

• 接收信息

• 小部件（添加好友，刪除好友）

一、建立數據表存儲主機ip，接收信息端口port，nickname

在mysql數據庫里建立chatusr數據表，表的格式為：

檢測表是否存在和建立數據表的代碼如下：

 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("連接數據庫成功");
  }

二、向所有用戶發送信息

向所有數據庫中成員和自己發送消息；

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

public int getlength(byte[] conf) {
    int c=0,i;
    for(i=0;i<250;++i)
      if(conf[i]==10)//'\0'的編碼為10，表示數組結尾
        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);
    //發送給自己
    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("網絡通信出現錯誤，問題在于" + ioe.toString());
    }
    //發送給其他人
    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();
      }
    }
  }

三、接收信息

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

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("來自本機:\\" + 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來自主機:\\" + t_ip + "\n端口:" + receivePacket.getPort()+"\n時間:"+ date.toString());
          record.append("\n"+t_name+":\t");
        }
        record.append(receivedString+"\n");
      } catch (IOException e) {
        record.append("網絡通信出現錯誤,問題在于" + e.toString());
      }
      record.selectAll();
    }
  }

四、小部件

1、添加好友、刪除好友
2、顯示當前群聊信息

• 功能很簡單，大家可以根據這個框架，自己完善，

• 代碼太亂，貼一個github鏈接

關于“java+jdbc+mysql+socket搭建局域網聊天室的案例”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。