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搭建局域网聊天室的案例”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。