1. 集群调用函数

执行命令
rp(tool:rpc({application, get_env, [message_store, is_use_channel_sync]}, 'msync@ebs')).
查日志
tool:log_search_rpc("2022-07-05 15:18:27", 7200, "1028405512963623676", 20, "ejabberd@ebs").

查聊天室
[MucPid] = easemob_muc_router:get_router(<<"easemob-demo#easeim_185068033212417">>).
rp(tool:get_state("<55333.5711.7675>")).

config:load_env("/data/apps/opt/msync/releases/23.3.1.0/sys.config").
easemob_traffic_control_sup:stop(),easemob_traffic_control_sup:start().

2. trace

{ok, Dev} = file:open("/tmp/trace",[write]).
recon_trace:calls({queue, in, fun(_) -> return_trace() end}, 3, [{io_server, Dev}]).

recon_trace:calls({easemob_user_channel, read, fun(_) -> return_trace() end}, 100, [{return_to, true}, {scope, local}]).

3. kafka

./kafka-consumer-groups.sh --bootstrap-server hsb-didi-guangzhou-mesos-master2:9092 --list

./kafka-consumer-groups.sh --bootstrap-server hsb-didi-guangzhou-mesos-master2:9092 --describe --group msync-channel-outgoing

rm /Users/one/easemob/msync/apps/msync/src/msync.appup.src

4. msync kafka

msync_log, easemob_log， easemob_log_worker: kafka的生产者

• 用户发送的消息，支持的消息类型有上行，下行，离线，ack
• 用户的状态
• 好友操作
• 用户禁言操作
• 敏感词
• ...

easemob_rest_event: 消费redis/kafka，发送多人聊天事件消息 (发现聊天室/群组kafka消费处于空转状态)
msync_easemob_sendmsg: 消费redis/kafka发消息

easemob_kafka: 读写kafka的核心模块

相关配置

• kafka_client_module brod | ekaf
• queue_log_module kafka | redis
• kafka_log_async true | false

测试

1. 登陆
2. 禁言 （单聊，群聊，聊天室）
3. 发消息（单聊，群聊，聊天室，消息撤回，消息透传和扩展）
4. 好友（添加，删除，拒绝，接受）
5. presence
6. 黑名单
7. 通知

问题：

1. 无法设置app_config
2. 无法访问存储

Fri Dec 1 14:21:07 2023