Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
 heavyrain2012
|
5ae8e375bf | ||
|
heavyrain2012
|
d7a0fd29bb | ||
|
heavyrain2012
|
92c59d2fe8 | ||
|
heavyrain2012
|
7824fb3844 | ||
|
heavyrain2012
|
0390d44c63 | ||
|
heavyrain2012
|
4fdc883f25 | ||
|
heavyrain2012
|
3862ab5254 | ||
|
heavyrain2012
|
38002aecc9 |
@@ -65,6 +65,9 @@ message.remote_history_message 0
|
||||
##服务器为每个用户缓存的消息数量。这个值改得太大，拉取消息时间变长，另外会占用大量内存。
|
||||
message.max_queue 1024
|
||||
|
||||
##是否开启拉取聊天室远程历史消息。如果为1，可以下拉继续加载在服务器上的该聊天室的消息；如果为0则不能。默认为1
|
||||
message.chatroom_remote_history_message 1
|
||||
|
||||
##是否禁止陌生人聊天
|
||||
message.disable_stranger_chat false
|
||||
|
||||
|
||||
@@ -0,0 +1 @@
|
||||
alter table `t_user_messages` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
+257
@@ -0,0 +1,257 @@
|
||||
alter table `t_user_messages` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_0` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_1` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_2` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_3` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_4` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_5` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_6` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_7` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_8` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_9` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_10` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_11` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_12` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_13` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_14` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_15` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_16` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_17` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_18` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_19` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_20` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_21` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_22` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_23` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_24` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_25` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_26` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_27` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_28` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_29` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_30` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_31` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_32` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_33` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_34` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_35` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_36` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_37` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_38` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_39` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_40` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_41` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_42` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_43` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_44` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_45` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_46` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_47` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_48` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_49` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_50` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_51` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_52` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_53` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_54` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_55` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_56` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_57` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_58` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_59` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_60` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_61` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_62` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_63` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_64` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_65` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_66` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_67` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_68` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_69` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_70` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_71` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_72` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_73` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_74` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_75` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_76` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_77` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_78` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_79` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_80` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_81` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_82` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_83` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_84` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_85` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_86` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_87` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_88` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_89` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_90` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_91` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_92` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_93` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_94` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_95` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_96` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_97` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_98` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_99` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_100` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_101` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_102` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_103` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_104` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_105` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_106` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_107` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_108` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_109` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_110` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_111` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_112` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_113` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_114` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_115` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_116` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_117` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_118` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_119` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_120` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_121` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_122` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_123` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_124` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_125` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_126` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
|
||||
alter table `t_user_messages_127` add column `_cont_type` int(11) NOT NULL DEFAULT '0';
|
||||
+1
-1
@@ -5,7 +5,7 @@
|
||||
<relativePath>../</relativePath>
|
||||
<artifactId>wildfirechat-parent</artifactId>
|
||||
<groupId>cn.wildfirechat</groupId>
|
||||
<version>0.75</version>
|
||||
<version>0.76</version>
|
||||
</parent>
|
||||
|
||||
<artifactId>moquette-broker</artifactId>
|
||||
|
||||
@@ -25,6 +25,7 @@ import java.util.concurrent.Executors;
|
||||
|
||||
import static io.moquette.BrokerConstants.PUSH_ANDROID_SERVER_ADDRESS;
|
||||
import static io.moquette.BrokerConstants.PUSH_IOS_SERVER_ADDRESS;
|
||||
import static win.liyufan.im.HttpUtils.HttpPostType.POST_TYPE_Push;
|
||||
|
||||
public class PushServer {
|
||||
private static final Logger LOG = LoggerFactory.getLogger(PushServer.class);
|
||||
@@ -99,7 +100,7 @@ public class PushServer {
|
||||
url = iOSPushServerUrl;
|
||||
pushMessage.voipDeviceToken = session.getVoipDeviceToken();
|
||||
}
|
||||
HttpUtils.httpJsonPost(url, new Gson().toJson(pushMessage, pushMessage.getClass()));
|
||||
HttpUtils.httpJsonPost(url, new Gson().toJson(pushMessage, pushMessage.getClass()), POST_TYPE_Push);
|
||||
} else {
|
||||
LOG.info("Not mobile platform {}", session.getPlatform());
|
||||
}
|
||||
|
||||
@@ -30,8 +30,6 @@ public final class BrokerConstants {
|
||||
public static final String HTTP_LOCAL_PORT = "local_port";
|
||||
|
||||
public static final String HTTP_ADMIN_PORT = "http.admin.port";
|
||||
public static final String NODE_ID = "node_id";
|
||||
public static final String NODE_IDS = "node_ids";
|
||||
public static final String DEFAULT_MOQUETTE_STORE_MAP_DB_FILENAME = "moquette_store.mapdb";
|
||||
public static final String DEFAULT_PERSISTENT_PATH = System.getProperty("user.dir") + File.separator
|
||||
+ DEFAULT_MOQUETTE_STORE_MAP_DB_FILENAME;
|
||||
@@ -106,11 +104,6 @@ public final class BrokerConstants {
|
||||
public static final String CHATROOM_INFO_UPDATE_CALLBACK = "chatroom.chatroom_info_update_callback";
|
||||
public static final String CHATROOM_MEMBER_UPDATE_CALLBACK = "chatroom.chatroom_member_update_callback";
|
||||
|
||||
|
||||
public static final String HZ_Cluster_Node_External_IP = "node_external_ip";
|
||||
public static final String HZ_Cluster_Node_External_Long_Port = "node_external_long_port";
|
||||
public static final String HZ_Cluster_Node_External_Short_Port = "node_external_short_port";
|
||||
public static final String HZ_Cluster_Node_ID = "node_id";
|
||||
public static final String HTTP_SERVER_SECRET_KEY = "http.admin.secret_key";
|
||||
public static final String HTTP_SERVER_API_NO_CHECK_TIME = "http.admin.no_check_time";
|
||||
|
||||
@@ -138,6 +131,7 @@ public final class BrokerConstants {
|
||||
|
||||
public static final String MESSAGE_ROAMING = "message.roaming";
|
||||
public static final String MESSAGE_Remote_History_Message = "message.remote_history_message";
|
||||
public static final String MESSAGE_Remote_Chatroom_History_Message = "message.chatroom_remote_history_message";
|
||||
|
||||
public static final String MESSAGE_Max_Queue = "message.max_queue";
|
||||
|
||||
|
||||
@@ -38,7 +38,7 @@ public class LoadRemoteMessagesHandler extends IMHandler<WFCMessage.LoadRemoteMe
|
||||
}
|
||||
}
|
||||
|
||||
WFCMessage.PullMessageResult result = m_messagesStore.loadRemoteMessages(fromUser, request.getConversation(), beforeUid, request.getCount());
|
||||
WFCMessage.PullMessageResult result = m_messagesStore.loadRemoteMessages(fromUser, request.getConversation(), beforeUid, request.getCount(), request.getContentTypeList());
|
||||
byte[] data = result.toByteArray();
|
||||
LOG.info("User {} load message with count({}), payload size({})", fromUser, result.getMessageCount(), data.length);
|
||||
ackPayload.ensureWritable(data.length).writeBytes(data);
|
||||
|
||||
@@ -17,10 +17,6 @@ import io.netty.buffer.ByteBuf;
|
||||
import cn.wildfirechat.common.ErrorCode;
|
||||
import win.liyufan.im.IMTopic;
|
||||
|
||||
import static io.moquette.BrokerConstants.HZ_Cluster_Node_External_IP;
|
||||
import static io.moquette.BrokerConstants.HZ_Cluster_Node_External_Long_Port;
|
||||
import static io.moquette.BrokerConstants.HZ_Cluster_Node_External_Short_Port;
|
||||
|
||||
@Handler(IMTopic.RouteTopic)
|
||||
public class RouteHandler extends IMHandler<WFCMessage.RouteRequest> {
|
||||
@Override
|
||||
@@ -38,10 +34,9 @@ public class RouteHandler extends IMHandler<WFCMessage.RouteRequest> {
|
||||
return ErrorCode.ERROR_CODE_SECRECT_KEY_MISMATCH;
|
||||
}
|
||||
|
||||
Member member = mServer.getHazelcastInstance().getCluster().getLocalMember();
|
||||
String serverIp = member.getStringAttribute(HZ_Cluster_Node_External_IP);
|
||||
String longPort = member.getStringAttribute(HZ_Cluster_Node_External_Long_Port);
|
||||
String shortPort = member.getStringAttribute(HZ_Cluster_Node_External_Short_Port);
|
||||
String serverIp = mServer.getServerIp();
|
||||
String longPort = mServer.getLongPort();
|
||||
String shortPort = mServer.getShortPort();
|
||||
|
||||
ClientSession clientSession = m_sessionsStore.sessionForClient(clientID);
|
||||
boolean isSessionAlreadyStored = clientSession != null;
|
||||
|
||||
@@ -784,13 +784,13 @@ public class DatabaseStore {
|
||||
}
|
||||
}
|
||||
|
||||
List<WFCMessage.Message> loadRemoteMessages(String user, WFCMessage.Conversation conversation, long beforeUid, int count) {
|
||||
List<WFCMessage.Message> loadRemoteMessages(String user, WFCMessage.Conversation conversation, long beforeUid, int count, Collection<Integer> contentTypes) {
|
||||
List<WFCMessage.Message> messages = new ArrayList<>();
|
||||
long[] before = new long[1];
|
||||
before[0] = beforeUid;
|
||||
boolean hasMore = loadRemoteMessagesFromTable(user, conversation, before, count, MessageShardingUtil.getMessageTable(beforeUid), messages);
|
||||
boolean hasMore = loadRemoteMessagesFromTable(user, conversation, before, count, MessageShardingUtil.getMessageTable(beforeUid), messages, contentTypes);
|
||||
while (messages.size() < count && hasMore) {
|
||||
hasMore = loadRemoteMessagesFromTable(user, conversation, before, count - messages.size(), MessageShardingUtil.getMessageTable(beforeUid), messages);
|
||||
hasMore = loadRemoteMessagesFromTable(user, conversation, before, count - messages.size(), MessageShardingUtil.getMessageTable(beforeUid), messages, contentTypes);
|
||||
}
|
||||
|
||||
int month = 0;
|
||||
@@ -800,7 +800,7 @@ public class DatabaseStore {
|
||||
int size = messages.size();
|
||||
hasMore = true;
|
||||
while (size == messages.size() && hasMore) {
|
||||
hasMore = loadRemoteMessagesFromTable(user, conversation, before, count - messages.size(), nexTable, messages);
|
||||
hasMore = loadRemoteMessagesFromTable(user, conversation, before, count - messages.size(), nexTable, messages, contentTypes);
|
||||
}
|
||||
|
||||
if (size < messages.size()) {
|
||||
@@ -811,7 +811,7 @@ public class DatabaseStore {
|
||||
return messages;
|
||||
}
|
||||
|
||||
boolean loadRemoteMessagesFromTable(String user, WFCMessage.Conversation conversation, long[] before, int count, String table, List<WFCMessage.Message> messages) {
|
||||
boolean loadRemoteMessagesFromTable(String user, WFCMessage.Conversation conversation, long[] before, int count, String table, List<WFCMessage.Message> messages, Collection<Integer> contentTypes) {
|
||||
long beforeUid = before[0];
|
||||
String sql = "select `_mid`, `_from`, `_type`, `_target`, `_line`, `_data`, `_dt`, `_to` from " + table +" where";
|
||||
if (conversation.getType() == ProtoConstants.ConversationType.ConversationType_Private) {
|
||||
@@ -820,7 +820,21 @@ public class DatabaseStore {
|
||||
sql += " _type = ? and _line = ? and _mid < ? and _target = ?";
|
||||
}
|
||||
|
||||
sql += "order by `_mid` DESC limit ?";
|
||||
if(contentTypes != null && !contentTypes.isEmpty()) {
|
||||
sql += " and _content_type in (";
|
||||
boolean first = true;
|
||||
for (int i:contentTypes) {
|
||||
if(first) {
|
||||
first = false;
|
||||
} else {
|
||||
sql += ",";
|
||||
}
|
||||
sql += i;
|
||||
}
|
||||
sql += ")";
|
||||
}
|
||||
|
||||
sql += " order by `_mid` DESC limit ?";
|
||||
|
||||
Connection connection = null;
|
||||
PreparedStatement statement = null;
|
||||
@@ -893,20 +907,21 @@ public class DatabaseStore {
|
||||
return false;
|
||||
}
|
||||
|
||||
void persistUserMessage(final String userId, final long messageId, final long messageSeq) {
|
||||
void persistUserMessage(final String userId, final long messageId, final long messageSeq, final int messageContentType) {
|
||||
mScheduler.execute(()->{
|
||||
Connection connection = null;
|
||||
PreparedStatement statement = null;
|
||||
try {
|
||||
connection = DBUtil.getConnection();
|
||||
|
||||
String sql = "insert into " + getUserMessageTable(userId) + " (`_mid`, `_uid`, `_seq`) values(?, ?, ?)";
|
||||
String sql = "insert into " + getUserMessageTable(userId) + " (`_mid`, `_uid`, `_seq`, `_cont_type`) values(?, ?, ?, ?)";
|
||||
|
||||
statement = connection.prepareStatement(sql);
|
||||
int index = 1;
|
||||
statement.setLong(index++, messageId);
|
||||
statement.setString(index++, userId);
|
||||
statement.setLong(index++, messageSeq);
|
||||
statement.setInt(index++, messageContentType);
|
||||
int count = statement.executeUpdate();
|
||||
LOG.info("Update rows {}", count);
|
||||
} catch (SQLException e) {
|
||||
|
||||
@@ -93,6 +93,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
private static boolean IS_MESSAGE_ROAMING = true;
|
||||
|
||||
private static boolean IS_MESSAGE_REMOTE_HISTORY_MESSAGE = true;
|
||||
private static boolean IS_CHATROOM_MESSAGE_REMOTE_HISTORY_MESSAGE = true;
|
||||
|
||||
static final String USER_ROBOTS = "user_robots";
|
||||
static final String USER_THINGS = "user_things";
|
||||
@@ -167,6 +168,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
|
||||
IS_MESSAGE_ROAMING = "1".equals(m_Server.getConfig().getProperty(MESSAGE_ROAMING));
|
||||
IS_MESSAGE_REMOTE_HISTORY_MESSAGE = "1".equals(m_Server.getConfig().getProperty(MESSAGE_Remote_History_Message));
|
||||
IS_CHATROOM_MESSAGE_REMOTE_HISTORY_MESSAGE = "1".equals(m_Server.getConfig().getProperty(MESSAGE_Remote_Chatroom_History_Message, "1"));
|
||||
Constants.MAX_MESSAGE_QUEUE = Integer.parseInt(m_Server.getConfig().getProperty(MESSAGE_Max_Queue));
|
||||
|
||||
try {
|
||||
@@ -730,18 +732,25 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
}
|
||||
|
||||
@Override
|
||||
public WFCMessage.PullMessageResult loadRemoteMessages(String user, WFCMessage.Conversation conversation, long beforeUid, int count) {
|
||||
public WFCMessage.PullMessageResult loadRemoteMessages(String user, WFCMessage.Conversation conversation, long beforeUid, int count, Collection<Integer> contentTypes) {
|
||||
WFCMessage.PullMessageResult.Builder builder = WFCMessage.PullMessageResult.newBuilder();
|
||||
List<WFCMessage.Message> messages;
|
||||
if (IS_MESSAGE_REMOTE_HISTORY_MESSAGE) {
|
||||
messages = databaseStore.loadRemoteMessages(user, conversation, beforeUid, count);
|
||||
} else {
|
||||
messages = new ArrayList<>();
|
||||
boolean loadMessage = IS_MESSAGE_REMOTE_HISTORY_MESSAGE;
|
||||
if(conversation.getType() == ProtoConstants.ConversationType.ConversationType_ChatRoom) {
|
||||
loadMessage = IS_CHATROOM_MESSAGE_REMOTE_HISTORY_MESSAGE;
|
||||
}
|
||||
|
||||
if (loadMessage) {
|
||||
messages = databaseStore.loadRemoteMessages(user, conversation, beforeUid, count, contentTypes);
|
||||
} else {
|
||||
messages = new ArrayList<>();
|
||||
}
|
||||
|
||||
builder.setCurrent(0).setHead(0);
|
||||
if(messages != null) {
|
||||
builder.addAllMessage(messages);
|
||||
}
|
||||
|
||||
return builder.build();
|
||||
}
|
||||
|
||||
@@ -862,7 +871,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
mWriteLock.unlock();
|
||||
}
|
||||
|
||||
databaseStore.persistUserMessage(user, messageId, messageSeq);
|
||||
databaseStore.persistUserMessage(user, messageId, messageSeq, messageContentType);
|
||||
return messageSeq;
|
||||
}
|
||||
|
||||
@@ -1062,7 +1071,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
event.type = type;
|
||||
m_Server.getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(mGroupInfoUpdateCallback, new Gson().toJson(event));
|
||||
HttpUtils.httpJsonPost(mGroupInfoUpdateCallback, new Gson().toJson(event), HttpUtils.HttpPostType.POST_TYPE_Grout_Event_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -1081,7 +1090,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
event.value = value;
|
||||
m_Server.getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(mGroupMemberUpdateCallback, new Gson().toJson(event));
|
||||
HttpUtils.httpJsonPost(mGroupMemberUpdateCallback, new Gson().toJson(event), HttpUtils.HttpPostType.POST_TYPE_Grout_Member_Event_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -1099,7 +1108,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
event.value = value;
|
||||
m_Server.getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(mRelationUpdateCallback, new Gson().toJson(event));
|
||||
HttpUtils.httpJsonPost(mRelationUpdateCallback, new Gson().toJson(event), HttpUtils.HttpPostType.POST_TYPE_User_Relation_Event_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -1112,7 +1121,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
if (!StringUtil.isNullOrEmpty(mUserInfoUpdateCallback)) {
|
||||
m_Server.getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(mUserInfoUpdateCallback, new Gson().toJson(InputOutputUserInfo.fromPbUser(user)));
|
||||
HttpUtils.httpJsonPost(mUserInfoUpdateCallback, new Gson().toJson(InputOutputUserInfo.fromPbUser(user)), HttpUtils.HttpPostType.POST_TYPE_User_Info_Event_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -1129,7 +1138,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
event.type = type;
|
||||
m_Server.getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(mChannelInfoUpdateCallback, new Gson().toJson(event));
|
||||
HttpUtils.httpJsonPost(mChannelInfoUpdateCallback, new Gson().toJson(event), HttpUtils.HttpPostType.POST_TYPE_Channel_Info_Event_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -1145,7 +1154,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
event.type = type;
|
||||
m_Server.getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(mChatroomInfoUpdateCallback, new Gson().toJson(event));
|
||||
HttpUtils.httpJsonPost(mChatroomInfoUpdateCallback, new Gson().toJson(event), HttpUtils.HttpPostType.POST_TYPE_Chatroom_Info_Event_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -1163,7 +1172,7 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
event.type = type;
|
||||
m_Server.getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(mChatroomMemberUpdateCallback, new Gson().toJson(event));
|
||||
HttpUtils.httpJsonPost(mChatroomMemberUpdateCallback, new Gson().toJson(event), HttpUtils.HttpPostType.POST_TYPE_Chatroom_Member_Event_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -2588,10 +2597,9 @@ public class MemoryMessagesStore implements IMessagesStore {
|
||||
|
||||
if (tokenUserId != null) {
|
||||
if (tokenUserId.equals(userId)) {
|
||||
Member member = m_Server.getHazelcastInstance().getCluster().getLocalMember();
|
||||
String serverIp = member.getStringAttribute(HZ_Cluster_Node_External_IP);
|
||||
String longPort = member.getStringAttribute(HZ_Cluster_Node_External_Long_Port);
|
||||
String shortPort = member.getStringAttribute(HZ_Cluster_Node_External_Short_Port);
|
||||
String serverIp = m_Server.getServerIp();
|
||||
String longPort = m_Server.getLongPort();
|
||||
String shortPort = m_Server.getShortPort();
|
||||
if (!StringUtil.isNullOrEmpty(serverIp)) {
|
||||
serverIPs.add(serverIp);
|
||||
}
|
||||
|
||||
@@ -356,23 +356,31 @@ public class Server {
|
||||
MediaServerConfig.FILE_STROAGE_REMOTE_SERVER_URL = config.getProperty(FILE_STORAGE_REMOTE_SERVER_URL);
|
||||
|
||||
MediaServerConfig.USER_QINIU = Integer.parseInt(config.getProperty(BrokerConstants.USER_QINIU)) > 0;
|
||||
if(MediaServerConfig.USER_QINIU) {
|
||||
if(MediaServerConfig.QINIU_SERVER_URL.split(":").length == 2) {
|
||||
String error = "媒体存储服务只能填上Host，不能带端口";
|
||||
System.out.println(error);
|
||||
LOG.error(error);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private String getServerIp(IConfig config) {
|
||||
String serverIp = config.getProperty(BrokerConstants.SERVER_IP_PROPERTY_NAME);
|
||||
|
||||
if (serverIp == null || serverIp.equals("0.0.0.0")) {
|
||||
String warning = "警告：无效配置，server.ip不能为空，需要配置服务的公网IP地址或者域名才能在公网使用！！！\nIM服务将使用本地地址，只能在局域网内使用！";
|
||||
System.out.println(warning);
|
||||
LOG.error(warning);
|
||||
serverIp = Utility.getLocalAddress().getHostAddress();
|
||||
}
|
||||
return serverIp;
|
||||
}
|
||||
|
||||
private boolean configureCluster(IConfig config) throws FileNotFoundException {
|
||||
LOG.info("Configuring embedded Hazelcast instance");
|
||||
String serverIp = getServerIp(config);
|
||||
|
||||
serverIp = getServerIp(config);
|
||||
String hzConfigPath = "config/hazelcast.xml";
|
||||
String hzClientIp = config.getProperty(BrokerConstants.HAZELCAST_CLIENT_IP, "localhost");
|
||||
String hzClientPort = config.getProperty(BrokerConstants.HAZELCAST_CLIENT_PORT, "5703");
|
||||
|
||||
if (hzConfigPath != null) {
|
||||
boolean isHzConfigOnClasspath = this.getClass().getClassLoader().getResource(hzConfigPath) != null;
|
||||
Config hzconfig = isHzConfigOnClasspath
|
||||
@@ -385,29 +393,10 @@ public class Server {
|
||||
hazelcastInstance = Hazelcast.newHazelcastInstance();
|
||||
}
|
||||
|
||||
longPort = config.getProperty(BrokerConstants.PORT_PROPERTY_NAME);
|
||||
shortPort = config.getProperty(BrokerConstants.HTTP_SERVER_PORT);
|
||||
|
||||
String longPort = config.getProperty(BrokerConstants.PORT_PROPERTY_NAME);
|
||||
String shortPort = config.getProperty(BrokerConstants.HTTP_SERVER_PORT);
|
||||
String nodeIdStr = config.getProperty(BrokerConstants.NODE_ID);
|
||||
ISet<Integer> nodeIdSet = hazelcastInstance.getSet(BrokerConstants.NODE_IDS);
|
||||
int nodeId;
|
||||
try {
|
||||
nodeId = Integer.parseInt(nodeIdStr);
|
||||
}catch (Exception e){
|
||||
throw new IllegalArgumentException("nodeId error: " + nodeIdStr);
|
||||
}
|
||||
if (nodeIdSet != null && nodeIdSet.contains(nodeId)){
|
||||
LOG.error("只允许一个实例运行，多个实例会引起冲突，进程终止");
|
||||
System.exit(-1);
|
||||
}
|
||||
|
||||
MessageShardingUtil.setNodeId(nodeId);
|
||||
nodeIdSet.add(nodeId);
|
||||
|
||||
hazelcastInstance.getCluster().getLocalMember().setStringAttribute(HZ_Cluster_Node_External_Long_Port, longPort);
|
||||
hazelcastInstance.getCluster().getLocalMember().setStringAttribute(HZ_Cluster_Node_External_Short_Port, shortPort);
|
||||
hazelcastInstance.getCluster().getLocalMember().setIntAttribute(HZ_Cluster_Node_ID, nodeId);
|
||||
hazelcastInstance.getCluster().getLocalMember().setStringAttribute(HZ_Cluster_Node_External_IP, serverIp);
|
||||
MessageShardingUtil.setNodeId(1);
|
||||
Tokenor.setKey(config.getProperty(BrokerConstants.TOKEN_SECRET_KEY));
|
||||
String expirTimeStr = config.getProperty(TOKEN_EXPIRE_TIME);
|
||||
if (!StringUtil.isNullOrEmpty(expirTimeStr)) {
|
||||
@@ -421,6 +410,22 @@ public class Server {
|
||||
return true;
|
||||
}
|
||||
|
||||
private String serverIp;
|
||||
private String longPort;
|
||||
private String shortPort;
|
||||
|
||||
public String getServerIp() {
|
||||
return serverIp;
|
||||
}
|
||||
|
||||
public String getLongPort() {
|
||||
return longPort;
|
||||
}
|
||||
|
||||
public String getShortPort() {
|
||||
return shortPort;
|
||||
}
|
||||
|
||||
public HazelcastInstance getHazelcastInstance() {
|
||||
return hazelcastInstance;
|
||||
}
|
||||
|
||||
@@ -104,7 +104,7 @@ public interface IMessagesStore {
|
||||
int getNotifyReceivers(String fromUser, WFCMessage.Message.Builder message, Set<String> notifyReceivers);
|
||||
Set<String> getAllEnds();
|
||||
WFCMessage.PullMessageResult fetchMessage(String user, String exceptClientId, long fromMessageId, int pullType);
|
||||
WFCMessage.PullMessageResult loadRemoteMessages(String user, WFCMessage.Conversation conversation, long beforeUid, int count);
|
||||
WFCMessage.PullMessageResult loadRemoteMessages(String user, WFCMessage.Conversation conversation, long beforeUid, int count, Collection<Integer> contentTypes);
|
||||
long insertUserMessages(String sender, int conversationType, String target, int line, int messageContentType, String userId, long messageId);
|
||||
WFCMessage.GroupInfo createGroup(String operator, WFCMessage.GroupInfo groupInfo, List<WFCMessage.GroupMember> memberList, String memberExtra, boolean isAdmin);
|
||||
ErrorCode addGroupMembers(String operator, boolean isAdmin, String groupId, List<WFCMessage.GroupMember> memberList, String extra);
|
||||
|
||||
@@ -179,7 +179,7 @@ public class MessagesPublisher {
|
||||
final WFCMessage.Message finalMsg = message;
|
||||
Server.getServer().getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(robot.getCallback(), new Gson().toJson(SendMessageData.fromProtoMessage(finalMsg), SendMessageData.class));
|
||||
HttpUtils.httpJsonPost(robot.getCallback(), new Gson().toJson(SendMessageData.fromProtoMessage(finalMsg), SendMessageData.class), HttpUtils.HttpPostType.POST_TYPE_Robot_Message_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -598,7 +598,7 @@ public class MessagesPublisher {
|
||||
if (channelInfo != null && !StringUtil.isNullOrEmpty(channelInfo.getCallback())) {
|
||||
Server.getServer().getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(channelInfo.getCallback() + "/message", new Gson().toJson(SendMessageData.fromProtoMessage(message), SendMessageData.class));
|
||||
HttpUtils.httpJsonPost(channelInfo.getCallback() + "/message", new Gson().toJson(SendMessageData.fromProtoMessage(message), SendMessageData.class), HttpUtils.HttpPostType.POST_TYPE_Channel_Message_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -645,7 +645,7 @@ public class MessagesPublisher {
|
||||
public void forwardMessage(final WFCMessage.Message message, String forwardUrl) {
|
||||
Server.getServer().getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(forwardUrl, new Gson().toJson(OutputMessageData.fromProtoMessage(message), OutputMessageData.class));
|
||||
HttpUtils.httpJsonPost(forwardUrl, new Gson().toJson(OutputMessageData.fromProtoMessage(message), OutputMessageData.class), HttpUtils.HttpPostType.POST_TYPE_Forward_Message_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -669,7 +669,7 @@ public class MessagesPublisher {
|
||||
callback.onFailure(statusCode, errorMessage);
|
||||
});
|
||||
}
|
||||
});
|
||||
}, HttpUtils.HttpPostType.POST_TYPE_Forward_Message_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
@@ -683,7 +683,7 @@ public class MessagesPublisher {
|
||||
|
||||
Server.getServer().getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(channelInfo.getCallback() + "/subscribe", new Gson().toJson(new OutputNotifyChannelSubscribeStatus(user, channelInfo.getTargetId(), listen), OutputNotifyChannelSubscribeStatus.class));
|
||||
HttpUtils.httpJsonPost(channelInfo.getCallback() + "/subscribe", new Gson().toJson(new OutputNotifyChannelSubscribeStatus(user, channelInfo.getTargetId(), listen), OutputNotifyChannelSubscribeStatus.class), HttpUtils.HttpPostType.POST_TYPE_Channel_Subscriber_Event_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
|
||||
@@ -264,7 +264,7 @@ public class ProtocolProcessor {
|
||||
if (!StringUtil.isNullOrEmpty(mUserOnlineStatusCallback)) {
|
||||
mServer.getCallbackScheduler().execute(() -> {
|
||||
try {
|
||||
HttpUtils.httpJsonPost(mUserOnlineStatusCallback, new Gson().toJson(new UserOnlineStatus(userId, clientId, platform, status, packageName)));
|
||||
HttpUtils.httpJsonPost(mUserOnlineStatusCallback, new Gson().toJson(new UserOnlineStatus(userId, clientId, platform, status, packageName)), HttpUtils.HttpPostType.POST_TYPE_User_Online_Event_Callback);
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
Utility.printExecption(LOG, e, EVENT_CALLBACK_Exception);
|
||||
|
||||
@@ -54,6 +54,9 @@ public class DBUtil {
|
||||
if (embedDB != null && embedDB.equals("1")) {
|
||||
IsEmbedDB = true;
|
||||
LOG.info("Use h2 database");
|
||||
String warning = "您正在使用内置h2数据库，建议仅在开发验证或者用户数小于100人时才使用此数据库，其它情况建议使用MySQL。";
|
||||
System.out.println(warning);
|
||||
LOG.warn(warning);
|
||||
} else {
|
||||
IsEmbedDB = false;
|
||||
LOG.info("Use mysql database");
|
||||
|
||||
@@ -8,6 +8,7 @@
|
||||
|
||||
package win.liyufan.im;
|
||||
|
||||
import cn.wildfirechat.common.ErrorCode;
|
||||
import io.netty.util.internal.StringUtil;
|
||||
import okhttp3.*;
|
||||
import org.apache.http.HttpResponse;
|
||||
@@ -35,11 +36,28 @@ public class HttpUtils {
|
||||
void onFailure(int statusCode, String errorMessage);
|
||||
}
|
||||
|
||||
public static void httpJsonPost(final String url, final String jsonStr) {
|
||||
httpJsonPost(url, jsonStr, null);
|
||||
public enum HttpPostType {
|
||||
POST_TYPE_Push,
|
||||
POST_TYPE_Grout_Event_Callback,
|
||||
POST_TYPE_Grout_Member_Event_Callback,
|
||||
POST_TYPE_User_Relation_Event_Callback,
|
||||
POST_TYPE_User_Info_Event_Callback,
|
||||
POST_TYPE_Channel_Info_Event_Callback,
|
||||
POST_TYPE_Channel_Subscriber_Event_Callback,
|
||||
POST_TYPE_Chatroom_Info_Event_Callback,
|
||||
POST_TYPE_Chatroom_Member_Event_Callback,
|
||||
POST_TYPE_Robot_Message_Callback,
|
||||
POST_TYPE_Channel_Message_Callback,
|
||||
POST_TYPE_Forward_Message_Callback,
|
||||
POST_TYPE_User_Online_Event_Callback,
|
||||
POST_TYPE_Server_Exception_Callback;
|
||||
}
|
||||
|
||||
public static void httpJsonPost(final String url, final String jsonStr, final HttpCallback httpCallback) {
|
||||
public static void httpJsonPost(String url, String jsonStr, HttpPostType postType) {
|
||||
httpJsonPost(url, jsonStr, null, postType);
|
||||
}
|
||||
|
||||
public static void httpJsonPost(String url, String jsonStr, HttpCallback httpCallback, HttpPostType postType) {
|
||||
//消息推送内容为 {"sender":"uCGUxUaa","senderName":"杨","convType":0,"target":"usq7v7UU","targetName":"鞋子","userId":"usq7v7UU","line":0,"cntType":400,"serverTime":1610590766485,"pushMessageType":1,"pushType":2,"pushContent":"","pushData":"","unReceivedMsg":1,"mentionedType":0,"packageName":"cn.wildfirechat.chat","deviceToken":"AFoieP9P6u6CccIkRK23gRwUJWKqSkdiqnb-6gC1kL7Wv-9XNoEYBPU7VsINU_q8_WTKfafe35qWu7ya7Z-NmgOTX9XVW3A3zd6ilh--quj6ccINXRvVnh8QmI9QQ","isHiddenDetail":false,"language":"zh"}
|
||||
//推送信息只打印前100个字符，防止敏感信息打印到日志中去。
|
||||
LOG.info("POST to {} with data {}...", url, jsonStr.substring(0, Math.min(jsonStr.length(), 100)));
|
||||
@@ -56,7 +74,20 @@ public class HttpUtils {
|
||||
client.newCall(request).enqueue(new Callback() {
|
||||
@Override
|
||||
public void onFailure(Call call, IOException e) {
|
||||
String logText;
|
||||
if(postType == HttpPostType.POST_TYPE_Push) {
|
||||
logText = "Http请求到推送服务失败，请检查推送服务是否正在运行或者配置文件中推送服务地址是否正确。";
|
||||
} else if(postType == HttpPostType.POST_TYPE_Robot_Message_Callback) {
|
||||
logText = "Http请求转发消息到机器人服务失败，请检查机器人服务是否部署且在机器人信息中的回调地址是否正确。\n如果不需要机器人及机器人服务，请关掉应用服务中自动添加机器人好友和发送机器人欢迎语的代码，用户不给机器人发送消息就不会有转发请求了。";
|
||||
} else if(postType == HttpPostType.POST_TYPE_Channel_Message_Callback ||
|
||||
postType == HttpPostType.POST_TYPE_Channel_Subscriber_Event_Callback) {
|
||||
logText = "Http请求到频道服务失败，请检查频道服务是否部署且在频道信息中的回调地址是否正确。";
|
||||
} else {
|
||||
logText = "Http请求回调地址失败，请检查IM服务配置文件中对应的回调地址是否正确";
|
||||
}
|
||||
System.out.println(logText);
|
||||
e.printStackTrace();
|
||||
LOG.info(logText);
|
||||
LOG.info("POST to {} with data {} failure", url, jsonStr);
|
||||
if(httpCallback != null) {
|
||||
httpCallback.onFailure(-1, e.getMessage());
|
||||
@@ -88,5 +119,4 @@ public class HttpUtils {
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -99,7 +99,7 @@ public class Utility {
|
||||
for (Map.Entry<String, IMExceptionEvent> entry : exceptionEventHashMap.entrySet()) {
|
||||
if(entry.getValue().count > 0) {
|
||||
String jsonStr = new Gson().toJson(entry.getValue());
|
||||
Server.getServer().getCallbackScheduler().execute(() -> HttpUtils.httpJsonPost(gMonitorEventAddress, jsonStr));
|
||||
Server.getServer().getCallbackScheduler().execute(() -> HttpUtils.httpJsonPost(gMonitorEventAddress, jsonStr, HttpUtils.HttpPostType.POST_TYPE_Server_Exception_Callback));
|
||||
entry.getValue().count = 0;
|
||||
lastSendTime = now;
|
||||
}
|
||||
@@ -112,7 +112,7 @@ public class Utility {
|
||||
event.call_stack = "别担心！这个是心跳消息，已经有24小时没有出现异常消息了！";
|
||||
event.count = IMExceptionEvent.EventType.HEART_BEAT;
|
||||
String jsonStr = new Gson().toJson(event);
|
||||
Server.getServer().getCallbackScheduler().execute(() -> HttpUtils.httpJsonPost(gMonitorEventAddress, jsonStr));
|
||||
Server.getServer().getCallbackScheduler().execute(() -> HttpUtils.httpJsonPost(gMonitorEventAddress, jsonStr, HttpUtils.HttpPostType.POST_TYPE_Server_Exception_Callback));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
+1
-1
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>wildfirechat-parent</artifactId>
|
||||
<groupId>cn.wildfirechat</groupId>
|
||||
<version>0.75</version>
|
||||
<version>0.76</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
||||
@@ -46,6 +46,7 @@ public enum ErrorCode {
|
||||
ERROR_CODE_LOCK_ALREADY_LOCKED(25, "already locked"),
|
||||
ERROR_CODE_NOT_YOUR_LOCKED(26, "unload failure, not your lock"),
|
||||
ERROR_CODE_ROBOT_NO_TOKEN(27, "robot no token"),
|
||||
ERROR_CODE_WS_NOT_CONFIGURED_CORRECTLY(28, "ws not configured correctly"),
|
||||
ERROR_CODE_CONFERENCE_ROOM_NOT_EXIST(60, "conference room not exist"),
|
||||
|
||||
ERROR_CODE_USER_NOT_PREPARED(238, "user not prepared"),
|
||||
|
||||
@@ -59417,6 +59417,20 @@ public final class WFCMessage {
|
||||
* <code>required int32 count = 3;</code>
|
||||
*/
|
||||
int getCount();
|
||||
|
||||
// repeated int32 content_type = 4;
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
java.util.List<java.lang.Integer> getContentTypeList();
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
int getContentTypeCount();
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
int getContentType(int index);
|
||||
}
|
||||
/**
|
||||
* Protobuf type {@code LoadRemoteMessages}
|
||||
@@ -59492,6 +59506,27 @@ public final class WFCMessage {
|
||||
count_ = input.readInt32();
|
||||
break;
|
||||
}
|
||||
case 32: {
|
||||
if (!((mutable_bitField0_ & 0x00000008) == 0x00000008)) {
|
||||
contentType_ = new java.util.ArrayList<java.lang.Integer>();
|
||||
mutable_bitField0_ |= 0x00000008;
|
||||
}
|
||||
contentType_.add(input.readInt32());
|
||||
break;
|
||||
}
|
||||
case 34: {
|
||||
int length = input.readRawVarint32();
|
||||
int limit = input.pushLimit(length);
|
||||
if (!((mutable_bitField0_ & 0x00000008) == 0x00000008) && input.getBytesUntilLimit() > 0) {
|
||||
contentType_ = new java.util.ArrayList<java.lang.Integer>();
|
||||
mutable_bitField0_ |= 0x00000008;
|
||||
}
|
||||
while (input.getBytesUntilLimit() > 0) {
|
||||
contentType_.add(input.readInt32());
|
||||
}
|
||||
input.popLimit(limit);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
|
||||
@@ -59500,6 +59535,9 @@ public final class WFCMessage {
|
||||
throw new com.google.protobuf.InvalidProtocolBufferException(
|
||||
e.getMessage()).setUnfinishedMessage(this);
|
||||
} finally {
|
||||
if (((mutable_bitField0_ & 0x00000008) == 0x00000008)) {
|
||||
contentType_ = java.util.Collections.unmodifiableList(contentType_);
|
||||
}
|
||||
this.unknownFields = unknownFields.build();
|
||||
makeExtensionsImmutable();
|
||||
}
|
||||
@@ -59586,10 +59624,34 @@ public final class WFCMessage {
|
||||
return count_;
|
||||
}
|
||||
|
||||
// repeated int32 content_type = 4;
|
||||
public static final int CONTENT_TYPE_FIELD_NUMBER = 4;
|
||||
private java.util.List<java.lang.Integer> contentType_;
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public java.util.List<java.lang.Integer>
|
||||
getContentTypeList() {
|
||||
return contentType_;
|
||||
}
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public int getContentTypeCount() {
|
||||
return contentType_.size();
|
||||
}
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public int getContentType(int index) {
|
||||
return contentType_.get(index);
|
||||
}
|
||||
|
||||
private void initFields() {
|
||||
conversation_ = cn.wildfirechat.proto.WFCMessage.Conversation.getDefaultInstance();
|
||||
beforeUid_ = 0L;
|
||||
count_ = 0;
|
||||
contentType_ = java.util.Collections.emptyList();
|
||||
}
|
||||
private byte memoizedIsInitialized = -1;
|
||||
public final boolean isInitialized() {
|
||||
@@ -59628,6 +59690,9 @@ public final class WFCMessage {
|
||||
if (((bitField0_ & 0x00000004) == 0x00000004)) {
|
||||
output.writeInt32(3, count_);
|
||||
}
|
||||
for (int i = 0; i < contentType_.size(); i++) {
|
||||
output.writeInt32(4, contentType_.get(i));
|
||||
}
|
||||
getUnknownFields().writeTo(output);
|
||||
}
|
||||
|
||||
@@ -59649,6 +59714,15 @@ public final class WFCMessage {
|
||||
size += com.google.protobuf.CodedOutputStream
|
||||
.computeInt32Size(3, count_);
|
||||
}
|
||||
{
|
||||
int dataSize = 0;
|
||||
for (int i = 0; i < contentType_.size(); i++) {
|
||||
dataSize += com.google.protobuf.CodedOutputStream
|
||||
.computeInt32SizeNoTag(contentType_.get(i));
|
||||
}
|
||||
size += dataSize;
|
||||
size += 1 * getContentTypeList().size();
|
||||
}
|
||||
size += getUnknownFields().getSerializedSize();
|
||||
memoizedSerializedSize = size;
|
||||
return size;
|
||||
@@ -59776,6 +59850,8 @@ public final class WFCMessage {
|
||||
bitField0_ = (bitField0_ & ~0x00000002);
|
||||
count_ = 0;
|
||||
bitField0_ = (bitField0_ & ~0x00000004);
|
||||
contentType_ = java.util.Collections.emptyList();
|
||||
bitField0_ = (bitField0_ & ~0x00000008);
|
||||
return this;
|
||||
}
|
||||
|
||||
@@ -59820,6 +59896,11 @@ public final class WFCMessage {
|
||||
to_bitField0_ |= 0x00000004;
|
||||
}
|
||||
result.count_ = count_;
|
||||
if (((bitField0_ & 0x00000008) == 0x00000008)) {
|
||||
contentType_ = java.util.Collections.unmodifiableList(contentType_);
|
||||
bitField0_ = (bitField0_ & ~0x00000008);
|
||||
}
|
||||
result.contentType_ = contentType_;
|
||||
result.bitField0_ = to_bitField0_;
|
||||
onBuilt();
|
||||
return result;
|
||||
@@ -59845,6 +59926,16 @@ public final class WFCMessage {
|
||||
if (other.hasCount()) {
|
||||
setCount(other.getCount());
|
||||
}
|
||||
if (!other.contentType_.isEmpty()) {
|
||||
if (contentType_.isEmpty()) {
|
||||
contentType_ = other.contentType_;
|
||||
bitField0_ = (bitField0_ & ~0x00000008);
|
||||
} else {
|
||||
ensureContentTypeIsMutable();
|
||||
contentType_.addAll(other.contentType_);
|
||||
}
|
||||
onChanged();
|
||||
}
|
||||
this.mergeUnknownFields(other.getUnknownFields());
|
||||
return this;
|
||||
}
|
||||
@@ -60071,6 +60162,72 @@ public final class WFCMessage {
|
||||
return this;
|
||||
}
|
||||
|
||||
// repeated int32 content_type = 4;
|
||||
private java.util.List<java.lang.Integer> contentType_ = java.util.Collections.emptyList();
|
||||
private void ensureContentTypeIsMutable() {
|
||||
if (!((bitField0_ & 0x00000008) == 0x00000008)) {
|
||||
contentType_ = new java.util.ArrayList<java.lang.Integer>(contentType_);
|
||||
bitField0_ |= 0x00000008;
|
||||
}
|
||||
}
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public java.util.List<java.lang.Integer>
|
||||
getContentTypeList() {
|
||||
return java.util.Collections.unmodifiableList(contentType_);
|
||||
}
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public int getContentTypeCount() {
|
||||
return contentType_.size();
|
||||
}
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public int getContentType(int index) {
|
||||
return contentType_.get(index);
|
||||
}
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public Builder setContentType(
|
||||
int index, int value) {
|
||||
ensureContentTypeIsMutable();
|
||||
contentType_.set(index, value);
|
||||
onChanged();
|
||||
return this;
|
||||
}
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public Builder addContentType(int value) {
|
||||
ensureContentTypeIsMutable();
|
||||
contentType_.add(value);
|
||||
onChanged();
|
||||
return this;
|
||||
}
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public Builder addAllContentType(
|
||||
java.lang.Iterable<? extends java.lang.Integer> values) {
|
||||
ensureContentTypeIsMutable();
|
||||
super.addAll(values, contentType_);
|
||||
onChanged();
|
||||
return this;
|
||||
}
|
||||
/**
|
||||
* <code>repeated int32 content_type = 4;</code>
|
||||
*/
|
||||
public Builder clearContentType() {
|
||||
contentType_ = java.util.Collections.emptyList();
|
||||
bitField0_ = (bitField0_ & ~0x00000008);
|
||||
onChanged();
|
||||
return this;
|
||||
}
|
||||
|
||||
// @@protoc_insertion_point(builder_scope:LoadRemoteMessages)
|
||||
}
|
||||
|
||||
@@ -62158,14 +62315,15 @@ public final class WFCMessage {
|
||||
"t\030\001 \002(\t\022\021\n\tlong_port\030\002 \002(\005\022\022\n\nshort_port" +
|
||||
"\030\003 \002(\005\"G\n\017GetTokenRequest\022\017\n\007user_id\030\001 \002" +
|
||||
"(\t\022\021\n\tclient_id\030\002 \002(\t\022\020\n\010platform\030\003 \001(\005\"" +
|
||||
"\\\n\022LoadRemoteMessages\022#\n\014conversation\030\001 " +
|
||||
"r\n\022LoadRemoteMessages\022#\n\014conversation\030\001 " +
|
||||
"\002(\0132\r.Conversation\022\022\n\nbefore_uid\030\002 \002(\003\022\r" +
|
||||
"\n\005count\030\003 \002(\005\"a\n\020MultiCastMessage\022\021\n\tfro",
|
||||
"m_user\030\001 \002(\t\022 \n\007content\030\002 \002(\0132\017.MessageC" +
|
||||
"ontent\022\n\n\002to\030\003 \003(\t\022\014\n\004line\030\004 \002(\005\"E\n\035Reca" +
|
||||
"llMultiCastMessageRequest\022\022\n\nmessage_id\030" +
|
||||
"\001 \002(\003\022\020\n\010receiver\030\002 \003(\tB#\n\025cn.wildfirech" +
|
||||
"at.protoB\nWFCMessage"
|
||||
"\n\005count\030\003 \002(\005\022\024\n\014content_type\030\004 \003(\005\"a\n\020M",
|
||||
"ultiCastMessage\022\021\n\tfrom_user\030\001 \002(\t\022 \n\007co" +
|
||||
"ntent\030\002 \002(\0132\017.MessageContent\022\n\n\002to\030\003 \003(\t" +
|
||||
"\022\014\n\004line\030\004 \002(\005\"E\n\035RecallMultiCastMessage" +
|
||||
"Request\022\022\n\nmessage_id\030\001 \002(\003\022\020\n\010receiver\030" +
|
||||
"\002 \003(\tB#\n\025cn.wildfirechat.protoB\nWFCMessa" +
|
||||
"ge"
|
||||
};
|
||||
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
||||
new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
|
||||
@@ -62591,7 +62749,7 @@ public final class WFCMessage {
|
||||
internal_static_LoadRemoteMessages_fieldAccessorTable = new
|
||||
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
|
||||
internal_static_LoadRemoteMessages_descriptor,
|
||||
new java.lang.String[] { "Conversation", "BeforeUid", "Count", });
|
||||
new java.lang.String[] { "Conversation", "BeforeUid", "Count", "ContentType", });
|
||||
internal_static_MultiCastMessage_descriptor =
|
||||
getDescriptor().getMessageTypes().get(70);
|
||||
internal_static_MultiCastMessage_fieldAccessorTable = new
|
||||
|
||||
@@ -6,7 +6,7 @@
|
||||
<!--<relativePath>../pom.xml</relativePath>-->
|
||||
<artifactId>wildfirechat-parent</artifactId>
|
||||
<groupId>cn.wildfirechat</groupId>
|
||||
<version>0.75</version>
|
||||
<version>0.76</version>
|
||||
</parent>
|
||||
|
||||
<artifactId>distribution</artifactId>
|
||||
|
||||
@@ -60,6 +60,9 @@ message.remote_history_message 0
|
||||
##服务器为每个用户缓存的消息数量。这个值改得太大，拉取消息时间变长，另外会占用大量内存。
|
||||
message.max_queue 1024
|
||||
|
||||
##是否开启拉取聊天室远程历史消息。如果为1，可以下拉继续加载在服务器上的该聊天室的消息；如果为0则不能。默认为1
|
||||
message.chatroom_remote_history_message 1
|
||||
|
||||
##是否禁止陌生人聊天
|
||||
message.disable_stranger_chat false
|
||||
|
||||
|
||||
@@ -12,7 +12,7 @@
|
||||
<artifactId>wildfirechat-parent</artifactId>
|
||||
|
||||
<packaging>pom</packaging>
|
||||
<version>0.75</version>
|
||||
<version>0.76</version>
|
||||
<name>Wildfire Chat</name>
|
||||
<description>Wildfire Chat Server</description>
|
||||
<inceptionYear>2019</inceptionYear>
|
||||
|
||||
+1
-1
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>wildfirechat-parent</artifactId>
|
||||
<groupId>cn.wildfirechat</groupId>
|
||||
<version>0.75</version>
|
||||
<version>0.76</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
||||
Reference in New Issue
Block a user