Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Пример Android-приложения для видеоконференции

Данный пример может использоваться для участия в видеоконференции для трех пользователей на Web Call Server и позволяет публиковать WebRTC-поток.

...

Ниже расположены контролы для отключения/включения аудио и видео для публикуемого потока, поле ввода текстового сообщения и лог сообщений.

Работа с кодом примера

Для разбора кода возьмем класс ConferenceActivity.java примера conference, который доступен для скачивания в соответствующей сборке 1.0.1.38.

...

Например, в следующем коде подключаемся к "комнате" и запрашиваем список других участников:

Code Block
languagejsjava
themeRDark
room = roomManager.join(roomOptions);
room.on(new RoomEvent() {
    public void onState(final Room room) {
        for (final Participant participant : room.getParticipants()) {
    ...

...

Flashphoner.init() код

Code Block
languagejsjava
themeRDark
Flashphoner.init(this);

...

  • URL WCS-сервера
  • имя пользователя для присоединения к чат-комнате
Code Block
languagejsjava
themeRDark
RoomManagerOptions roomManagerOptions = new RoomManagerOptions(mWcsUrlView.getText().toString(), mLoginView.getText().toString());

/**
  * RoomManager object is created with method createRoomManager().
  * Connection session is created when RoomManager object is created.
  */
roomManager = Flashphoner.createRoomManager(roomManagerOptions);

...

RoomManager.onConnected() код

Code Block
languagejsjava
themeRDark
@Override
public void onConnected(final Connection connection) {
    runOnUiThread(new Runnable() {
        @Override
        public void run() {
            mConnectButton.setText(R.string.action_disconnect);
            mConnectButton.setTag(R.string.action_disconnect);
            mConnectButton.setEnabled(true);
            mConnectStatus.setText(connection.getStatus());
            mJoinButton.setEnabled(true);
        }
    });
}

...

Методу RoomManager.join() передается объект RoomOptions с именем комнаты конференции.

Code Block
languagejsjava
themeRDark
RoomOptions roomOptions = new RoomOptions();
roomOptions.setName(mJoinRoomView.getText().toString());

/**
  * The participant joins a conference room with method RoomManager.join().
  * RoomOptions object is passed to the method.
  * Room object is created and returned by the method.
  */
room = roomManager.join(roomOptions);

...

Если текущий участник остается в комнате, запускается проигрывание потока от других участников при помощи Participant.play()

Code Block
languagejsjava
themeRDark
@Override
public void onState(final Room room) {
    /**
      * After joining, Room object with data of the room is received.
      * Method Room.getParticipants() is used to check the number of already connected participants.
      * The method returns collection of Participant objects.
      * The collection size is determined, and, if the maximum allowed number (in this case, three) has already been reached, the user leaves the room with method Room.leave().
      */
    if (room.getParticipants().size() >= 3) {
        room.leave(null);
        runOnUiThread(
             new Runnable() {
                 @Override
                 public void run() {
                     mJoinStatus.setText("Room is full");
                     mJoinButton.setEnabled(true);
                 }
             }
        );
        return;
    }


    final StringBuffer chatState = new StringBuffer("participants: ");

    /**
      * Iterating through the collection of the other participants returned by method Room.getParticipants().
      * There is corresponding Participant object for each participant.
      */
    for (final Participant participant : room.getParticipants()) {
        /**
          * A player view is assigned to each of the other participants in the room.
          */
        final ParticipantView participantView = freeViews.poll();
        if (participantView != null) {
            chatState.append(participant.getName()).append(",");
            busyViews.put(participant.getName(), participantView);

            /**
              * Playback of the stream being published by the other participant is started with method Participant.play().
              * SurfaceViewRenderer to be used to display the video stream is passed when the method is called.
              */
            participant.play(participantView.surfaceViewRenderer);
            runOnUiThread(...
        }
    }
     new Runnable() {
                     @Override
                     public void run() {
                         participantView.login.setText(participant.getName());
                     }
                 }
            );
        }
    }
    runOnUiThread(
        new Runnable() {
            @Override
            public void run() {
                mJoinButton.setText(R.string.action_leave);
                mJoinButton.setTag(R.string.action_leave);
                mJoinButton.setEnabled(true);
                mJoinStatus.setText("");
                mPublishButton.setEnabled(true);
                mSendButton.setEnabled(true);
                if (room.getParticipants().size() == 0) {
                    addMessageHistory("chat", "room is empty");
                } else {
                    addMessageHistory("chat", chatState.substring(0, chatState.length() - 1));
                }
            }
        }
    );
}

6. Публикация видеопотока.

Room.publish() код

Методу передаются:

  • SurfaceViewRenderer, который будет использоваться для отображения видео с камеры
  • параметр record, определяющий, будет ли записываться публикуемый поток
Code Block
languagejs
themeRDark
case PUBLISH_REQUEST_CODE: {
    if (grantResults.length == 0 ||
           grantResults[0] != PackageManager.PERMISSION_GRANTED ||
           grantResults[1] != PackageManager.PERMISSION_GRANTED) {

        Log.i(TAG, "Permission has been denied by user");
    } else {
        mPublishButton.setEnabled(false);
        /**
          * Stream is created and published with method Room.publish().
          * SurfaceViewRenderer to be used to display video from the camera is passed to the method.
          */
        boolean record = mRecord.isChecked();
        StreamOptions streamOptions = new StreamOptions();
        streamOptions.setRecord(record);
        stream = room.publish(localRenderer, streamOptions);

        /**
          * Callback function for stream status change is added to make appropriate changes in controls of the interface when stream is being published.
          */
        stream.on(new StreamStatusEvent() {
            @Override
            public void onStreamStatus(final Stream stream, final StreamStatus streamStatus) {
                runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        if (StreamStatus.PUBLISHING.equals(streamStatus)) {
                            mPublishButton.setText(R.string.action_stop);
                            mPublishButton.setTag(R.string.action_stop);
                            mMuteAudio.setEnabled(true);
                            mMuteVideo.setEnabled(true);
                        } else {
                            mPublishButton.setText(R.string.action_publish);
                            mPublishButton.setTag(R.string.action_publish);
                            mMuteAudio.setEnabled(false);
                            mMuteAudio.setChecked(false);
                            mMuteVideo.setEnabled(false);
                            mMuteVideo.setChecked(false);
                            ConferenceActivity.this.stream = null;
                        }
                        if (mJoinButton.getTag() == null || Integer.valueOf(R.string.action_join).equals(mJoinButton.getTag()))...
}


6. Публикация видеопотока.

Room.publish() код

Методу передаются:

  • SurfaceViewRenderer, который будет использоваться для отображения видео с камеры
  • параметр record, определяющий, будет ли записываться публикуемый поток
Code Block
languagejava
themeRDark
case PUBLISH_REQUEST_CODE: {
    if (grantResults.length == 0 ||
           grantResults[0] !=        mPublishButton.setEnabled(false);PackageManager.PERMISSION_GRANTED ||
           grantResults[1]             } else!= PackageManager.PERMISSION_GRANTED) {

        Log.i(TAG, "Permission has been denied by user");
    } else {
        mPublishButton.setEnabled(truefalse);
        /**
          * Stream is created and  }published with method Room.publish().
          * SurfaceViewRenderer to be used to display video from the camera is passed to the mPublishStatus.setText(streamStatus.toString());method.
          */
        boolean record  }= mRecord.isChecked();
        StreamOptions streamOptions = new StreamOptions();
        }streamOptions.setRecord(record);
        stream =   }room.publish(localRenderer, streamOptions);
        });...
        Log.i(TAG, "Permission has been granted by user");
    }
}

