Swing GUI版本Scrcpy投屏Demo源码

package com.lyyd.server; import com.android.ddmlib.*; import com.lyyd.client.ImageIconUtil; import org.apache.commons.lang3.StringUtils; import org.bytedeco.javacv.FFmpegFrameGrabber; import org.bytedeco.javacv.Frame; import org.bytedeco.javacv.Java2DFrameConverter; import javax.swing.*; import java.awt.image.BufferedImage; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.nio.ByteBuffer; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; public class Scrcpy { private String LOCAL_SCRCPY_PATH = Thread.currentThread().getContextClassLoader().getResource("").getPath() + "scrcpy-server.jar"; private static String REMOTE_SCRCPY_PATH = "/data/local/tmp/scrcpy-server.jar"; private IDevice iDevice; private String mobileId; private int width; private int height; private int maxSize = 800; private int pid; private OutputStream controlOutputStream; public boolean isRunning = false; public int getWidth() { return width; } public void setWidth(int width) { this.width = width; } public int getHeight() { return height; } public void setHeight(int height) { this.height = height; } private String scrcpy_version = "1.24"; private int scrcpy_bitrate = 8000000; Socket controlSocket = null; private BufferedImage bImage; public Scrcpy() { } public void setiDevice(IDevice iDevice) { this.iDevice = iDevice; } public void setMobileId(String mobileId) { this.mobileId = mobileId; } /** * scrcpy连接 * * @throws Exception */ public synchronized void start(JLabel label) throws Exception { if (isRunning) { return; } pushScrcpyToDevice(); CountDownLatch countDownLatch = new CountDownLatch(1); new Thread(() -> { try { String startCmd = String.format( "CLASSPATH=%s app_process / com.genymobile.scrcpy.Server " + "%s " + // Scrcpy server version "log_level=info " + //Log level: info, verbose... "max_size=%d " + //Max screen width (long side) "bit_rate=%s " + //Bitrate of video "max_fps=60 " + //Max frame per second "lock_video_orientation=-1 " + // Lock screen orientation: LOCK_SCREEN_ORIENTATION "tunnel_forward=true " + //Tunnel forward // "crop=- " + // Crop screen "send_frame_meta=false " + //Send frame rate to client "control=true " + // Control enabled "display_id=0 " + // Display id "show_touches=false " + //Show touches "stay_awake=true " + //Stay awake // "level=256,profile=1 " + // "codec_options=- " + //Codec (video encoding) options // "encoder_name=OMX.qcom.video.encoder.avc " + //Encoder name "power_off_on_close=false", //Power off screen after server closed REMOTE_SCRCPY_PATH, scrcpy_version, maxSize, scrcpy_bitrate); System.out.println(mobileId + " start scrcpy: " + startCmd); iDevice.executeShellCommand(startCmd, new MultiLineReceiver() { @Override public void processNewLines(String[] lines) { for (String line : lines) { if (!StringUtils.isEmpty(line)) { if (line.contains("Device:")) { countDownLatch.countDown(); } } } } @Override public boolean isCancelled() { return false; } }, 0, TimeUnit.SECONDS); isRunning = false; } catch (Exception e) { throw new RuntimeException(String.format("[%s]启动scrcpy失败", mobileId), e); } }).start(); int scrcpyStartTimeoutInSeconds = 10; boolean scrcpyStartSuccess = countDownLatch.await(scrcpyStartTimeoutInSeconds, TimeUnit.SECONDS); if (!scrcpyStartSuccess) { throw new RuntimeException(String.format("[%s]启动scrcpy失败，超时时间：%d秒", mobileId, scrcpyStartTimeoutInSeconds)); } System.out.println(mobileId + " scrcpy启动完成"); isRunning = true; int localPort = PortProvider.getScrcpyAvailablePort(); System.out.println("本地端口：" + localPort); iDevice.createForward(localPort, "scrcpy", IDevice.DeviceUnixSocketNamespace.ABSTRACT); new Thread(() -> { try (Socket screenSocket = new Socket("127.0.0.1", localPort); InputStream screenStream = screenSocket.getInputStream()) { if (screenStream.read() != 0) { throw new RuntimeException(String.format("[%s]scrcpy connection error", mobileId)); } System.out.println(mobileId + " connect scrcpy success"); controlSocket = new Socket("127.0.0.1", localPort); controlOutputStream = controlSocket.getOutputStream(); for (int i = 0; i < 64; i++) { screenStream.read(); } width = screenStream.read() << 8 | screenStream.read(); height = screenStream.read() << 8 | screenStream.read(); setWidth(width); setHeight(height); System.out.println(mobileId + " scrcpy width: " + width + " heigth: " + height); InputStream in = screenSocket.getInputStream(); FFmpegFrameGrabber frameGrabber = new FFmpegFrameGrabber(in); frameGrabber.setFrameRate(60); frameGrabber.setFormat("h264"); frameGrabber.setVideoBitrate(8000000); frameGrabber.setVideoOption("preset", "ultrafast"); frameGrabber.start(false); while (isRunning) { if (screenSocket != null) { Frame frame = frameGrabber.grab(); Java2DFrameConverter converter = new Java2DFrameConverter(); BufferedImage bufferedImage = converter.convert(frame); if (bufferedImage != null) { label.setIcon(ImageIconUtil.createAutoAdjustIcon(bufferedImage, true)); label.setAlignmentX(0.5f); label.setAlignmentY(0.5f); } } } } catch (Exception e) { System.out.println(mobileId + " 处理scrcpy数据失败"); e.printStackTrace(); } finally { if (controlOutputStream != null) { try { controlOutputStream.close(); } catch (IOException e) { e.printStackTrace(); } } if (controlSocket != null) { try { controlSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } System.out.println(mobileId + " �