Android實現手機監控攝像頭

2022-03-28 16:00:14

一直想在自己的Android手機上實現一個手機監控攝像頭功能。今天逛論壇，看到一個例子，於是做了出來，留著以後完善。

功能點：

1、Android和PC通過socket通訊。

2、Android下Camera的使用。

看程式碼：

package com.wenix.androidcameramonitor;
 
import android.app.Activity;
import android.app.AlertDialog;
import android.app.AlertDialog.Builder;
import android.content.DialogInterface;
import android.content.DialogInterface.OnClickListener;
import android.content.Intent;
import android.os.Bundle;
import android.view.Window;
import android.view.WindowManager;
import android.widget.EditText;
import android.widget.TableLayout;
 
public class GetIP extends Activity {
    String ipname = null;
 
    @Override
    public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    // 設定全螢幕
    requestWindowFeature(Window.FEATURE_NO_TITLE);
    getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN,
        WindowManager.LayoutParams.FLAG_FULLSCREEN);
    setContentView(R.layout.activity_main);
 
    final Builder builder = new AlertDialog.Builder(this); // 定義一個AlertDialog.Builder物件
    builder.setTitle("登入伺服器對話方塊"); // 設定對話方塊的標題
 
    // 裝載/res/layout/login.xml介面佈局
    TableLayout loginForm = (TableLayout) getLayoutInflater().inflate(
        R.layout.login, null);
    final EditText iptext = (EditText) loginForm
        .findViewById(R.id.ipedittext);
    builder.setView(loginForm); // 設定對話方塊顯示的View物件
    // 為對話方塊設定一個「登入」按鈕
    builder.setPositiveButton("登入"
    // 為按鈕設定監聽器
        , new OnClickListener() {
            @Override
            public void onClick(DialogInterface dialog, int which) {
            // 此處可執行登入處理
            ipname = iptext.getText().toString().trim();
            Bundle data = new Bundle();
            data.putString("ipname", ipname);
            Intent intent = new Intent(GetIP.this, MainActivity.class);
            intent.putExtras(data);
            startActivity(intent);
            }
        });
    // 為對話方塊設定一個「取消」按鈕
    builder.setNegativeButton("取消", new OnClickListener() {
        @Override
        public void onClick(DialogInterface dialog, int which) {
        // 取消登入，不做任何事情。
        System.exit(1);
        }
    });
    // 建立、並顯示對話方塊
    builder.create().show();
    }
}

獲取ip後就跳轉到MainActivity。

package com.wenix.androidcameramonitor;
 
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
 
import android.app.Activity;
import android.content.Intent;
import android.graphics.ImageFormat;
import android.graphics.Rect;
import android.graphics.YuvImage;
import android.hardware.Camera;
import android.hardware.Camera.Size;
import android.os.Bundle;
import android.util.Log;
import android.view.SurfaceHolder;
import android.view.SurfaceHolder.Callback;
import android.view.SurfaceView;
import android.view.Window;
import android.view.WindowManager;
 
