本文实现思路：利用UDP协议进行局域网信息传输，建立点对点的聊天网络，每个端用户有自己的一个mysql数据库，所以需要获取其数据库用户名和密码，然后通过该数据库内容发送信息，接收消息则没有限制，
步骤：
- 建立数据表存储主机ip，接收信息端口port，nickname
- 向所有用户发送信息
- 接收信息
- 小部件（添加好友，删除好友）
一、建立数据表存储主机ip，接收信息端口port，nickname
在mysql数据库里建立chatusr数据表，表的格式为：
检测表是否存在和建立数据表的代码如下：
java;" style="margin: 3px auto 0px; padding: 0px 0px 0px 5px; outline: none; background-image: initial; background-position: initial; background-size: initial; background-repeat: initial; background-attachment: initial; background-origin: initial; background-clip: initial; width: 640px; line-height: 20px; clear: both; border-left: 3px solid rgb(108, 226, 108);"> 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、显示当前群聊信息
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持CuoXin错新网。
注：相关教程知识阅读请移步到JAVA教程频道。
