小贝子编程

通过Android在YouTube上直播时，不活跃的流



我能够通过YouTube API创建事件。事件正在我的YouTube页面"事件选项卡"（即将到来的类别）中显示。但是，当我开始流式传输时，它会返回错误403（流不活动）。我想每次上线时都会创建一个新的广播事件。任何帮助将不胜感激。这是我的代码....

这在AsyncTask中：

YouTube youtube = new YouTube.Builder(transport, jsonFactory,
        credential).setApplicationName(APP_NAME).build();
YouTubeApi.createLiveEvent(youtube, "event description", "event name");

在方法YoutubeApi.createLiveEvent(...)中：

public static void createLiveEvent(YouTube youtube, String description,
    String name) {
    try {
        LiveBroadcastSnippet broadcastSnippet = new LiveBroadcastSnippet();
        broadcastSnippet.setTitle(name);
        broadcastSnippet.setScheduledStartTime(new DateTime(new Date()));
        LiveBroadcastContentDetails contentDetails = new LiveBroadcastContentDetails();
        MonitorStreamInfo monitorStream = new MonitorStreamInfo();
        monitorStream.setEnableMonitorStream(false);
        contentDetails.setMonitorStream(monitorStream);
        // Create LiveBroadcastStatus with privacy status.
        LiveBroadcastStatus status = new LiveBroadcastStatus();
        status.setPrivacyStatus("public");

        LiveBroadcast broadcast = new LiveBroadcast();
        broadcast.setKind("youtube#liveBroadcast");
        broadcast.setSnippet(broadcastSnippet);
        broadcast.setStatus(status);
        broadcast.setContentDetails(contentDetails);
        // Create the insert request
        YouTube.LiveBroadcasts.Insert liveBroadcastInsert = youtube
            .liveBroadcasts().insert("snippet,status,contentDetails",
                broadcast);
        // Request is executed and inserted broadcast is returned
        LiveBroadcast returnedBroadcast = liveBroadcastInsert.execute();
        // Create a snippet with title.
        LiveStreamSnippet streamSnippet = new LiveStreamSnippet();
        streamSnippet.setTitle(name);
        // Create content distribution network with format and ingestion
        // type.
        CdnSettings cdn = new CdnSettings();
        cdn.setFormat("240p");
        cdn.setIngestionType("rtmp");
        LiveStream stream = new LiveStream();
        stream.setKind("youtube#liveStream");
        stream.setSnippet(streamSnippet);
        stream.setCdn(cdn);
        // Create the insert request
        YouTube.LiveStreams.Insert liveStreamInsert = youtube.liveStreams()
            .insert("snippet,cdn", stream);
        // Request is executed and inserted stream is returned
        LiveStream returnedStream = liveStreamInsert.execute();
        // Create the bind request
        YouTube.LiveBroadcasts.Bind liveBroadcastBind = youtube
            .liveBroadcasts().bind(returnedBroadcast.getId(),
                "id,contentDetails");
        // Set stream id to bind
        liveBroadcastBind.setStreamId(returnedStream.getId());
        // Request is executed and bound broadcast is returned
        liveBroadcastBind.execute();
    } catch (GoogleJsonResponseException e) {
        System.err.println("GoogleJsonResponseException code: " + e.getDetails().getCode() + " : " + e.getDetails().getMessage());
        e.printStackTrace();
    } catch (IOException e) {
        System.err.println("IOException: " + e.getMessage());
        e.printStackTrace();
    } catch (Throwable t) {
        System.err.println("Throwable: " + t.getStackTrace());
        t.printStackTrace();
    }
}

这是我启动事件流的代码：

public static void startEvent(YouTube youtube, String broadcastId) // broadcast id is same(checked)
        throws IOException {
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        Log.e(APP_NAME, "", e);
    }
    YouTube.LiveStreams.List liveBroadcastRequest = youtube
            .liveStreams().list("id,snippet,status");
    // liveBroadcastRequest.setMine(true);
    liveBroadcastRequest.setId(broadcastId);  //  setBroadcastStatus("upcoming");

    // List request is executed and list of broadcasts are returned
    LiveStreamListResponse returnedListResponse = liveBroadcastRequest.execute();
    List<LiveStream> returnedList = returnedListResponse.getItems();

    Transition transitionRequest = youtube.liveBroadcasts().transition(
            "live", broadcastId, "status");
    transitionRequest.execute();
}

我收到的例外日志：