public class MainActivity extends Activity {
    SurfaceView sView;
    SurfaceHolder surfaceHolder;
    int screenWidth, screenHeight;
    Camera camera; // 定義系統所用的照相機
    boolean isPreview = false; // 是否在瀏覽中
    private String ipname;
 
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        // 設定全螢幕
        requestWindowFeature(Window.FEATURE_NO_TITLE);
        getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN, WindowManager.LayoutParams.FLAG_FULLSCREEN);
        setContentView(R.layout.activity_main);
 
        // 獲取IP地址
        Intent intent = getIntent();
        Bundle data = intent.getExtras();
        ipname = data.getString("ipname");
 
        screenWidth = 640;
        screenHeight = 480;
        sView = (SurfaceView) findViewById(R.id.sView); // 獲取介面中SurfaceView元件
        surfaceHolder = sView.getHolder(); // 獲得SurfaceView的SurfaceHolder
 
        // 為surfaceHolder新增一個回撥監聽器
        surfaceHolder.addCallback(new Callback() {
            @Override
            public void surfaceChanged(SurfaceHolder holder, int format, int width, int height) {
            }
 
            @Override
            public void surfaceCreated(SurfaceHolder holder) {
                initCamera(); // 開啟攝像頭
            }
 
            @Override
            public void surfaceDestroyed(SurfaceHolder holder) {
                // 如果camera不為null ,釋放攝像頭
                if (camera != null) {
                    if (isPreview)
                        camera.stopPreview();
                    camera.release();
                    camera = null;
                }
                System.exit(0);
            }
        });
        // 設定該SurfaceView自己不維護緩衝
        surfaceHolder.setType(SurfaceHolder.SURFACE_TYPE_PUSH_BUFFERS);
 
    }
 
    private void initCamera() {
        if (!isPreview) {
            camera = Camera.open();
        }
        if (camera != null && !isPreview) {
            try {
                Camera.Parameters parameters = camera.getParameters();
                parameters.setPreviewSize(screenWidth, screenHeight); // 設定預覽照片的大小
                parameters.setPreviewFpsRange(20, 30); // 每秒顯示20~30幀
                parameters.setPictureFormat(ImageFormat.NV21); // 設定圖片格式
                parameters.setPictureSize(screenWidth, screenHeight); // 設定照片的大小
                // camera.setParameters(parameters); // android2.3.3以後不需要此行程式碼
                camera.setPreviewDisplay(surfaceHolder); // 通過SurfaceView顯示取景畫面
                camera.setPreviewCallback(new StreamIt(ipname)); // 設定回撥的類
                camera.startPreview(); // 開始預覽
                camera.autoFocus(null); // 自動對焦
            } catch (Exception e) {
                e.printStackTrace();
            }
            isPreview = true;
        }
    }
 
}
 
class StreamIt implements Camera.PreviewCallback {
    private String ipname;
 
    public StreamIt(String ipname) {
        this.ipname = ipname;
    }
 
    @Override
    public void onPreviewFrame(byte[] data, Camera camera) {
        Size size = camera.getParameters().getPreviewSize();
        try {
            // 呼叫image.compressToJpeg（）將YUV格式影象資料data轉為jpg格式
            YuvImage image = new YuvImage(data, ImageFormat.NV21, size.width, size.height, null);
            if (image != null) {
                ByteArrayOutputStream outstream = new ByteArrayOutputStream();
                image.compressToJpeg(new Rect(0, 0, size.width, size.height), 80, outstream);
                outstream.flush();
                // 啟用執行緒將影象資料傳送出去
                Thread th = new MyThread(outstream, ipname);
                th.start();
            }
        } catch (Exception ex) {
            Log.e("Sys", "Error:" + ex.getMessage());
        }
    }
}
 
class MyThread extends Thread {
    private byte byteBuffer[] = new byte[1024];
    private OutputStream outsocket;
    private ByteArrayOutputStream myoutputstream;
    private String ipname;
 
