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

发布时间:2021-02-18 10:34:15 作者:小新
来源:亿速云 阅读:198

这篇文章将为大家详细讲解有关java+jdbc+mysql+socket搭建局域网聊天室的案例,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。

步骤:

一、建立数据表存储主机ip,接收信息端口port,nickname

在mysql数据库里建立chatusr数据表,表的格式为:

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

检测表是否存在和建立数据表的代码如下:

 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、显示当前群聊信息

关于“java+jdbc+mysql+socket搭建局域网聊天室的案例”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。

推荐阅读:
  1. 搭建Websocket简易聊天室
  2. PHP案例之聊天室设计

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

java mysql socket

上一篇:Hadoop如何安装

下一篇:如何搭建selenium3+python3环境

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》