...

Room.onJoined() код

Code Block
languagejsjava
themeRDark
@Override
public void onJoined(final Participant participant) {
    /**
      * When a new participant joins the room, a player view is assigned to that participant.
      */
    final ParticipantView participantView = freeViews.poll();
    if (participantView != null) {
        runOnUiThread(
             new Runnable() {
                 @Override
                 public void run() {
                     participantView.login.setText(participant.getName());
                     addMessageHistory(participant.getName(), "joined");
                 }
             }
        );
        busyViews.put(participant.getName(), participantView);
    }
}

...

При получении данного события поток, опубликованный участником, воспроизводится с помощью метода Participant.play(). Этому методу передается SurfaceViewRenderer, в котором будет отображаться видео

Code Block
languagejsjava
themeRDark
@Override
public void onPublished(final Participant participant) {
    /**
      * When one of the other participants starts publishing, playback of the stream published by that participant is started.
      */
    final ParticipantView participantView = busyViews.get(participant.getName());
    if (participantView != null) {
        participant.play(participantView.surfaceViewRenderer);
    }
}

...

Room.onMessage() код

Code Block
languagejsjava
themeRDark
@Override
public void onMessage(final Message message) {
/**
  * When one of the participants sends a text message, the received message is added to the messages log.
  */
    runOnUiThread(
        new Runnable() {
            @Override
            public void run() {
                addMessageHistory(message.getFrom(), message.getText());
            }
       });
}

