anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

解决配置文件中特殊字符问题

Browse Source
This commit is contained in:
heavyrain2012
2021-08-05 15:44:20 +08:00
parent 5a2ded4b6e
commit debd4f1aea
1 changed files with 18 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/server/config/ConfigurationParser.java
+18 -15
View File
@@ -84,34 +84,37 @@ class ConfigurationParser {
String line;
try {
while ((line = br.readLine()) != null) {
line = line.trim();
int commentMarker = line.indexOf('#');
if (commentMarker != -1) {
if (commentMarker == 0) {
// skip its a comment
continue;
} else {
// it's a malformed comment
throw new ParseException(line, commentMarker);
String[] ss = line.split(" ");
if(ss.length != 2) {
throw new ParseException(line, commentMarker);
}
}
} else {
if (line.isEmpty() || line.matches("^\\s*$")) {
// skip it's a black line
continue;
}
// split till the first space
int delimiterIdx = line.indexOf(' ');
String key;
String value = "";
if (delimiterIdx > 0) {
key = line.substring(0, delimiterIdx).trim();
value = line.substring(delimiterIdx).trim();
} else {
key = line.trim();
}
m_properties.put(key, value);
}
// split till the first space
int delimiterIdx = line.indexOf(' ');
String key;
String value = "";
if (delimiterIdx > 0) {
key = line.substring(0, delimiterIdx).trim();
value = line.substring(delimiterIdx).trim();
} else {
key = line.trim();
}
m_properties.put(key, value);
}
} catch (IOException ex) {
throw new ParseException("Failed to read", 1);