111

app/src/main/java/com/shayu/phonelive/AppContext.java

@@ -156,7 +156,29 @@ public class AppContext extends CommonAppContext {
         //初始化融云
         RongcloudIMManager.initRongIM(this);
 
+        RongcloudIMManager.addRongcloudIMOnReceiveMessageListener(new RongIMClient.OnReceiveMessageWrapperListener() {
+            @Override
+            public boolean onReceived(io.rong.imlib.model.Message message, int i, boolean b, boolean b1) {
+                Log.e("wewe", message.getConversationType() + "112121");
+                //融云直播间聊天
+                Message msg = Message.obtain();
+                msg.what = Constants.SOCKET_WHAT_BROADCAST;
+                try {
+                    if (!"".equals(message.getContent()) && message.getContent() != null) {
+                        TextMessage content = (TextMessage) message.getContent();
+                        if (content.getContent().contains("_method_")) {
+                            msg.obj = content.getContent();
+                            if (SocketRyClient.mSocketHandler != null) {
+                                SocketRyClient.mSocketHandler.sendMessage(msg);
+                            }
+                        }
+                    }
+                }catch (Exception e){
 
+                }
+                return false;
+            }
+        });
 
         //监听im消息
         V2TIMManager.getInstance().addSimpleMsgListener(new V2TIMSimpleMsgListener() {