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

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

本文实现思路：利用UDP协议进行局域网信息传输，建立点对点的聊天网络，每个端用户有自己的一个mysql数据库，所以需要获取其数据库用户名和密码，然后通过该数据库内容发送信息，接收消息则没有限制，

步骤：

建立数据表存储主机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

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.getAddrIXyvCOcbxaess().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

if(t_ip.equals(ip[ti])) {

break;

}

}

if(ti==num) {

mysql="Insert Into chatusr Values ('"+t_IXyvCOcbxaip+"','"+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链接

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.getAddrIXyvCOcbxaess().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

if(t_ip.equals(ip[ti])) {

break;

}

}

if(ti==num) {

mysql="Insert Into chatusr Values ('"+t_IXyvCOcbxaip+"','"+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链接

if(t_ip.equals(ip[ti])) {

break;

}

}

if(ti==num) {

mysql="Insert Into chatusr Values ('"+t_IXyvCOcbxaip+"','"+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链接

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。