dianping/camel
1
1
Fork 0
mirror of https://github.com/dianping/camel.git synced 2024-11-10 17:35:03 +08:00
Code Issues Projects Releases Packages Wiki Activity

add log formatter

Browse source
This commit is contained in:
leon.li 2015-12-04 09:28:06 +08:00
parent b7c53f984e
commit 20c1d46559
1 changed files with 56 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

56
slb-agent/src/main/java/com/dianping/platform/slb/agent/core/task/LogFormatter.java Normal file
View file

@ -0,0 +1,56 @@
package com.dianping.platform.slb.agent.core.task;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.io.OutputStream;
import java.util.Map;
/**
* dianping.com @2015
* slb - soft load balance
* <p/>
* Created by leon.li(Li Yang)
*/
@Service
public class LogFormatter {
public static final String NEW_LINE = "\r\n";
public static final String CHUNK_TERMINATOR = "\r\n--9ed2b78c112fbd17a8511812c554da62941629a8--\r\n";
public static final String LOG_TERMINATOR = "\r\n--255220d51dc7fb4aacddadedfe252a346da267d4--\r\n";
public void writeHeader(OutputStream logOut, Map<String, String> headers) throws IOException {
StringBuilder sb = new StringBuilder();
if (headers != null) {
for (Map.Entry<String, String> headEntry : headers.entrySet()) {
sb.append(headEntry.getKey());
sb.append(": ");
sb.append(headEntry.getValue());
sb.append(NEW_LINE);
}
}
if (sb.length() > 0) {
sb.append(NEW_LINE);
} else {
sb.append(NEW_LINE);
sb.append(NEW_LINE);
}
logOut.write(sb.toString().getBytes());
}
public void writeChunkTerminator(OutputStream logOut) throws IOException {
logOut.write(CHUNK_TERMINATOR.getBytes("ascii"));
logOut.flush();
}
public void writeTerminator(OutputStream logOut) throws IOException {
logOut.write(LOG_TERMINATOR.getBytes("ascii"));
logOut.flush();
}
}