初始配置

import { RtmConfig, RtmAreaCode, RtmProtocolType, RtmLogLevel } from '@shengwang/rtm-full';

const config: RtmConfig = {
  appId: 'your_appid',
  userId: 'your_userid',
  areaCode: RtmAreaCode.CN | RtmAreaCode.AS,
  protocolType: RtmProtocolType.TCP_UDP,
  presenceTimeout: 300,
  heartbeatInterval: 5,
  useStringUserId: true,
  ispPolicyEnabled: false,
};

import { 
  RtmConfig, 
  RtmLogLevel, 
  RtmProxyType, 
  RtmEncryptionMode, 
  RtmServiceType 
} from '@shengwang/rtm-full';

// Create configuration with all options
const config: RtmConfig = {
  appId: 'your_appid',
  userId: 'your_userid',
  
  // Log configuration
  logConfig: {
    level: RtmLogLevel.INFO,
    filePath: '/data/app/el2/100/base/your_application/files/rtm_logs',
    fileSizeInKB: 10240
  },
  
  // Proxy configuration
  proxyConfig: {
    proxyType: RtmProxyType.HTTP,
    server: 'your_server_address',
    port: 8080,
    account: 'your_account',
    password: 'your_password'
  },
  
  // Encryption configuration
  encryptionConfig: {
    encryptionKey: 'your_encryption_key',
    encryptionMode: RtmEncryptionMode.AES_256_GCM,
    encryptionSalt: new Uint8Array([1, 2, 3, 4, 5, /* ... 32 bytes total */])
  },
  
  // Private deployment configuration
  privateConfig: {
    accessPointHosts: ['host1.example.com', 'host2.example.com'],
    serviceType: RtmServiceType.MESSAGE | RtmServiceType.STREAM
  }
};

constructor(config: RtmConfig)

import { RtmClient, RtmConfig } from '@shengwang/rtm-full';

const config: RtmConfig = {
  appId: 'your_appid',
  userId: 'your_userid'
};

try {
  const rtmClient = new RtmClient(config);
  console.log('RTM Client created successfully');
} catch (error) {
  console.error('Failed to create RTM client:', error);
}

import { RtmClient, LinkStateEvent, MessageEvent, TokenEvent, PresenceEvent, StorageEvent, LockEvent, TopicEvent, RtmMessageType, RtmTokenEventType, RtmPresenceEventType } from '@shengwang/rtm-full';

// Listen to link state changes
rtmClient.addEventListener('linkState', (event: object) => {
  const linkEvent = event as LinkStateEvent;
  console.log('Link state changed:', linkEvent.currentState);
  console.log('Previous state:', linkEvent.previousState);
  console.log('Reason:', linkEvent.reasonCode);
});

// Listen to incoming messages
rtmClient.addEventListener('message', (event: object) => {
  const msgEvent = event as MessageEvent;
  console.log('Received message from:', msgEvent.publisher);
  console.log('Channel:', msgEvent.channelName);
  
  if (msgEvent.messageType === RtmMessageType.STRING) {
    console.log('Text message:', msgEvent.message);
  } else {
    console.log('Binary message length:', (msgEvent.message as Uint8Array).length);
  }
});

// Listen to token events
rtmClient.addEventListener('token', (event: object) => {
  const tokenEvent = event as TokenEvent;
  if (tokenEvent.eventType === RtmTokenEventType.WILL_EXPIRE) {
    console.log('Token will expire, renewing...');
    rtmClient.renewToken('new_token_string');
  }
});

// Listen to presence events
rtmClient.addEventListener('presence', (event: object) => {
  const presenceEvent = event as PresenceEvent;
  console.log('Presence event:', presenceEvent.eventType);
  console.log('Channel:', presenceEvent.channelName);
});

// Listen to storage events
rtmClient.addEventListener('storage', (event: object) => {
  const storageEvent = event as StorageEvent;
  console.log('Storage event:', storageEvent.eventType);
  console.log('Target:', storageEvent.target);
});

// Listen to lock events
rtmClient.addEventListener('lock', (event: object) => {
  const lockEvent = event as LockEvent;
  console.log('Lock event:', lockEvent.eventType);
  console.log('Channel:', lockEvent.channelName);
});

// Listen to topic events
rtmClient.addEventListener('topic', (event: object) => {
  const topicEvent = event as TopicEvent;
  console.log('Topic event:', topicEvent.eventType);
  console.log('Channel:', topicEvent.channelName);
});

removeEventListener(eventName: string, callback?: (event: object) => void): void

import { RtmClient, MessageEvent } from '@shengwang/rtm-full';

// 定义一个回调函数
const messageHandler = (event: object) => {
  const msgEvent = event as MessageEvent;
  console.log('Received message:', msgEvent.message);
};

// 添加监听
rtmClient.addEventListener('message', messageHandler);

// 删除特定的监听器
rtmClient.removeEventListener('message', messageHandler);

// 或者删除该事件的所有监听器
rtmClient.removeEventListener('message');

// 删除其他事件的监听器
rtmClient.removeEventListener('linkState');
rtmClient.removeEventListener('presence');
rtmClient.removeEventListener('storage');

async login(token?: string): Promise<LoginResponse>

import { RtmClient, RtmError } from '@shengwang/rtm-full';

try {
  const response = await rtmClient.login('your_token');
  console.log('Login successful, timestamp:', response.timestamp);
} catch (error) {
  if (error instanceof RtmError) {
    console.error('Login failed:', error.errorCode, error.reason);
  }
}

// Login with empty token (if token authentication is not enabled)
try {
  const response = await rtmClient.login();
  console.log('Login successful');
} catch (error) {
  if (error instanceof RtmError) {
    console.error('Login failed:', error.errorCode, error.reason);
  }
}

async logout(): Promise<LogoutResponse>

import { RtmError } from '@shengwang/rtm-full';

try {
  const response = await rtmClient.logout();
  console.log('Logout successful, timestamp:', response.timestamp);
} catch (error) {
  if (error instanceof RtmError) {
    console.error('Logout failed:', error.errorCode, error.reason);
  }
}

release(): void

// Release the RTM client instance
rtmClient.release();
console.log('RTM client released');

// After release, you need to create a new instance to use RTM again