Android-sdk Mjpeg Viewer (access to Mjpeg-streamer)

Android-sdk から Mjpeg-streamer(Raspberry pi)へのアクセスする Javaプログラムを作成してみました。
興味のある方ご覧ください。
なほ、 Mjpeg-streamer (Raspberry pi など)は、別途インストールが必要ですが、
それは、他のインターネット上の情報などを参考にしてください。

プログラム、３個です。
MainActivity.java
MySurfaceView,java
MyHttpReader.java

先ず、eclipse(luna) で、android アプリケーションプロジェクトを新規作成します。
プロジェクト名：MjpegViewer -- 適当
ガイダンスに従って、MainActivity(ブランク hello text が１個あるもの)を作成して完了します。
注）　SdkVersion　は、 19 から 21 を指定します。

以後、 MjpegViewer プロジェクト上での操作です。
1)先ず、下記、MainActivity.java 以外の java ソースをプロジェクトの
src/com.example.mjpegviewer/ ディレクトリーに取り込んでください。

2) res/layout/acivity_main.xml を開いて
トップのレイアウトを、LinearLayout (vertical)に変更
左の　カスタム&ライブラリー・ビューから、MySufaceView をドラッグ＆ドロップ

3) AndroidManifest.xml をテキスト表示で開いて、
下記パーミッションを追加します。

    <uses-permission android:name="android.permission.INTERNET"/>

4) MyHttpReader.java のコンストラクターの Mjpeg-streamer アクセスの設定値を自分の環境に合わせて修正します。

	public MyHttpReader(){
		mUri="/?action=snapshot";	// get a jpeg data from mjpeg-streamer server with snapshot
		//mUri="/?action=stream&type=mjpg";	// multi-part -> not support
		yid="neko";  //---> your id
		ypass="nyanya";  //---> your password
		host="192.168.1.150";  //--> ip
		port=8080;  //-->  port

5) 以上で完成です。
あとは、試してみるだけ。

MainActivity.java は、こんな感じ。
eclipse でAndroid プロジェクトを作成した直後とほとんど同じ。
src/com.example.mjpegviewer/MainActivity.java

package com.example.mjpegviewer;

import android.app.Activity;
import android.os.Bundle;
import android.view.Menu;
import android.view.MenuItem;


public class MainActivity extends Activity {

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
    }


    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        // Inflate the menu; this adds items to the action bar if it is present.
        getMenuInflater().inflate(R.menu.main, menu);
        return true;
    }

    @Override
    public boolean onOptionsItemSelected(MenuItem item) {
        // Handle action bar item clicks here. The action bar will
        // automatically handle clicks on the Home/Up button, so long
        // as you specify a parent activity in AndroidManifest.xml.
        int id = item.getItemId();
        if (id == R.id.action_settings) {
            return true;
        }
        return super.onOptionsItemSelected(item);
    }
}

MySurfaceView.java は、こんな感じ。
注） 1/2 の縮尺処理を追加しました。 2015.1.19
src/com.example.mjpegviewer/MySurfaceView.java

package com.example.mjpegviewer;

import java.io.IOException;
import android.content.Context;
import android.graphics.Bitmap;
import android.graphics.BitmapFactory;
import android.graphics.Canvas;
import android.util.AttributeSet;
import android.util.Log;
import android.view.SurfaceHolder;
import android.view.SurfaceView;

public class MySurfaceView extends SurfaceView  implements Runnable, SurfaceHolder.Callback {
	private static final boolean DEBUG=false;
	private static final boolean SCALE=true;	// scale 1/2
	boolean isLoop = true;
	MyHttpReader mMyHttpReader;
	Thread mThread;

	public MySurfaceView(Context context, AttributeSet attrs) {
		super(context, attrs);
		if(DEBUG) Log.d("MySurfaceView","MySurfaceView() :#1 called!!");
		// TODO 自動生成されたコンストラクター・スタブ
		getHolder().addCallback(this);
		initMySurfaceView();
	}
	
