📄 server.java
字号:
{newuser newme=new newuser();newme.setVisible(true);}
else if(e.getSource()==Server.me_item2)
{try
{String tempman=Server.liconnect.getSelectedItem();
String s1="'"+tempman+"'";String s2="'"+""+"'";String s3="'"+""+"'";
String temp="DELETE FROM t_pass WHERE passname="+s1+"";
System.out.println(temp);
System.out.println(""+sql.executeUpdate(temp));
server_wmessage wm=new server_wmessage("删除成功"," 你已经成功删除用户");wm. setBounds(100,170,440,130);wm.setVisible(true);
}
catch(SQLException e1){}}
else if(e.getSource()==Server.me_item3)
{try
{KeyGenerator kg=KeyGenerator.getInstance("DESede");
kg.init(168);
SecretKey k=kg.generateKey();
FileOutputStream f=new FileOutputStream("key1.dat");
ObjectOutputStream b=new ObjectOutputStream(f);
b.writeObject(k);}
catch(Exception e1){}
server_wmessage wm=new server_wmessage("添加成功"," 你已经成功添加对称密钥");wm. setBounds(100,170,440,130);wm.setVisible(true);
}
else if(e.getSource()==Server.me_item4)
{try
{KeyPairGenerator kpg=KeyPairGenerator.getInstance("RSA");
kpg.initialize(1024);
KeyPair kp=kpg.genKeyPair();
PublicKey pbkey=kp.getPublic();
PrivateKey prkey=kp.getPrivate();
FileOutputStream f1=new FileOutputStream("Skey_RSA_pub.dat");
ObjectOutputStream b1=new ObjectOutputStream(f1);
b1.writeObject(pbkey);
FileOutputStream f2=new FileOutputStream("Skey_RSA_pri.dat");
ObjectOutputStream b2=new ObjectOutputStream(f2);
b2.writeObject(prkey);
}
catch(Exception e1){}
server_wmessage wm=new server_wmessage("添加成功"," 你已经成功添加非对称密钥");wm. setBounds(100,170,440,130);wm.setVisible(true);
}
else if(e.getSource()==Server.see)
{Server.a_message.setText("");String tempmessage,tempdate;
try
{
rs=sql.executeQuery("SELECT * FROM t_message");
while(rs.next())
{tempmessage=rs.getString(2);tempdate=rs.getString(4);
if(tempdate.trim().equals(Server.see.getText().trim()))
{Server.a_message.append(tempmessage+"\n");
}
}
}
catch(SQLException e1){}
}
else if(e.getSource()==Server.b_all)
{is_one=1;
Server.liconnect.removeAll();
String p_name;
try
{
rs=sql.executeQuery("SELECT * FROM t_pass");
while(rs.next())
{p_name=rs.getString(1);Server.liconnect.add(p_name);
}
}
catch(SQLException e1){}
}
else if(e.getSource()==Server.b_online)
{is_one=0;//Server.mylist.clear();
Server.liconnect.removeAll();
String p_name;//date indata,outdata;
try
{
rs=sql.executeQuery("SELECT * FROM t_online");
while(rs.next())
{p_name=rs.getString(1);Server.liconnect.add(p_name);//Sever.mylist.add(p_name);
}
}
catch(SQLException e1){}
}
else if(e.getSource()==Server.d_all)
{try
{String tempman=Server.liconnect.getSelectedItem();
String s1="'"+tempman+"'";String s2="'"+""+"'";String s3="'"+""+"'";
String temp="DELETE FROM t_pass WHERE passname="+s1+"";
System.out.println(temp);
System.out.println(""+sql.executeUpdate(temp));
server_wmessage wm=new server_wmessage("删除成功"," 你已经成功删除用户");wm. setBounds(100,170,440,130);wm.setVisible(true);
}
catch(SQLException e1){}
}
else if(e.getSource()==Server.d_online)
{try
{String tempman=Server.liconnect.getSelectedItem();
String sqlname,port;
rs=sql.executeQuery("SELECT * FROM t_pass ");
while(rs.next())
{sqlname=rs.getString(1);
port=rs.getString(4);
if(sqlname.trim().equals(tempman.trim()))
{Server.liconnect.remove(sqlname);
sen.smess("stop",Integer.parseInt(port.trim()));
break;
}
}
String outman=tempman;
String s1="'"+tempman+"'";String s2="'"+""+"'";String s3="'"+""+"'";String temp="DELETE FROM t_online WHERE name="+s1+"";
System.out.println(""+sql.executeUpdate(temp));
server_wmessage wm=new server_wmessage("删除成功"," 你已经成功阻止用户在线");wm. setBounds(100,170,440,130);wm.setVisible(true);
}
catch(SQLException e1){}
}
else if(e.getSource()==Server.liconnect)
{String temp=new String();
String selectname=Server.liconnect.getSelectedItem();
String belong_dept=new String("");
String sqlname,sqlword,is_message,port,sqldebe,pass_con1="",pass_con2="",pass_con3="",pass_con4="",pass_con5="";
try
{
rs=sql.executeQuery("SELECT * FROM t_pass ");
while(rs.next())
{sqlname=rs.getString(1);sqlword=rs.getString(2);is_message=rs.getString(3);
port=rs.getString(4);sqldebe=rs.getString(5);pass_con1=rs.getString(6); pass_con2=rs.getString(7); pass_con3=rs.getString(8);
if(selectname.trim().equals(sqlname.trim()))
{temp="客户名:"+sqlname.trim()+"\n"+"客户端口:"+port.trim()+"\n"+"所属部门:"+sqldebe.trim()+"\n"+"所能发信息的部门:"+pass_con1.trim()+","+pass_con2.trim()+","+pass_con3.trim();
break;
}
}
}
catch(SQLException e2){};
server_wmessage wm=new server_wmessage("发送提示",temp);wm. setBounds(100,170,440,130);wm.setVisible(true);
}
}
}
/*************************** 接收信息类 *************************************/
class receivemessage extends Thread
{byte data[]=new byte[8192];
DatagramPacket pack=new DatagramPacket(data,data.length);
public void run()
{ DatagramSocket mail_data=null;
try{mail_data=new DatagramSocket(8888); }
catch(Exception e){}
while(true)
{if(mail_data==null) break;
else
try{mail_data.receive(pack);
int length=pack.getLength();
InetAddress adress =pack.getAddress();
int port=pack.getPort();
String message=new String(pack.getData(),0,length);
Server.a_message.append(message+'\n');
System.out.println(""+Server.liconnect.getItemCount());
}
catch(Exception e){}
}
}
}
/***************************** 系统提示窗口 ************************************/
class server_wmessage extends Frame implements ActionListener
{static Label label;Panel p=new Panel();
Button button=new Button("确定");
server_wmessage(String s,String s2)
{super(s);
setBounds(400,270,440,130);
setVisible(true);
setResizable(true);
p.setLayout(new GridLayout(1,5));label=new Label(s2);
p.add(new Label()); p.add(new Label());p.add(button); p.add(new Label()); p.add(new Label());
add("Center",label);add("South",p);
button.addActionListener(this);
addWindowListener(new WindowAdapter()
{public void windowClosing(WindowEvent e)
{dispose();
}
});
}
public void actionPerformed(ActionEvent e)
{this.dispose();}
}
/*************************** 信息发送 ***********************************/
class sen
{
sen()
{}
public static void smess(String s,int i)
{byte buffer[]=s.trim().getBytes();
try{InetAddress address=InetAddress.getByName("localhost");
DatagramSocket mail_data=new DatagramSocket();
DatagramPacket data_pack=new DatagramPacket(buffer,buffer.length,address,i);
mail_data.send(data_pack);
}
catch(Exception e){}
}
}
/************************** 增加背景图画 ***************************************/
class Imagecanvas extends Canvas
{Toolkit tool;Image myimage;
Imagecanvas (String s)
{getSize();
tool=getToolkit();
myimage=tool.getImage(s);
}
public void paint(Graphics g)
{g.drawImage(myimage,30,10,myimage.getWidth(this),myimage.getHeight(this),this);
}
public Dimension getPreferredSize()
{return new Dimension(160,160);
}
}
/*************************** 新增用户 *********************************/
class newuser extends Frame implements ActionListener
{Label label1=new Label("请输入用户名");Label label2=new Label("请输入密码");Label label3=new Label("请再输入密码");Label label4=new Label("请输入所属部门");Label label5=new Label("请输入可发信息的部门");
Button b1=new Button("确定");Button b2=new Button("取消");Panel pcen=new Panel();Panel psou=new Panel();
TextField t1=new TextField(10);TextField t2=new TextField(10);TextField t3=new TextField(10);
Choice ch1=new Choice();Checkbox box1,box2,box3;
newuser()
{super("修改密码");
setBounds(300,200,350,200);
setVisible(false);
setResizable(false);
t1.setEchoChar('*'); t2.setEchoChar('*'); t3.setEchoChar('*');
ch1.add("请选择");ch1.add("管理部");ch1.add("人事部");ch1.add("物流部");
box1=new Checkbox("管理部");box2=new Checkbox("人事部");box3=new Checkbox("物流部");
pcen.setLayout(new GridLayout(7,4));
pcen.add(new Label());pcen.add(new Label());pcen.add(new Label());pcen.add(new Label());
pcen.add(new Label());pcen.add(label1);pcen.add(t1);pcen.add(new Label());
pcen.add(new Label());pcen.add(label2);pcen.add(t2);pcen.add(new Label());
pcen.add(new Label());pcen.add(label3);pcen.add(t3);pcen.add(new Label());
pcen.add(new Label());pcen.add(label4);pcen.add(ch1);pcen.add(new Label());
pcen.add(label5);pcen.add(box1);pcen.add(box2);pcen.add(box3);
pcen.add(new Label());pcen.add(new Label());pcen.add(new Label());pcen.add(new Label());
psou.setLayout(new GridLayout(1,6));psou.add(new Label());psou.add(new Label());psou.add(b1);psou.add(b2);psou.add(new Label());psou.add(new Label());
add("Center",pcen);add("South",psou);
b1.addActionListener(this);b2.addActionListener(this);
addWindowListener(new WindowAdapter()
{public void windowClosing(WindowEvent e)
{setVisible(false);
}
});
}
public void actionPerformed(ActionEvent e)
{
if(e.getSource()==b1)
{this.dispose();
server_wmessage wm=new server_wmessage("添加成功"," 你已经成功添加用户");wm. setBounds(100,170,440,130);wm.setVisible(true);
}
else if(e.getSource()==b2) {this.setVisible(false);}
}
}⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -