远程屏幕监控java实现

/**************************************** *　程序文件名称： ClientTest.java * 功能： 客户端应用程序 *****************************************/ import java.awt.*; import java.awt.event.*; import javax.swing.*; import java.awt.AWTEvent; import java.awt.BorderLayout; import java.awt.Dimension; import java.awt.Graphics; import java.awt.Rectangle; import java.awt.Toolkit; import java.awt.event.AWTEventListener; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.KeyEvent; import java.awt.event.MouseEvent; import java.awt.event.MouseListener; import java.awt.event.MouseMotionListener; import java.awt.event.MouseWheelEvent; import java.awt.event.MouseWheelListener; import java.awt.event.WindowAdapter; import java.awt.event.WindowEvent; import java.awt.image.BufferedImage; import java.io.ByteArrayInputStream; import java.io.InputStream; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JMenuItem; import javax.swing.JOptionPane; import javax.swing.JPopupMenu; import javax.swing.JScrollPane; import javax.swing.Scrollable; import javax.swing.SwingConstants; import javax.swing.UIManager; import com.sun.image.codec.jpeg.JPEGCodec; import com.sun.image.codec.jpeg.JPEGImageDecoder; public class ClientTest extends JLabel implements Runnable//,Scrollable { private DatagramSocket socket; private boolean ended; private long delay=1000; private InetAddress server; private BufferedImage image; public static String s=""; final private JPopupMenu menu; /* 1. 显示图像 */ public void paint(Graphics g) { super.paint(g); if(image!=null) {g.drawImage(image,0,0,this);} } /* 2.构造方法 */ public ClientTest(String ip) throws Exception { super(); image=null; ended=false; //设置UDP数据报端口 socket=new DatagramSocket(5000); //设置存放接收数据缓冲区的大小 socket.setReceiveBufferSize(409600); //存放被控端IP地址 server=InetAddress.getLocalHost(); //定义向被控端发出截取屏幕图像指令的线程 new Thread(new Runnable() { public void run() { DatagramPacket packetsign=new DatagramPacket("REFRESH".getBytes(),20); while(!ended) { try { packetsign.setAddress(server); packetsign.setPort(5000); socket.send(packetsign); Thread.sleep(delay); } catch (Exception e) { try { Thread.sleep(100); } catch (Exception ex) { } } } //end while } //end run }).start(); //定义弹出式菜单 menu=new JPopupMenu(); JMenuItem target=new JMenuItem("监控目的地址"); final JLabel one=this; this.setPreferredSize(new Dimension(640,480)); InetAddress address=InetAddress.getByName(ip); server=address; menu.add(target); /* 设置鼠标按键监听 */ this.addMouseListener(new MouseListener(){ public void mouseClicked(MouseEvent e) { process(e);} public void mouseEntered(MouseEvent e) { process(e);} public void mouseExited(MouseEvent e) { process(e); } //点击鼠标按键 public void mousePressed(MouseEvent e) { process(e); sendMouse(MouseEvent.MOUSE_PRESSED,e.getX(),e.getY(),e.getButton()); } //释放鼠标按键 public void mouseReleased(MouseEvent e) { process(e); sendMouse(MouseEvent.MOUSE_RELEASED,e.getX(),e.getY(),e.getButton()); } //侦测鼠标的坐标位置 private void process(MouseEvent e) { if(e.isPopupTrigger()) { menu.show(one,e.getX(),e.getY()); } } }); /* end addMouseListener( ) */ /* 设置鼠标移动监听 */ this.addMouseMotionListener(new MouseMotionListener(){ public void mouseDragged(MouseEvent e) { sendMouse(MouseEvent.MOUSE_MOVED,e.getX(),e.getY(),e.getButton()); } public void mouseMoved(MouseEvent e) { sendMouse(MouseEvent.MOUSE_MOVED,e.getX(),e.getY(),e.getButton()); } }); /* end addMouseMotionListener( ) */ /* 设置鼠标滚轮监听 */ this.addMouseWheelListener(new MouseWheelListener(){ public void mouseWheelMoved(MouseWheelEvent e) { sendMouse(MouseEvent.MOUSE_WHEEL,e.getX(),e.getY(),e.getUnitsToScroll()); } }); /* end addMouseWheelListener( ) */ } /* 构造方法 ClientInit( ) 结束 */ /* 发送键盘信息方法 */ private void sendKey(int type,int code,char c,int location) { byte[] bytes=new byte[50]; for(int i=0;i<bytes.length;i++) { bytes[i]=' '; } String command; if(type==KeyEvent.KEY_PRESSED) { command="KeyPressed"; } else if(type==KeyEvent.KEY_RELEASED) { command="KeyReleased"; } else { command=""; } byte[] the=command.getBytes(); for(int i=0;i<the.length;i++) { bytes[i]=the[i]; } the=String.valueOf(code).getBytes(); for(int i=0;i<the.length;i++) { bytes[20+i]=the[i]; } the=String.valueOf(Character.getNumericValue(c)).getBytes(); for(int i=0;i<the.length;i++) { bytes[30+i]=the[i]; } the=String.valueOf(location).getBytes(); for(int i=0;i<the.length;i++) { bytes[40+i]=the[i]; } try { DatagramPacket packet=new DatagramPacket(bytes,bytes.length,server,5000); socket.send(packet); } catch (Exception e) { e.printStackTrace(); } } /* end sendKey */ /* 发送鼠标事件信息方法 */ private void sendMouse(int type,int x,int y,int button) { byte[] bytes=new byte[50]; for(int i=0;i<bytes.length;i++) { bytes[i]=' '; } String command; if(type==MouseEvent.MOUSE_PRESSED) { command="MousePressed"; } else if(type==MouseEvent.MOUSE_RELEASED) { command="MouseReleased"; } else if(type==MouseEvent.MOUSE_MOVED) { command="MouseMoved"; } else if(type==MouseEvent.MOUSE_WHEEL) { command="MouseWheel"; } else {command=""; } if(button==MouseEvent.BUTTON1) { button=MouseEvent.BUTTON1_MASK; } else if(button==MouseEvent.BUTTON2) { button=MouseEvent.BUTTON2_MASK; } else if(button==MouseEvent.BUTTON3) { button=MouseEvent.BUTTON3_MASK; } byte[] the=command.getBytes(); for(int i=0;i<the.length;i++) {bytes[i]=the[i]; } the=String.valueOf(x).getBytes(); for(int i=0;i<the.length;i++) { bytes[20+i]=the[i]; } the=String.valueOf(y).getBytes(); for(int i=0;i<the.length;i++) { bytes[30+i]=the[i]; } the=String.valueOf(button).getBytes(); for(int i=0;i<the.length;i++) { bytes[40+i]=the[i]; } try { DatagramPacket packetmouse=new DatagramPacket(bytes,bytes.length,server,5000); socket.send(packetmouse); } catch (Exception e) { e.printStackTrace(); } } /* end sendMouse( ) */ /* 3.将接收到的屏幕图象数据进行解压，还原成图像 */ private void getScreen(InputStream input) { try{ JPEGImageDecoder decoder=JPEGCodec.createJPEGDecoder(input); BufferedImage image=decoder.decodeAsBufferedImage(); this.image=image; this.setPreferredSize(new Dimension(image.getWidth(),image.getHeight())); this.updateUI(); } catch (Exception e) {e.printStackTrace();} } /* 4.线程RUN（），接收传来的屏幕图像数据 */ public void run() { byte[] bytes=new byte[409600]; while(!ended) { try { DatagramPacket packet=new DatagramPacket(bytes,bytes.length); socket.receive(packet); ByteArrayInputStream input= new ByteArrayInputStream( packet.getData(),packet.getOffset(