	public MySurfaceView(Context context) {
		super(context);
		if(DEBUG) Log.d("MySurfaceView","MySurfaceView() :#1 called!!");
		// TODO 自動生成されたコンストラクター・スタブ
		getHolder().addCallback(this);
		initMySurfaceView();
	}
	/*
	 * void initMySurfaceView()
	 */
	public void initMySurfaceView(){
		mMyHttpReader = new MyHttpReader();
	}
	/*
	 * my thread
	 * void run()
	 */
	@Override
	public void run() {
		// TODO 自動生成されたメソッド・スタブ
		while(isLoop){
			// Mjpeg-Streamer access
			mMyHttpReader.get();
			// access ok
			if(mMyHttpReader.mHttpEntity != null){
				try {
					// convert jpeg to Bitmap object
					Bitmap bitmap = BitmapFactory.decodeStream(mMyHttpReader.mHttpEntity.getContent());
					// convert jpeg to Bitmap OK
					if(bitmap != null){
						Canvas mCanvas = getHolder().lockCanvas();
						if(mCanvas != null){
							// scale 1/2
							if(SCALE){
								// 640:480 -> 320:240
								Bitmap bitmap2= Bitmap.createScaledBitmap(bitmap, 320, 240, false);
								mCanvas.drawBitmap(bitmap2, 0, 0, null);
							}
							else{
								mCanvas.drawBitmap(bitmap, 0, 0, null);
							}
							getHolder().unlockCanvasAndPost(mCanvas);
						}
					}
					else{
						if(DEBUG) Log.e("MySurfaceView","run() #3: bitmap == null");
					}
				}
				catch (IllegalStateException e) {
					// TODO 自動生成された catch ブロック
					e.printStackTrace();
				}
				catch (IOException e) {
					// TODO 自動生成された catch ブロック
					e.printStackTrace();
				}
			}
			// 毎回 shutdown しなくても良いみたい。
			//mMyHttpReader.shutdown();
			if(isLoop==true){
				//try{
				//	Thread.sleep(5000); //5000ミリ秒Sleepする
				//}
				//catch(InterruptedException e){}
			}
		}
		// HttpClient shutdown
		mMyHttpReader.shutdown();
	}

	@Override
	public void surfaceChanged(SurfaceHolder holder, int format, int width,
			int height) {
		// TODO 自動生成されたメソッド・スタブ
		if(DEBUG) Log.d("MySurfaceView","surfaceChanged() :#1 called!!");
	}

	@Override
	public void surfaceCreated(SurfaceHolder holder) {
		// TODO 自動生成されたメソッド・スタブ
		if(DEBUG) Log.d("MySurfaceView","surfaceCreated() :#1 called!!");
		isLoop = true;
		mThread = new Thread(this);
		mThread.start();
	}

	@Override
	public void surfaceDestroyed(SurfaceHolder holder) {
		// TODO 自動生成されたメソッド・スタブ
		if(DEBUG) Log.d("MySurfaceView","surfaceDestroyed() :#1 called!!");
		// require my thread stop
		isLoop = false;
		try {
			// wait for my thread stop
			mThread.join();
		}
		catch (InterruptedException e) {
			// TODO 自動生成された catch ブロック
			e.printStackTrace();
		}
	}
}

MyHttpReader.java は、こんな感じ
src/com.example.mjpegviewer/MyHttpReader.java

package com.example.mjpegviewer;

import java.io.IOException;

import org.apache.http.HttpEntity;
import org.apache.http.HttpHost;
import org.apache.http.HttpRequest;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.MethodNotSupportedException;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.impl.DefaultHttpRequestFactory;
import org.apache.http.impl.client.DefaultHttpClient;

import android.util.Base64;
import android.util.Log;

/*
 * サーバーのデータを読む
 * 注）必ず、別スレッドで実行します。
 */
public class MyHttpReader {
	String mUri,	// "/" , "index.html" , "/?action=snapshot"
		yid,		// "" or "your id"
		ypass;		// "" or "your password"
	String host,	// host ip -> "192.158.1.180"
		scheme,		// "http"
		domain;		// "" or virtual domain name
	int port;		// 80,8080 etc
	int rc;
	HttpEntity mHttpEntity;
	DefaultHttpClient mHttpClient;
	HttpHost mHttpHost;
	boolean shutdown_f,keep_alive_f;
	HttpRequest mHttpRequest;
	
