public class LPChatServer extends LPWSServer implements ChatServer
LPWSServer.OnResponseModelListener<T>, LPWSServer.ResponseListener
构造器和说明 |
---|
LPChatServer(LPSDKContext sdkContext) |
LPChatServer(java.lang.String ipAddr,
int port,
java.util.ArrayList<LPIpAddress> backupIpAddrs,
LPSDKContext sdkContext) |
限定符和类型 | 方法和说明 |
---|---|
io.reactivex.Flowable<LPResChatLoginModel> |
getObservableOfLogin()
Chat Server返回
|
io.reactivex.Observable<LPMessageRevoke> |
getObservableOfMsgRevoke() |
io.reactivex.Observable<LPMessageRevoke> |
getObservableOfMsgRevokeRes() |
io.reactivex.Flowable<LPMessageModel> |
getObservableOfReceiveMessage()
接收消息
|
io.reactivex.Observable<LPMessageTranslateModel> |
getObservableOfReceiveTranslateMessage() |
io.reactivex.Observable<LPWhisperListModel> |
getObservableOfWhisperList()
私聊消息回调
|
java.lang.String |
getWSServerName() |
void |
login(java.lang.String classId,
LPUserModel userModel,
java.lang.String partnerId)
登录 chat room
|
void |
onClose(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client) |
void |
onFailure(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client,
java.lang.Throwable e) |
void |
onMessage(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client,
okio.ByteString inputStream) |
void |
onReconnect(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client) |
void |
onSentMessageFailure(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client,
com.baijiahulian.common.networkv2_ws.common.BJMessageBody messageBody) |
void |
onStateChanged(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client,
com.baijiahulian.common.networkv2_ws.common.BJNetworkClientState state) |
void |
requestForbidAll(long roomId,
LPUserModel from,
int group,
int duration)
设置全体禁言(group)
|
void |
requestForbidChat(long roomId,
LPUserModel from,
LPUserModel to,
long duration)
单个用户禁言
|
void |
requestMsgRevoke(java.lang.String msgId,
java.lang.String fromId,
java.lang.String classId,
java.lang.String userId) |
void |
requestWhisperList(java.lang.String roomId,
java.lang.String from,
java.lang.String to,
int start,
int count)
拉取私聊消息
|
void |
resetReconnectDelay() |
void |
sendMessage(java.lang.String content,
LPMessageDataModel data,
LPUserModel from,
IUserModel toUser,
java.lang.String channel,
LPMessageReferenceModel referenceModel,
java.util.Set<LPMessageAtUserModel> atUserList) |
void |
sendMessage(java.lang.String message,
LPUserModel from,
IUserModel toUser,
java.lang.String channel,
LPMessageReferenceModel referenceModel,
java.util.Set<LPMessageAtUserModel> atUserList) |
void |
sendRequest(java.lang.String request) |
void |
sendTranslateMessage(java.lang.String message,
java.lang.String messageId,
java.lang.String classId,
java.lang.String userId,
java.lang.String fromLanguage,
java.lang.String toLanguage) |
connect, disconnect, getClientType, getCurrentIpAddress, getSubjectOfFailure, getWSConnectionState, notifyNetworkSwitch, onMessage, registerResponseListenerAndModel, reset, setAddress, setBackupIpAddrs, setClientInfo, setClientName, unregisterResponseListener
getCurrentIpAddress
public LPChatServer(LPSDKContext sdkContext)
public LPChatServer(java.lang.String ipAddr, int port, java.util.ArrayList<LPIpAddress> backupIpAddrs, LPSDKContext sdkContext)
public void login(java.lang.String classId, LPUserModel userModel, java.lang.String partnerId)
classId
- userModel
- public void sendMessage(java.lang.String message, LPUserModel from, IUserModel toUser, java.lang.String channel, LPMessageReferenceModel referenceModel, java.util.Set<LPMessageAtUserModel> atUserList)
sendMessage
在接口中 ChatServer
public void sendMessage(java.lang.String content, LPMessageDataModel data, LPUserModel from, IUserModel toUser, java.lang.String channel, LPMessageReferenceModel referenceModel, java.util.Set<LPMessageAtUserModel> atUserList)
sendMessage
在接口中 ChatServer
public void sendTranslateMessage(java.lang.String message, java.lang.String messageId, java.lang.String classId, java.lang.String userId, java.lang.String fromLanguage, java.lang.String toLanguage)
sendTranslateMessage
在接口中 ChatServer
public io.reactivex.Flowable<LPResChatLoginModel> getObservableOfLogin()
public io.reactivex.Flowable<LPMessageModel> getObservableOfReceiveMessage()
getObservableOfReceiveMessage
在接口中 ChatServer
public io.reactivex.Observable<LPMessageTranslateModel> getObservableOfReceiveTranslateMessage()
public void requestMsgRevoke(java.lang.String msgId, java.lang.String fromId, java.lang.String classId, java.lang.String userId)
requestMsgRevoke
在接口中 ChatServer
public io.reactivex.Observable<LPMessageRevoke> getObservableOfMsgRevokeRes()
getObservableOfMsgRevokeRes
在接口中 ChatServer
public io.reactivex.Observable<LPMessageRevoke> getObservableOfMsgRevoke()
getObservableOfMsgRevoke
在接口中 ChatServer
public void onStateChanged(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client, com.baijiahulian.common.networkv2_ws.common.BJNetworkClientState state)
onStateChanged
在接口中 com.baijiahulian.common.networkv2_ws.common.BJNetworkClientListener
public java.lang.String getWSServerName()
public void sendRequest(java.lang.String request)
public void onSentMessageFailure(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client, com.baijiahulian.common.networkv2_ws.common.BJMessageBody messageBody)
onSentMessageFailure
在接口中 com.baijiahulian.common.networkv2_ws.common.BJNetworkClientListener
onSentMessageFailure
在类中 LPWSServer
public void onMessage(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client, okio.ByteString inputStream)
onMessage
在接口中 com.baijiahulian.common.networkv2_ws.common.BJNetworkClientListener
public void onReconnect(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client)
onReconnect
在接口中 com.baijiahulian.common.networkv2_ws.common.BJNetworkClientListener
onReconnect
在类中 LPWSServer
public void onClose(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client)
onClose
在接口中 com.baijiahulian.common.networkv2_ws.common.BJNetworkClientListener
public void resetReconnectDelay()
public void onFailure(com.baijiahulian.common.networkv2_ws.common.IBJNetworkClient client, java.lang.Throwable e)
onFailure
在接口中 com.baijiahulian.common.networkv2_ws.common.BJNetworkClientListener
onFailure
在类中 LPWSServer
public void requestForbidChat(long roomId, LPUserModel from, LPUserModel to, long duration)
requestForbidChat
在接口中 ChatServer
from
- to
- duration
- public void requestForbidAll(long roomId, LPUserModel from, int group, int duration)
ChatServer
requestForbidAll
在接口中 ChatServer
roomId
- 直播房间号from
- 设置用户group
- message_send_forbid_all_triggerpublic void requestWhisperList(java.lang.String roomId, java.lang.String from, java.lang.String to, int start, int count)
ChatServer
requestWhisperList
在接口中 ChatServer
public io.reactivex.Observable<LPWhisperListModel> getObservableOfWhisperList()
ChatServer
getObservableOfWhisperList
在接口中 ChatServer