diff --git a/broker/src/main/java/io/moquette/server/Server.java b/broker/src/main/java/io/moquette/server/Server.java index 4231a913..a42d37bb 100755 --- a/broker/src/main/java/io/moquette/server/Server.java +++ b/broker/src/main/java/io/moquette/server/Server.java @@ -356,6 +356,13 @@ 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) { diff --git a/broker/src/main/java/win/liyufan/im/DBUtil.java b/broker/src/main/java/win/liyufan/im/DBUtil.java index 488943df..323b1a0c 100755 --- a/broker/src/main/java/win/liyufan/im/DBUtil.java +++ b/broker/src/main/java/win/liyufan/im/DBUtil.java @@ -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");