...

10. Отправка сообщения другим участника участникам конференции

Participant.sendMessage() код

...

Room.unpublish() код

Code Block
languagejsjava
themeRDark
    @Override
    public void onClick(View view) {
        if (mPublishButton.getTag() == null || Integer.valueOf(R.string.action_publish).equals(mPublishButton.getTag())) {
            ActivityCompat.requestPermissions(ConferenceActivity.this,
                  new String[]{Manifest.permission.RECORD_AUDIO, Manifest.permission.CAMERA},
                  PUBLISH_REQUEST_CODE);
        } else {
            mPublishButton.setEnabled(false);
            /**
              * Stream is unpublished with method Room.unpublish().
              */
            room.unpublish();
        }
        View currentFocus = getCurrentFocus();
        if (currentFocus != null) {
            InputMethodManager inputManager = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
            inputManager.hideSoftInputFromWindow(currentFocus.getWindowToken(), InputMethodManager.HIDE_NOT_ALWAYS);
        }
    }
});


12. Выход из комнаты конференции при нажатии Leave

...

Методу передается обработчик ответа REST-приложения WCS-сервера.

Code Block
languagejsjava
themeRDark
room.leave(new RestAppCommunicator.Handler() {
    @Override
    public void onAccepted(Data data) {
        runOnUiThread(action);
    }

    @Override
    public void onRejected(Data data) {
        runOnUiThread(action);
    }
});

...

RoomManager.disconnect() код

Code Block
languagejsjava
themeRDark
mConnectButton.setEnabled(false);

/**
  * Connection to WCS server is closed with method RoomManager.disconnect().
  */
roomManager.disconnect();

...

Stream.unmuteAudio(), Stream.muteAudio(), Stream.unmuteVideo(), Stream.muteVideo() код

Code Block
languagejsjava
themeRDark
/**
  * MuteAudio switch is used to mute/unmute audio of the published stream.
  * Audio is muted with method Stream.muteAudio() and unmuted with method Stream.unmuteAudio().
  */
mMuteAudio = (Switch) findViewById(R.id.mute_audio);
mMuteAudio.setOnCheckedChangeListener(new CompoundButton.OnCheckedChangeListener() {
    public void onCheckedChanged(CompoundButton buttonView, boolean isChecked) {
        if (isChecked) {
            stream.muteAudio();
        } else {
            stream.unmuteAudio();
        }
    }
});

/**
  * MuteVideo switch is used to mute/unmute video of the published stream.
  * Video is muted with method Stream.muteVideo() and unmuted with method Stream.unmuteVideo().
  */
mMuteVideo = (Switch) findViewById(R.id.mute_video);
mMuteVideo.setOnCheckedChangeListener(new CompoundButton.OnCheckedChangeListener() {
    public void onCheckedChanged(CompoundButton buttonView, boolean isChecked) {
        if (isChecked) {
            stream.muteVideo();
        } else {
            stream.unmuteVideo();
        }
    }
});