socket流程+实现桌面监控+通信+zip压缩解压.docx

1 socket的通信方式、流程2 思想A.建立SOCKET连接。B.读取桌面操作情况C.生成图片，并写出。3 具体实现package TCP;import com.sun.image.codec.jpeg.JPEGCodec;import java.awt.Dimension;import java.awt.Image;import java.awt.Rectangle;import java.awt.Robot;import java.awt.Toolkit;import java.awt.image.BufferedImage;import java.io.FileOutputStream;import java.io.IOException;import .ServerSocket;import .Socket;import java.util.zip.ZipEntry;import java.util.zip.ZipOutputStream;public class ShellServer extends Thread private Dimension screenSize; private Rectangle rectangle; private Robot robot; private ServerSocket server =null; public ShellServer() screenSize = Toolkit.getDefaultToolkit().getScreenSize(); rectangle = new Rectangle(screenSize);/ 可以指定捕获屏幕区域 try server=new ServerSocket(5000); robot = new Robot(); catch (Exception e) e.printStackTrace(); System.out.println(e); public void run() ZipOutputStream os = null; ZipOutputStream zos = null; Socket socket = null; while (true) try socket = server.accept();/ socket = new Socket(2,5000);/ 连接远程IP BufferedImage image = robot.createScreenCapture(rectangle);/ 捕获制定屏幕矩形区域 os = new ZipOutputStream(socket.getOutputStream();/ 加入压缩流 Image i = null; os.setLevel(9); os.putNextEntry(new ZipEntry(test.jpg); JPEGCodec.createJPEGEncoder(os).encode(image);/ 图像编码成JPEG zos = new ZipOutputStream(new FileOutputStream(C:/1.zip); zos.putNextEntry(new ZipEntry(test.jpg); JPEGCodec.createJPEGEncoder(zos).encode(image);/ 图像编码成JPEG zos.close(); System.out.println(); os.close(); Thread.sleep(500);/ 每秒20帧 catch (Exception e) e.printStackTrace(); finally if (os != null) try os.close(); catch (Exception ioe) if (socket != null) try socket.close(); catch (IOException e) public static void main(String args) new ShellServer().start(); package TCP;import java.awt.*;import java.awt.image.BufferedImage;import javax.imageio.ImageIO;import javax.swing.*;import java.io.*;import .ServerSocket;import .Socket;import java.util.zip.ZipInputStream;public class ShellClient extends JFrame private static final long serialVersionUID = 1L; Dimension screenSize; public ShellClient() super(); screenSize = Toolkit.getDefaultToolkit().getScreenSize(); this.setSize(800, 640); Screen p = new Screen(); Container c = this.getContentPane(); c.setLayout(new BorderLayout(); c.add(p, SwingConstants.CENTER); new Thread(p).start(); SwingUtilities.invokeLater(new Runnable() public void run() setVisible(true); ); public static void main(String args) new ShellClient(); class Screen extends JPanel implements Runnable private static final long serialVersionUID = 1L; private Image cimage; public void run() / ServerSocket ss = null; try / ss = new ServerSocket(5000);/ 探听5000端口的连接 while (true) Socket s = null; try s = new Socket(, 5000); ZipInputStream zis = new ZipInputStream(s .getInputStream(); zis.getNextEntry(); cimage = ImageIO.read(zis);/ 把ZIP流转换为图片 / getGraphics(); removeAll(); repaint(); catch (Exception e) e.printStackTrace(); finally if (s != null) try s.close(); catch (IOException e) e.printStackTrace(); catch (Exception e) finally / if (ss != null) / try / ss.close(); / catch (IOException e) / e.printStackTrace(); / / public Screen() super(); this.setLayout(null); public void paint(Graphics g) super.paint(g); Graphics2D g2 = (Graphics2D) g; g2.drawImage(cimage, 0, 0, null); 4 扩展4.1 A.SOCKET消息互传：4.1.1 服务端：/服务端输入 客户端输出 BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream(),UTF-8);/服务端输出 客户端输入/PrintWriter os=new PrintWriter(socket.getOutputStream();BufferedWriter os= new BufferedWriter(new PrintWriter(socket.getOutputStream();4.1.2 客户端：/ 客户端接收(写入) 服务端输出BufferedReader in= new BufferedReader(new InputStreamReader(server.getInputStream(),UTF-8); /客户端写出 服务端接收PrintWriter out=new P