?? qqserver.java
字號:
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
String q1="'"+s1.trim()+"'";
String q2="'"+s2.trim()+"'";
String q3="'"+s3.trim()+"'";
String q4="'"+s4.trim()+"'";
String q5="'"+s5.trim()+"'";
String q6="'"+s6.trim()+"'";
String q7="'"+s7.trim()+"'";
rs=sql.executeQuery("select * from yonghuxinxi where 用戶名="+q1);
while(rs.next())
{ try
{
String nn="yiyougaiyonghu";
byte buffer[]=nn.getBytes();
data_send=new DatagramPacket(buffer,buffer.length,address,8888);
send=new DatagramSocket();
send.send(data_send);//提示客戶端數據庫中已有該用戶！
}
catch(Exception e6) {}
text1.append("服務器發送:已有該用戶!"+'\n');
gg=false;
}
if(gg)
{
sql.executeUpdate("insert into yonghuxinxi values("+q1+","+q2+","+q3+","+q4+","+q5+","+q6+","+q7+")");
try
{
String nn="zhucechenggong";
byte buffer[]=nn.getBytes();
data_send=new DatagramPacket(buffer,buffer.length,address,8888);
send=new DatagramSocket();
send.send(data_send); //提示客戶端注冊成功！
text1.append("服務器發送:注冊成功！"+'\n');
con.close();
}
catch(Exception e9) {}
}
}
catch(SQLException e8) {}
}
else if(qq.equals("scanonline"))//掃描所有在線用戶和所有用戶，發送給客戶端
{ String nn="onlineqq";
try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
rs=sql.executeQuery("select * from zaixian");
while(rs.next())
{String str=rs.getString("用戶名");
nn=nn+','+str+',';
}
}
catch(SQLException e) {}
try
{ byte buffer[]=nn.getBytes();
data_send=new DatagramPacket(buffer,buffer.length,address,8888);
send=new DatagramSocket();
send.send(data_send);
text1.append("服務器發送："+nn+'\n');
}
catch(Exception e3){}
String nnn="suoyouyonghu";
try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
rs=sql.executeQuery("select * from yonghuxinxi");
while(rs.next())
{String str=rs.getString("用戶名");
nnn=nnn+','+str+',';
}
}
catch(SQLException e) {}
try
{ byte buffer[]=nnn.getBytes();
data_send=new DatagramPacket(buffer,buffer.length,address,8888);
send=new DatagramSocket();
send.send(data_send);
text1.append("服務器發送："+nnn+'\n');
}
catch(Exception e3){}
}
else if(qq.equals("liaotianshuju"))//客戶端發來的數據包為聊天數據，根據目的用戶名查詢其IP地址進行轉發
{ InetAddress qfq=null;
String ip=null;
try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
String q1="'"+s2.trim()+"'";
rs=sql.executeQuery("select * from zaixian where 用戶名="+q1);
while(rs.next())
{ ip=rs.getString("ip地址");
}
try
{
qfq=InetAddress.getByName(ip);
}
catch(UnknownHostException e) {}
try
{
String nn="liaotianshuju"+','+s1+','+s3;
byte buffer[]=nn.getBytes();
data_send=new DatagramPacket(buffer,buffer.length,qfq,8888);
send=new DatagramSocket();
send.send(data_send);
text1.append("服務器發送："+nn+'\n');
}
catch(Exception e6) {}
}
catch (SQLException e2) {}
}
else if(qq.equals("chaxungerenxinxi")) //接收的數據包請求為查詢個人信息
{ String w1=null,w2=null,w3=null,w4=null,w5=null,w6=null;
try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
String q1="'"+s1.trim()+"'";
rs=sql.executeQuery("select * from yonghuxinxi where 用戶名="+q1);
while(rs.next())
{w1=rs.getString("用戶名");
w2=rs.getString("學院");
w3=rs.getString("班級");
w4=rs.getString("QQ號");
w5=rs.getString("手機號");
w6=rs.getString("出生日期");
}
con.close();
}
catch(SQLException e8) {}
String nn="gerenxinxi"+','+w1+','+w2+','+w3+','+w4+','+w5+','+w6;
try
{ byte buffer[]=nn.getBytes();
data_send=new DatagramPacket(buffer,buffer.length,address,8888);
send=new DatagramSocket();
send.send(data_send);
}
catch(Exception e3){}
}
else if(qq.equals("qqxiaxian"))//客戶端通知服務器端下線，服務器端將其從在線列表中刪除
{ try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
String zz="'"+s1.trim()+"'";
sql.executeUpdate("delete from zaixian where 用戶名="+zz);
con.close();
}
catch(SQLException e8) {}
}
else if(qq.equals("xiugaigerenmima")) //客戶端請求修改其登錄密碼
{ try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
String q1="'"+s1.trim()+"'";
String q2="'"+s2.trim()+"'";
sql.executeUpdate("update yonghuxinxi set 密碼="+q2+" where 用戶名="+q1);
con.close();
}
catch(SQLException e3) {}
String nn="xiugaigerenmimachenggong"+',';
try
{ byte buffer[]=nn.getBytes();
data_send=new DatagramPacket(buffer,buffer.length,address,8888);
send=new DatagramSocket();
send.send(data_send); //服務器通知客戶端修改密碼成功
}
catch(Exception e3){}
}
else if(qq.equals("xiugaigerenxinxi")) //客戶端請求修改其個人信息
{ try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
String q1="'"+s1.trim()+"'";
String q2="'"+s2.trim()+"'";
String q3="'"+s3.trim()+"'";
String q4="'"+s4.trim()+"'";
String q5="'"+s5.trim()+"'";
String q6="'"+s6.trim()+"'";
sql.executeUpdate("update yonghuxinxi set 學院="+q2+" where 用戶名="+q1);
sql.executeUpdate("update yonghuxinxi set 班級="+q3+" where 用戶名="+q1);
sql.executeUpdate("update yonghuxinxi set QQ號="+q4+" where 用戶名="+q1);
sql.executeUpdate("update yonghuxinxi set 手機號="+q5+" where 用戶名="+q1);
sql.executeUpdate("update yonghuxinxi set 出生日期="+q6+" where 用戶名="+q1);
con.close();
}
catch(SQLException e3) {}
String nn="xinxixiugaichenggong"+',';
try
{ byte buffer[]=nn.getBytes();
data_send=new DatagramPacket(buffer,buffer.length,address,8888);
send=new DatagramSocket();
send.send(data_send); //服務器通知客戶端修改個人信息成功
}
catch(Exception e3){}
}
else if(qq.equals("filetransfer"))//在線用戶之間傳送文本文件，由服務器進行轉發
{ InetAddress qfq=null;
String ip=null;
try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
String q1="'"+s2.trim()+"'";
rs=sql.executeQuery("select * from zaixian where 用戶名="+q1);
while(rs.next())
{ ip=rs.getString("ip地址");
}
try
{
qfq=InetAddress.getByName(ip);
}
catch(UnknownHostException e) {}
}
catch (SQLException e2) {}
try
{
String nn="filetransfer"+','+s3+','+s.substring(qq.length()+s1.length()+s2.length()+s3.length()+4);
byte buffer[]=nn.getBytes();
data_send=new DatagramPacket(buffer,buffer.length,qfq,8888);
send=new DatagramSocket();
send.send(data_send);
}
catch(Exception e6) {}
}
else if(qq.equals("lixianwenjian"))//客戶端發送離線文件，服務器負責存儲，并在數據庫中添加相應的記錄
{ String q1="",q2="",q3="";
try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
q1="'"+s1.trim()+"'";
q2="'"+s2.trim()+"'";
q3="'"+s3.trim()+"'";
String q4="'"+s1.trim()+s2.trim()+s3.trim()+"'";
sql.executeUpdate("insert into lixianwenjian values("+q1+","+q2+","+q4+")");
}
catch(SQLException e4) {}
String wenjianming=s1.trim()+s2.trim()+s3.trim();
String filedata=s.substring(qq.length()+s1.length()+s2.length()+s3.length()+4);
try
{File file=new File("E:\\wenjian",wenjianming);
tofile=new FileWriter(file);
bout=new BufferedWriter(tofile);
bout.write(filedata,0,filedata.length());
bout.flush();
bout.close();
tofile.close();
}
catch(IOException e9) {}
}
else if(qq.equals("liuyan")) //客戶端請求留言，服務器在數據庫中添加相應的記錄
{ try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
String q1="'"+s1.trim()+"'";
String q2="'"+s2.trim()+"'";
String q3="'"+s3.trim()+"'";
String q4="'"+s4.trim()+"'";
sql.executeUpdate("insert into liuyan values("+q1+","+q2+","+q3+","+q4+")");
}
catch(SQLException e3) {}
}
}
public void actionPerformed(ActionEvent e)//服務器廣播信息給所有在線用戶
{if(e.getSource()==button)
{try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");}
catch(ClassNotFoundException e2) {}
InetAddress bc=null;
try
{
con=DriverManager.getConnection("jdbc:odbc:qqserver","","");
sql=con.createStatement();
rs=sql.executeQuery("select * from zaixian ");
while(rs.next())
{String aa=rs.getString("ip地址");
try
{
bc=InetAddress.getByName(aa);
}
catch(UnknownHostException e3) {}
String nn="broadcast"+'\n'+text2.getText();
byte buffer[]=nn.trim().getBytes();
try
{ data_send=new DatagramPacket(buffer,buffer.length,bc,8888);
send=new DatagramSocket();
send.send(data_send);
Date date1=new Date();
text1.append("服務器廣播："+text2.getText()+'\n');
}
catch(Exception e5) {}
}
con.close();
}
catch(SQLException e8) {}
}
}
}
public class qqserver
{ public static void main(String ll[])
{fuwuqi jj=new fuwuqi();
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -