一種輕量化計(jì)算任務(wù)的基于TCP的雙向通信協(xié)議
基本信息
| 申請(qǐng)?zhí)?/td> | CN202011634575.0 | 申請(qǐng)日 | - |
| 公開（公告）號(hào) | CN112822072A | 公開（公告）日 | 2021-05-18 |
| 申請(qǐng)公布號(hào) | CN112822072A | 申請(qǐng)公布日 | 2021-05-18 |
| 分類號(hào) | H04L12/26;H04L29/06 | 分類 | 電通信技術(shù); |
| 發(fā)明人 | 王晟 | 申請(qǐng)（專利權(quán)）人 | 鯨靈科技有限責(zé)任公司 |
| 代理機(jī)構(gòu) | 南京蘇高專利商標(biāo)事務(wù)所（普通合伙） | 代理人 | 吳靜波 |
| 地址 | 225000 江蘇省揚(yáng)州市邗江區(qū)瘦西湖路195號(hào)花都匯商務(wù)中心2號(hào)樓 | ||
| 法律狀態(tài) | - | ||
摘要
| 摘要 | 本發(fā)明公開了一種計(jì)算任務(wù)輕量化的基于TCP的雙向通信協(xié)議，包括啟動(dòng)一Spark任務(wù)進(jìn)行上下文環(huán)境初始化和Driver進(jìn)程日志的Tailer監(jiān)聽操作；創(chuàng)建NettyServer實(shí)例與周邊應(yīng)用對(duì)接；當(dāng)Driver進(jìn)程日志有變更部分被Tailer監(jiān)聽到后，將其內(nèi)容發(fā)送至已連接應(yīng)用，內(nèi)容字符串最前方加入標(biāo)識(shí)“！log”，NettyServer接收客戶端應(yīng)用發(fā)來的請(qǐng)求命令，并原路返回處理結(jié)果內(nèi)容；請(qǐng)求命令以字符“！”開頭的，標(biāo)識(shí)為雙方已經(jīng)協(xié)商好的指令；在Netty連接通道中傳輸?shù)淖址畠?nèi)容全部經(jīng)過ZIP編碼和UNZIP解碼。本申請(qǐng)以對(duì)變更進(jìn)行標(biāo)識(shí)，獲取對(duì)應(yīng)的處理方式，有效簡(jiǎn)化計(jì)算任務(wù)量，減輕計(jì)算負(fù)擔(dān)。 |
