tolag3/client_agent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

카카오 json파일 전송 로직 수정

Browse Source
This commit is contained in:
jangdongsin 2024-11-13 23:17:18 +09:00
parent b200b75213
commit 6d2985df6f
2 changed files with 31 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/main/java/com/munjaon/client/server/packet/KakaoMessage.java
View File

@ -170,4 +170,23 @@ public final class KakaoMessage {
return fileHeadBuffer; return fileHeadBuffer;
} }
public static ByteBuffer makeJsonBodyForDeliver(String path, String fileName) {
if (path == null || fileName == null) {
return null;
}
File file = new File(path + fileName);
if (file.exists() == false) {
return null;
}
ByteBuffer fileBodyBuffer = null;
try {
fileBodyBuffer = ByteBuffer.allocate((int) file.length());
fileBodyBuffer.put(Files.readAllBytes(file.toPath()));
} catch (IOException e) {
}
return fileBodyBuffer;
}
} }

14
src/main/java/com/munjaon/client/server/service/CollectClientService.java
View File

@ -671,7 +671,12 @@ public class CollectClientService extends Service {
/* 파일 전송 */ /* 파일 전송 */
ByteBuffer fileHeadBuffer = KakaoMessage.makeJsonHeaderForDeliver(path, data.getKakaoJsonFile()); ByteBuffer fileHeadBuffer = KakaoMessage.makeJsonHeaderForDeliver(path, data.getKakaoJsonFile());
socketChannel.write(fileHeadBuffer); socketChannel.write(fileHeadBuffer);
uploadFileSend(path + data.getKakaoJsonFile()); ByteBuffer fileBodyBuffer = KakaoMessage.makeJsonBodyForDeliver(path, data.getKakaoJsonFile());
fileBodyBuffer.flip();
while(fileBodyBuffer.hasRemaining()){
int bytesWritten = socketChannel.write(fileBodyBuffer);
saveLog("bytesWritten : " + bytesWritten);
}
long MSG_SEND_TIME = System.currentTimeMillis(); long MSG_SEND_TIME = System.currentTimeMillis();
while (true) { while (true) {
@ -824,7 +829,12 @@ public class CollectClientService extends Service {
/* 파일 전송 */ /* 파일 전송 */
ByteBuffer fileHeadBuffer = KakaoMessage.makeJsonHeaderForDeliver(path, data.getKakaoJsonFile()); ByteBuffer fileHeadBuffer = KakaoMessage.makeJsonHeaderForDeliver(path, data.getKakaoJsonFile());
socketChannel.write(fileHeadBuffer); socketChannel.write(fileHeadBuffer);
uploadFileSend(path + data.getKakaoJsonFile()); ByteBuffer fileBodyBuffer = KakaoMessage.makeJsonBodyForDeliver(path, data.getKakaoJsonFile());
fileBodyBuffer.flip();
while(fileBodyBuffer.hasRemaining()){
int bytesWritten = socketChannel.write(fileBodyBuffer);
saveLog("bytesWritten : " + bytesWritten);
}
long MSG_SEND_TIME = System.currentTimeMillis(); long MSG_SEND_TIME = System.currentTimeMillis();
while (true) { while (true) {