	public MyHttpReader(){
		mUri="/?action=snapshot";	// get a jpeg data from mjpeg-streamer server with snapshot
		//mUri="/?action=stream&type=mjpg";	// multi-part -> not support
		yid="neko";
		ypass="nyanya";
		host="192.168.1.150";
		port=8080;
		scheme="http";
		domain="";
		rc=0;
		mHttpEntity=null;
		keep_alive_f=true;
		initHttpClient();
	}
	/*
	 * void initHttpClient()
	 */
	public void initHttpClient(){
		//mHttpHost = new HttpHost("192.168.1.150", 80, "http");
		mHttpHost = new HttpHost(host,port,scheme);
		// set shutdown to HttpClient status flag.
		shutdown_f=true;
		try {
			mHttpRequest = new DefaultHttpRequestFactory().newHttpRequest("GET",mUri);

			// Virtual Domain is required
			if(domain.equals("") != true){
				mHttpRequest.setHeader("Host", domain);
			}
			if(keep_alive_f == true){
				mHttpRequest.setHeader("Connection","Keep-Alive");
			}
			if(yid.equals("")!=true && ypass.equals("")!=true){
				mHttpRequest.setHeader("Authorization", "Basic "+Base64.encodeToString((yid+":"+ypass).getBytes(), Base64.DEFAULT));
			}
		}
		catch (MethodNotSupportedException e) {
			// TODO 自動生成された catch ブロック
			//e.printStackTrace();
			Log.e("MyHttpReader","initHttpClient() #16:"+e.toString());
		}
	}
	/*
	 *  get()
	 */
	public void get(){
		try{
			mHttpEntity=null;
			Log.d("MyHttpReader","get() #3: mUri="+mUri);
			// HttpClient is closed.
			if(shutdown_f == true){
				mHttpClient = new DefaultHttpClient();
				shutdown_f=false;
			}
			Log.d("MyHttpReader","get() #5: mHttpHost.toURI()="+mHttpHost.toURI());
			HttpResponse response = mHttpClient.execute(mHttpHost,mHttpRequest);

			Log.d("MyHttpReader","get() #6:passed!");
			int status = response.getStatusLine().getStatusCode();
			if(status == HttpStatus.SC_OK){
				Log.d("MyHttpReader","get() #7: data OK");
				mHttpEntity = response.getEntity();
                // レスポンスデータを文字列として取得する。
				// String data= EntityUtils.toString(response.getEntity(), "UTF-8");
                // byte[]として読み出したいときは EntityUtils.toByteArray()を使う。
				// byte[] data_b = EntityUtils.toByteArray(response.getEntity());
				rc=1;
			}
			//データ無し
			else if(status == HttpStatus.SC_NOT_FOUND){
				Log.d("MyHttpReader","get() #8: data nothing");
				rc=2;
			}
			else{
				Log.e("MyHttpReader","get() #9: error occured status code="+status);
				rc=-1;
			}
			//ここでshutdown()すると、上位で、mHttpEntity のアクセスが終了しない内に通信が切断されるので、
			//上位で行います。
			//又、HttpClientを使い回す場合は、適切なところで行うこと。
			//mHttpClient.getConnectionManager().shutdown();
		}
		catch(ClientProtocolException e){
			Log.e("MyHttpReader","get() #14:"+e.toString());
			rc=-3;
		}
		catch(IOException e){
			Log.e("MyHttpReader","get() #15:"+e.toString());
			rc=-4;
		}
	}
	/*
	 * shutdown()
	 */
	public void shutdown(){
		Log.d("MyHttpReader","shutdown() #1:client shutdown");
		//HttpClientを使い回す場合は、上位が、 適切なところでコールします。
		//当然だがshutdown()したインスタンスは通信できなくなる。
		//プログラムの終了時には、必ずコールしてください。
		mHttpClient.getConnectionManager().shutdown();
		shutdown_f=true;
	}
}

AndroidManifest.xml は、こんな感じ

<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="com.example.mjpegviewer"
    android:versionCode="1"
    android:versionName="1.0" >

    <uses-sdk
        android:minSdkVersion="19"
        android:targetSdkVersion="21" />
    <uses-permission android:name="android.permission.INTERNET"/>
    
    <application
        android:allowBackup="true"
        android:icon="@drawable/ic_launcher"
        android:label="@string/app_name"
        android:theme="@style/AppTheme" >
        <activity
            android:name=".MainActivity"
            android:label="@string/app_name" >
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>
    </application>

</manifest>

res/layout/activity_main.xml は、こんな感じ

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:id="@+id/LinearLayout1"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical"
    android:paddingBottom="@dimen/activity_vertical_margin"
    android:paddingLeft="@dimen/activity_horizontal_margin"
    android:paddingRight="@dimen/activity_horizontal_margin"
    android:paddingTop="@dimen/activity_vertical_margin"
    tools:context="com.example.mjpegviewer.MainActivity" >

    <TextView
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="@string/hello_world" />

    <com.example.mjpegviewer.MySurfaceView
        android:id="@+id/mySurfaceView1"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content" />

</LinearLayout>

Mjpeg-streamer のインストールにかんしては、
おんちゃんは、こちらを参考にしました。
http://cubic9.com/Devel/%C5%C5%BB%D2%B9%A9%BA%EE/RaspberryPi/%A5%A6%A5%A7%A5%D6%A5%AB%A5%E1%A5%E9%A4%C7%A5%B9%A5%C8%A5%EA%A1%BC%A5%DF%A5%F3%A5%B0/
但し、１か所の情報だけでなく、複数箇所の情報を見た方が参考になります。
最後に、Ｒａｓｐｂｅｒｒｙ　ｐｉのポート(8080)は、オープンにしてください。
#ufw allow 8080

カテゴリ:

検索

このブログ記事について

カテゴリ

月別アーカイブ

ウェブページ

サイトナビ