外部サーバー アプリケーションと連携する製品を開発しています。外部サーバーまたは受信データのプロトコルまたはフォーマットを変更できません。
私のアプリケーションは、(主に) 外部サービスからネットワーク経由でパケットを受信するサービスとして実行されます。これらのパケットの多くは情報ですが、外部サービスはアプリケーションの「ビデオ」データを送信することを選択できます。このデータは独自の形式であり、個別にエンコードされたデータの「フレーム」として提供されます。私のサービスは独自の形式をビットマップ データにデコードし、それを (個々のフレームとして) 「ビデオの表示」アクティビティに送信します。
これらのフレームは 1 秒間に何度も来る可能性があるため、ストリーミングをできるだけ「ジャンク」フリーにしたいと考えています。各フレームをサービスから表示アクティビティに渡す最も効率的な方法を探しています。私は 3 つの方法を考え出しましたが、私の質問は、(もしあれば) 最も効率的な方法と、何か提案があるかどうかです。
それぞれの方法について説明し、それぞれのサンプル コードを少し示します。注: 含まれているコードは簡略化されていますが、「既存の機能するコード」を表しています。さまざまなアプリケーションでこれらの各メソッドを使用しましたが、この特定のアプリケーションに最適な方法について意見を求めています。私は意見が後ろのようなものであることを知っています。誰もが持っている...
方法 1: 「バインドされたサービス メッセージ」
「ビデオの表示」アクティビティが開始されると、サービスにバインドされ、MessageHandler がセットアップされます。サービスはこのハンドラを使用して、各「フレーム」をアクティビティに送信し、アクティビティはフレームをサーフェス ビューに描画します。
コード：
私のアクティビティは onResume() でサービスにバインドされます
void doBindService()
{
bindService(new Intent( this, com.myservice.class ), mConnection, Context.BIND_AUTO_CREATE );
}
そして onServiceConnected() で、サービスに Messenger への参照を送信します。
public void onServiceConnected( ComponentName className, Ibinder service )
{
m_service = new Messenger( service );
Message msg = Message.obtain(null, MyService.MSG_REGISTER_CLIENT );
msg.replyTo = mMessenger;
msg.arg1 = getServiceClientType();
m_service.send(msg);
}
サービス メッセージ ハンドラーは、MSG_REGISTER_CLIENT メッセージを受信すると、接続アクティビティの "replyTo" を格納します。
protected class IncomingHandler extends Handler
{
@Override
public void handleMessage(Message msg)
{
MessageParcel p = null;
Bundle b = msg.getData();
switch ( msg.what )
{
case MSG_REGISTER_CLIENT:
{
m_client_messenger = msg.replyTo;
break;
}
.....
}
}
}
サーバーからビデオ フレームを受信すると、保存されている Messenger を使用してそのフレームをアクティビティに送信します。
protected void sendClientFrame( byte[] frameData )
{
Message message = Message.obtain();
Bundle b = new Bundle();
b.putByteArray( "frame_data", frameData );
message.setData(b);
message.what = MyActivity.MSG_FRAME_DATA;
message.replyTo( mMessenger );
if ( m_client_messenger != null )
m_client_messenger.send(message);
}
アクティビティがこのメッセージを受け取ると、以下を描画します。
class IncomingServiceMessageHandler extends Handler
{
@Override
public void handleMessage( Mesasge msg )
{
super.handleMessage( msg );
switch ( msg.what )
{
case MyActivity.MSG_FRAME_DATA:
Bundle b = msg.getData();
b.setClassLoader( getClassLoader() );
byte[] frame_data = b.getByteArray( "frame_data" );
if ( frame_data != null )
decode_and_paint_frame_data( frame_data );
break;
case ....:
}
}
}
方法2：「インテントフレーム」
このメソッドは、各着信フレームをインテントにパックし、そのインテントをビュー アクティビティに送信します。
コード：
サービスがビデオ フレームを受信すると、インテントを作成し、フレーム データをインテントにパックしてアクティビティに送信します。
public void sendShowVideoActivityFrame( byte[] framedata )
{
Intent frame_intent = new Intent( this, MyActivity.class );
frame_intent.setFlags( Intent.FLAG_ACTIVITY_RENDER_TO_FRONT );
frame_intent.setAction( MyActivity.ACTION_SEND_FRAME );
frame_intent.startActivity( );
frame_intent.putExtra( "frame_data", framedata );
startActivity( frame_intent );
}
アクティビティがインテントを受け取ると、フレーム データをデコードしてペイントします。
@Override
protected void onNewIntent( Intent intent )
{
super.onNewIntent(intent);
if ( intent.getAction().compareTo( MyActivity.ACTION_SEND_FRAME ) == 0 )
{
byte[] frame_data = intent.getByteArrayExtra( "frame_data" );
if ( frame_data != null )
decode_and_paint_frame_data( frame_data );
}
}
方法 3: 「ローカル ソケット経由で送信」
サービスがビデオ フレームを受信すると、ローカル ソケットを介して「ビデオの表示」アクティビティに接続します。このソケットは、サービスによって受信された各フレームをアクティビティに「ストリーミング」するために使用されます。
コード：
サービスはソケットを作成し、アクティビティに接続します。
protected Socket m_activity_socket = null;
protected InputStream m_nis = null;
protected OutputStrea m_nos = null;
protected void sendClientFrame( byte[] frameData )
{
if ( m_activity_socket == null )
{
m_activity_socket = new Socket()
SocketAddress sockaddr = new InetSocketAddress("127.0.0.1", 12345 );
m_activity_socket.connect( sockaddr, 5000 );
if (m_activity_socket.isConnected()) {
m_nis = m_activity_socket.getInputStream();
m_nos = m_activity_socket.getOutputStream();
}
if ( m_nos != null )
{
// the header describes the frame data (type, width, height, length)
// frame width and heigth have been previously decoded
byte[] header = new byte[16];
build_header( 1, width, height, frameData.length, header, 1 );
m_nos.write( header ); // message header
m_nos.write( frameData ); // message data
}
}
クライアントがソケットからメッセージを受信すると、フレーム データをデコードして描画します。
public class SocketServerListener implements Runnable
{
private boolean _run = false;
public void run()
{
Socket s = null;
_run = true;
serverSocket = new ServerSocket( 12345 );
while( _run )
{
s = serverSocket.accept();
handleSocket( s );
}
serverSocket.close();
}
public void handleSocket( Socket s )
{
InputStream in = s.getInputStream();
OutputStream out = s.getOutputStream();
int bytes_read = 0;
byte[] header = new byte[16];
bytes_read = in.read( buffer, 0, header.length );
// the header contains the number of bytes in the frame data
int data_len = header_get_frame_length( );
byte[] frame_data = new byte[data_len];
bytes_read = in.read( frame_data, 0, frame_data.length );
if ( bytes_read == data_len ) // we got the full frame
decode_and_paint_frame_data( frame_data );
}
}
建設的なコメントをお寄せいただきありがとうございます。