com.google.api.client.googleapis.json.GoogleJsonResponseException: 403 Forbidden
{
  "code": 403,
  "errors": [
    {
      "domain": "youtube.liveBroadcast",
      "message": "Stream is inactive",
      "reason": "errorStreamInactive",
      "extendedHelp": "https://developers.google.com/youtube/v3/live/docs/liveBroadcasts/transition"
    }
  ],
  "message": "Stream is inactive"
}
at com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:113)
at com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:40)
at com.google.api.client.googleapis.services.AbstractGoogleClientRequest$1.interceptResponse(AbstractGoogleClientRequest.java:321)
at com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1065)
at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:419)
at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:352)
at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:469)
at net.ossrs.yasea.demo.utils.YouTubeApi.startEvent(YouTubeApi.java:236)
at net.ossrs.yasea.demo.rtmp.YoutubeRTMPUrl$StartEventTask.doInBackground(YoutubeRTMPUrl.java:160)
at net.ossrs.yasea.demo.rtmp.YoutubeRTMPUrl$StartEventTask.doInBackground(YoutubeRTMPUrl.java:144)
at android.os.AsyncTask$2.call(AsyncTask.java:295)
at java.util.concurrent.FutureTask.run(FutureTask.java:237)
at android.os.AsyncTask$SerialExecutor$1.run(AsyncTask.java:234)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1113)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:588)
at java.lang.Thread.run(Thread.java:818

我几天前就面临类似的问题...这是我所做的...

点要记住：a）您可能会在API中收到一个差异RTMP URL，而不是YouTube事件门户。

b）在广播过渡到状态"实时"时，您可能会收到403个错误

现在出现错误403（流不活动）：

在调用"广播过渡"之前，请确保将帧/数据发送到YouTube。 现在，在一个线程暂停为几秒钟上的diff线程上调用" barty.transition"（可能需要时间将数据发送到YouTube）。

eg：

公共静态void startEvent（最终YouTube YouTube，Final String BroadcastID） 抛出ioexception {

    try {
        Thread.sleep(10000);
    } catch (InterruptedException e) {
        Log.e(APP_NAME, "", e);
    }
    Transition transitionRequest = youtube.liveBroadcasts().transition(
            "live", broadcastId, "status");
    transitionRequest.execute();
}

我希望这会有所帮助..

您需要等待流状态切换到active。因此，您必须存储流ID和广播ID等待此状态。

可以使用TimerTask或ScheduledExecutorService进行检查：

mScheduleTaskExecutor = Executors.newSingleThreadScheduledExecutor();
// check every 2 seconds the stream status
mScheduleTaskExecutor.scheduleAtFixedRate(new Runnable() {
    @Override
    public void run() {
        try {
            if (mStreamId != null) {
                checkStreamStatus();
            }
        } catch (IOException e) {
            Log.e(TAG, null, e);
        }
    }
}, 0, 2, TimeUnit.SECONDS);

checkStreamStatus方法检查流状态，如果需要，它也可以检查流健康（健康状态"GOOD"）：

public void checkStreamStatus() throws IOException {
    YouTube.LiveStreams.List livestreamRequest = youtube.liveStreams().list("status");
    livestreamRequest.setId(mStreamId);
    LiveStreamListResponse returnedListResponse = livestreamRequest.execute();
    List < LiveStream > returnedList = returnedListResponse.getItems();
    if (returnedList.size() == 1) {
        LiveStream stream = returnedList.get(0);
        Log.v(TAG, "the current stream status is : " + stream.getStatus().getStreamStatus());
        if (stream.getStatus().getStreamStatus().equals("active")) {
            Log.v(TAG, "start broadcasting now");
            startEvent();
            mScheduleTaskExecutor.shutdownNow();
        }
    }
}

这是一个完整的示例：

public class YoutubeTask extends AsyncTask < Void, Void, String > {
    private final static String TAG = YoutubeTask.class.getSimpleName();
    private ScheduledExecutorService mScheduleTaskExecutor;
    private String mStreamId;
    private String mBroadcastId;
    private static YouTube youtube;
    @Override
    protected String doInBackground(Void...params) {
        mScheduleTaskExecutor = Executors.newSingleThreadScheduledExecutor();
        // Authorize the request.
        Credential credential = new GoogleCredential().setAccessToken("...");
        // This object is used to make YouTube Data API requests.
        youtube = new YouTube.Builder(new NetHttpTransport(), new JacksonFactory(), credential)
            .setApplicationName("youtube-cmdline-createbroadcast-sample").build();
        createLiveEvent(youtube, "event name");
        // check every 2 seconds the stream status
        mScheduleTaskExecutor.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                try {
                    if (mStreamId != null) {
                        checkStreamStatus();
                    }
                } catch (IOException e) {
                    Log.e(TAG, null, e);
                }
            }
        }, 0, 2, TimeUnit.SECONDS);
        return null;
    }
    public void createLiveEvent(YouTube youtube, String name) {
        try {
            LiveBroadcastSnippet broadcastSnippet = new LiveBroadcastSnippet();
            broadcastSnippet.setTitle(name);
            broadcastSnippet.setScheduledStartTime(new DateTime(new Date()));
            LiveBroadcastContentDetails contentDetails = new LiveBroadcastContentDetails();
            MonitorStreamInfo monitorStream = new MonitorStreamInfo();
            monitorStream.setEnableMonitorStream(false);
            contentDetails.setMonitorStream(monitorStream);
            LiveBroadcastStatus status = new LiveBroadcastStatus();
            status.setPrivacyStatus("public");
            LiveBroadcast broadcast = new LiveBroadcast();
            broadcast.setKind("youtube#liveBroadcast");
            broadcast.setSnippet(broadcastSnippet);
            broadcast.setStatus(status);
            broadcast.setContentDetails(contentDetails);
            YouTube.LiveBroadcasts.Insert liveBroadcastInsert = youtube
                .liveBroadcasts().insert("snippet,status,contentDetails",
                    broadcast);
            LiveBroadcast returnedBroadcast = liveBroadcastInsert.execute();
            LiveStreamSnippet streamSnippet = new LiveStreamSnippet();
            streamSnippet.setTitle(name);
            CdnSettings cdn = new CdnSettings();
            cdn.setFormat("240p");
            cdn.setIngestionType("rtmp");
            LiveStream stream = new LiveStream();
            stream.setKind("youtube#liveStream");
            stream.setSnippet(streamSnippet);
            stream.setCdn(cdn);
            // Create the insert request
            YouTube.LiveStreams.Insert liveStreamInsert = youtube.liveStreams().insert("snippet,cdn", stream);
            // Request is executed and inserted stream is returned
            LiveStream returnedStream = liveStreamInsert.execute();
            // Create the bind request
            YouTube.LiveBroadcasts.Bind liveBroadcastBind = youtube.liveBroadcasts().bind(returnedBroadcast.getId(),
                "id,contentDetails");
            // Set stream id to bind
            liveBroadcastBind.setStreamId(returnedStream.getId());
            // Request is executed and bound broadcast is returned
            liveBroadcastBind.execute();
            // store stream Id & broadcast Id
            mStreamId = returnedStream.getId();
            mBroadcastId = returnedBroadcast.getId();
        } catch (GoogleJsonResponseException e) {
            Log.e(TAG, null, e);
        } catch (IOException e) {
            Log.e(TAG, null, e);
        } catch (Throwable t) {
            Log.e(TAG, null, t);
        }
    }
    public void checkStreamStatus() throws IOException {
        YouTube.LiveStreams.List livestreamRequest = youtube.liveStreams().list("status");
        livestreamRequest.setId(mStreamId);
        LiveStreamListResponse returnedListResponse = livestreamRequest.execute();
        List < LiveStream > returnedList = returnedListResponse.getItems();
        if (returnedList.size() == 1) {
            LiveStream stream = returnedList.get(0);
            Log.v(TAG, "the current stream status is : " + stream.getStatus().getStreamStatus());
            if (stream.getStatus().getStreamStatus().equals("active")) {
                Log.v(TAG, "start broadcasting now");
                startEvent();
                mScheduleTaskExecutor.shutdownNow();
            }
        }
    }
    public void startEvent() throws IOException {
        YouTube.LiveBroadcasts.Transition transitionRequest = youtube.liveBroadcasts().transition(
            "live", mBroadcastId, "status");
        transitionRequest.execute();
    }
}

使用new YoutubeTask().execute();

启动此示例

您可以通过从OAuth Playground带有示波器https://www.googleapis.com/auth/youtube的OAUTH游乐场直接测试它。另外，用于测试流，我建议使用Android App RTMP摄像机来测试摄像机流到YouTube，您可以直接放置流名称XXXX-XXXX-XXXX-XXXX

相关内容

  • 没有找到相关文章

最新更新


热门标签：

javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium