构建千万用户规模的实时互动应用 RTM 仅需 30分钟 构建千万用户规模的实时互动应用 RTM 仅需 30分钟

public class EventHandler implements RtmEventListener {

    @Override

    public void onMessageEvent ( MessageEvent event ) {}

}

String appId = “your_appId”

String userId = “your_userId”

RtmConfig rtmConfig = new RtmConfig.Builder( appId, userIdeventListener(new EventHandler() ).build()

rtmClient = RtmClient.create( rtmConfig )

String token = “your_token”

rtmClient. login ( token, new ResultCallback < Void> () {

    @Override

    public void onSuccess ( Void responseInfo ) {}

    @Override

    public void onFailure ( ErrorInfo errorInfo ) {}

})

String channelName = “Room1”

String message = “Hello World”

PublishOptions options = new PublishOptions()

rtmClient. publish ( channelName, message, options, new ResultCallback < Void> () {

    @Override

    public void onSuccess ( Void responseInfo ) {}

    @Override

    public void onFailure ( ErrorInfo errorInfo ) {}

})

@interface EvnetHandler : NSObject <AgoraRtmClientDelegate>

@end

@implementation EvnetHandler

– (void)rtmKitAgoraRtmClientKit *)rtmKit didReceiveMessageEventAgoraRtmMessageEvent *)event {}

@end

NSString* appId = @“your_appId”

NSString* userId = @“your_userId”

AgoraRtmClientConfig* cfg = [[AgoraRtmClientConfig alloc] initWithAppId : appId userId : userId]

NSError* initError = nil

AgoraRtmClientKit* client = [[AgoraRtmClientKit alloc] initWithConfig : cfg delegate : &initError]

NSString* token = @“your_token”

[ client loginByToken :token completion :^( AgoraRtmCommonResponse * _Nullable response , AgoraRtmErrorInfo * _Nullable errorInfo ) {

     if ( errorInfo == nil ) {

     } else {

     }

}]

publish message

NSString* channelName = @“Room1”

NSString* message = @“Hello World”

[ client publish :message option :nil completion :^( AgoraRtmCommonResponse * response , AgoraRtmErrorInfo* _Nullable errorInfo ) {

     if ( errorInfo == nil ) {

     } else {

     }

}]

#include <mutex>

#include <condition_variable>

#include “IAgoraRtmClient.h”

using namespace std;

using namespace agora::rtm;

static const char* kAppName = “[rtm-demo]”;

mutex mtx;

condition_variable cv;

bool ready = false;

class RtmEventHandler : public IRtmEventHandler {

    public:

     void onMessageEvent(const IRtmEventHandler::MessageEvent &event) override {

         printf(“%s: message event: %s \r\n”, kAppName, event.message);

    }

     void onLoginResult(RTM_ERROR_CODEerrorCode) override {

         printf(“%s: login with error code: %d \r\n”, kAppName, errorCode);

        if (errorCode == RTM_ERROR_OK) {

            std ::unique_lock<std::mutex> lck(mtx);

             ready = true;

             cv.notify_all();

        }

    }

};

private string appId = “your_appId”

private string userId = “your_userId”

private string channelName = “ROOM1”

private IRtmClient rtmClient

public void Awake()

{

     Initialize()

}

public async void Initialize()

{

     RtmConfig config = new RtmConfig()

     config.appId = appId

     config.userId = userId

     try {

         rtmClient = RtmClient. CreateAgoraRtmClient . (config)

     } catch (RTMException e) {

     }

     rtmClient. OnMessageEvent += OnMessageEvent

     SubscribeOptions subscribeOptions = new SubscribeOptions ()

     var result1 = await rtmClient. SubscribeAsync( channelName, subscribeOptions)

     PublishOptions publishOptions = new PublishOptions ()

     var result2 = await rtmClient. PublishAsync( channelName, “Hello,World” , subscribeOptions)

}

private void OnMessageEvent( MessageEvent eve)

{

     Debug. Log( string. Format ( “Received message:{0} from :{1} “, eve. publisher, eve. message ))

}