3

我正在开发一种与外部服务器应用程序交互的产品。我无法更改外部服务器或传入数据的协议或格式。

我的应用程序（主要）作为服务运行，该服务通过网络从外部服务接收数据包。其中许多数据包是信息性的，但是外部服务可以选择发送我的应用程序“视频”数据。该数据采用专有格式，并以单独编码的数据“帧”形式出现。我的服务将专有格式解码为位图数据并将其（作为单独的帧）发送到我的“显示视频”活动。

由于这些帧每秒可以出现多次，我希望流媒体尽可能“免费”。我正在寻找将每个帧从我的服务传递到显示活动的最有效方法。我提出了三种方法，但我的问题是哪种方法最有效（如果有的话）以及您是否有任何建议。

我将解释每种方法，并为每种方法展示一些示例代码。注意：我包含的代码是简化的，但代表“现有功能代码”我已经在各种应用程序中使用了这些方法中的每一种，但希望就最适合这个特定应用程序的一些意见。我知道意见就像幕后黑手。每个人都有一个...

方法一：“绑定服务消息”

当“显示视频”活动启动时，它会绑定到服务并设置一个 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 ....:
        }

    }

}

方法二：“意图框架”

此方法将每个传入帧打包到一个意图中，并将该意图发送到视图活动。

代码：

当服务接收到视频帧时，它会创建一个意图并将帧数据打包到该意图中并将其触发到活动中。

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 );

}

当 Activity 接收到 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 );

    }
}

方法三：“通过本地套接字发送”

当服务接收到视频帧时，它通过本地套接字连接到“显示视频”活动。然后，此套接字用于在服务接收到每个帧时将其“流式传输”到活动。

代码：

该服务创建一个套接字并连接到活动：

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 );    
    }

}

提前感谢您的建设性意见。

4

2 回答 2

2

经过数小时的研究和数天的实验、反复试验，我决定采用最后一种描述的方法。我的服务发送一个 Intent 以启动我的活动，然后等待活动启动一个 ServerSocket 侦听给定的本地非特权端口。一旦活动准备就绪，它就会启动一个线程，并在指定端口上侦听一个套接字。然后服务使用 Socket 连接到该端口并发送帧数据。在上面的示例代码中，我似乎正在为每一帧重新连接。实际代码中并非如此。服务连接到套接字后，它只是保持打开状态，并在从内容服务器接收到数据时发送每一帧数据。

我选择这种方法是因为它看起来最有效，而且我对套接字编程非常熟悉。通过服务消息或意图发送帧似乎非常低效，并且在我无法控制的地方引入了延迟。

于 2013-07-17T15:41:03.103 回答
0

由于 Service 和 Activity 存在于同一进程中（如果未指定其他），您可以只使用静态变量/单例模式。它的开销为零。

于 2017-08-18T05:05:51.147 回答