本文实现思路：利用udp协议进行局域网信息传输，建立点对点的聊天网络，每个端用户有自己的一个mysql数据库，所以需要获取其数据库用户名和密码，然后通过该数据库内容发送信息，接收消息则没有限制，
步骤：
一、建立数据表存储主机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、显示当前群聊信息
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。
如对本文有疑问， 点击进行留言回复！！
网友评论