    public MyThread(ByteArrayOutputStream myoutputstream, String ipname) {
        this.myoutputstream = myoutputstream;
        this.ipname = ipname;
        try {
            myoutputstream.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
 
    public void run() {
        try {
            // 將影象資料通過Socket傳送出去
            Socket tempSocket = new Socket(ipname, 6000);
            outsocket = tempSocket.getOutputStream();
            ByteArrayInputStream inputstream = new ByteArrayInputStream(myoutputstream.toByteArray());
            int amount;
            while ((amount = inputstream.read(byteBuffer)) != -1) {
                outsocket.write(byteBuffer, 0, amount);
            }
            myoutputstream.flush();
            myoutputstream.close();
            tempSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
 
}

這樣就開啟了socket，然後把camera獲取的資料傳送到PC端。

PC端程式碼：

package com.wenix;
 
import java.awt.Dimension;
import java.awt.Graphics;
import java.awt.Image;
import java.awt.Toolkit;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.ServerSocket;
import java.net.Socket;
 
import javax.imageio.ImageIO;
import javax.swing.JButton;
import javax.swing.JFileChooser;
import javax.swing.JFrame;
import javax.swing.JPanel;
 
public class ImageServer {        
    public static ServerSocket ss = null;
    
    public static void main(String args[]) throws IOException{    
            ss = new ServerSocket(6000);
        
        final ImageFrame frame = new ImageFrame(ss);
        frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        frame.setVisible(true);
       
        while(true){
                frame.panel.getimage();
            frame.repaint();
        }        
    }
       
}
 
/** 
    A frame with an image panel
*/
@SuppressWarnings("serial")
class ImageFrame extends JFrame{
        public ImagePanel panel;
        public JButton jb;
   
    public ImageFrame(ServerSocket ss){
               // get screen dimensions              
               Toolkit kit = Toolkit.getDefaultToolkit();
        Dimension screenSize = kit.getScreenSize();
        int screenHeight = screenSize.height;
        int screenWidth = screenSize.width;
 
        // center frame in screen
        setTitle("ImageTest");
        setLocation((screenWidth - DEFAULT_WIDTH) / 2, (screenHeight - DEFAULT_HEIGHT) / 2);
        setSize(DEFAULT_WIDTH, DEFAULT_HEIGHT);
 
        // add panel to frame
        this.getContentPane().setLayout(null);
        panel = new ImagePanel(ss);
        panel.setSize(640,480);
        panel.setLocation(0, 0);
        add(panel);
        jb = new JButton("拍照");
        jb.setBounds(0,480,640,50);
        add(jb);
        saveimage saveaction = new saveimage(ss);
        jb.addActionListener(saveaction);
    }
 
    public static final int DEFAULT_WIDTH = 640;
    public static final int DEFAULT_HEIGHT = 560;  
}
 
/**
   A panel that displays a tiled image
*/
@SuppressWarnings("serial")
class ImagePanel extends JPanel {     
    private ServerSocket ss;
    private Image image;
    private InputStream ins;
         
    public ImagePanel(ServerSocket ss) {  
            this.ss = ss;
    }
    
    public void getimage() throws IOException{
            Socket s = this.ss.accept();
        System.out.println("連線成功!");
        this.ins = s.getInputStream();
                this.image = ImageIO.read(ins);
                this.ins.close();
    }
   
    public void paintComponent(Graphics g){  
        super.paintComponent(g);    
        if (image == null) return;
        g.drawImage(image, 0, 0, null);
    }
 
}
 
class saveimage implements ActionListener {
        RandomAccessFile inFile = null;
        byte byteBuffer[] = new byte[1024];
        InputStream ins;
        private ServerSocket ss;
        
        public saveimage(ServerSocket ss){
                this.ss = ss;
        }
        
        public void actionPerformed(ActionEvent event){
        try {
                        Socket s = ss.accept();
                        ins = s.getInputStream();
                        
                        // 檔案選擇器以當前的目錄開啟
                JFileChooser jfc = new JFileChooser(".");
                jfc.showSaveDialog(new javax.swing.JFrame());
                // 獲取當前的選擇檔案參照
                File savedFile = jfc.getSelectedFile();
                
                // 已經選擇了檔案
                if (savedFile != null) {
                    // 讀取檔案的資料，可以每次以快的方式讀取資料
                    try {
                                        inFile = new RandomAccessFile(savedFile, "rw");
                                } catch (FileNotFoundException e) {
                                        e.printStackTrace();
                                }
                }
 
            int amount;
            while ((amount = ins.read(byteBuffer)) != -1) {
                inFile.write(byteBuffer, 0, amount);
            }
            inFile.close();
            ins.close();
            s.close();
            javax.swing.JOptionPane.showMessageDialog(new javax.swing.JFrame(),
                    "已接儲存成功", "提示!", javax.swing.JOptionPane.PLAIN_MESSAGE);
                } catch (IOException e) {
 
                        e.printStackTrace();
                }
        }
}

執行結果如下：