hpsocket java代码_HPSocket介绍与使用
一、HPSocket介紹
HP-Socket是一套通用的高性能TCP/UDP/HTTP 通信框架，包含服務(wù)端組件、客戶端組件和Agent組件，廣泛適用于各種不同應(yīng)用場景的TCP/UDP/HTTP通信系統(tǒng)，提供C/C++、C#、Delphi、E(易語言)、Java、Python等編程語言接口。HP-Socket對通信層完全封裝，應(yīng)用程序不必關(guān)注通信層的任何細(xì)節(jié)；HP-Socket提供基于事件通知模型的API接口，能非常簡單高效地整合到新舊應(yīng)用程序中。
1.編譯
下載Hp-socket庫：
git clone https://github.com/ldcsaa/HP-Socket.git
這個(gè)庫有多個(gè)系統(tǒng)的版本，我們這里選用linux分析就好了。所以進(jìn)入到Linux下，看readme大概知道編譯流程。
./compile.sh
sudo ./install.sh
大概就是分兩個(gè)腳本，一個(gè)編譯腳本和一個(gè)安裝腳本。-h參數(shù)可以分別看到他們的使用說明。
compile.sh腳本
$ ./compile.sh -h
Usage: compile.sh [...O.P.T.I.O.N.S...]
----------------------+-------------------------------------------------
-d|--with-debug-lib : compile debug libs (default: true)
-j|--use-jemalloc : use jemalloc in release libs
: (x86/x64 default: true, ARM default: false)
-u|--udp-enabled : enable UDP components (default: true)
-t|--http-enabled : enable HTTP components (default: true)
-s|--ssl-enabled : enable SSL components (default: true)
-z|--zlib-enabled : enable ZLIB related functions (default: true)
-i|--iconv-enabled : enable ICONV related functions (default: true)
-c|--compiler : compiler (default: g++)
-p|--platform : platform: x86 / x64 / ARM
: (default: current machine arch platform)
-e|--clean : clean compilation intermediate temp files
-r|--remove : remove all compilation target files
-v|--version : print hp-socket version
-h|--help : print this usage message
----------------------+-------------------------------------------------
大概就是選擇某個(gè)模塊進(jìn)行編譯。
看看腳本邏輯
# 1.首先加載script/env.sh腳本里的變量和函數(shù)
source $PACKAGE_PATH/$SCRIPT_DIR/env.sh
# 2.解析參數(shù)：設(shè)置對應(yīng)的編譯模塊的變量值并得到一個(gè)控制狀態(tài)ACTION_NAME
parse_args "$@"
# 3.顯示上一步解析得到的配置結(jié)果
print_config
# 4.不同action的操作
if [ $EXEC_FLAG -eq 1 ]; then
do_clean
elif [ $EXEC_FLAG -eq 2 ]; then
do_remove
else
do_build
一般情況下我們用的是編譯，所以就是do_build函數(shù)
HPSOCKET_LIB_NAME=hpsocket
HPSOCKET4C_LIB_NAME=hpsocket4c
do_build()
{
# 設(shè)置一些編譯的變量
C_LAN_OPTS="-c -x c -I $DEPT_INC_DIR -Wall -Wswitch -Wno-deprecated-declarations -Wempty-body -Wconversion -Wreturn-type -Wparentheses -Wno-pointer-sign -Wno-format -Wuninitialized -Wunreachable-code -Wunused-function -Wunused-value -Wunused-variable -fno-strict-aliasing -fpic -fvisibility=hidden -fexceptions -std=c11"
CPP_LAN_OPTS="-c -x c++ -I $DEPT_INC_DIR -Wall -Wno-class-memaccess -Wno-reorder -Wswitch -Wno-deprecated-declarations -Wempty-body -Wconversion -Wreturn-type -Wparentheses -Wno-format -Wuninitialized -Wunreachable-code -Wunused-function -Wunused-value -Wunused-variable -fno-strict-aliasing -fpic -fthreadsafe-statics -fvisibility=hidden -fexceptions -frtti -std=c++14"
LINK_OPTS="-Wl,--no-undefined -Wl,-L$DEPT_LIB_DIR -L$DEPT_LIB_DIR -Wl,-z,relro -Wl,-z,now -Wl,-z,noexecstack -shared -Wl,-Bsymbolic"
RELEASE_CFG_OPTS="-g0 -O3 -fomit-frame-pointer -DNDEBUG"
DEBUG_CFG_OPTS="-g2 -gdwarf-2 -O0 -fno-omit-frame-pointer -DDEBUG -D_DEBUG"
if [ -d $HPSOCKET_LIB_TARGET_DIR ]; then
rm -rf $HPSOCKET_LIB_TARGET_DIR
fi
if [ -d $HPSOCKET4C_LIB_TARGET_DIR ]; then
rm -rf $HPSOCKET4C_LIB_TARGET_DIR
fi
# 編譯
do_compile $HPSOCKET_LIB_NAME $CFG_RELEASE
do_compile $HPSOCKET4C_LIB_NAME $CFG_RELEASE
if [ $WITH_DGBUG_LIB -eq 1 ]; then
do_compile $HPSOCKET_LIB_NAME $CFG_DEBUG
do_compile $HPSOCKET4C_LIB_NAME $CFG_DEBUG
fi
update_hp_def
}
do_compile()
{
_LIB_NAME=$1
_CFG_NAME=$2
parse_compile_args
do_compile_step_1
do_compile_step_2
do_compile_step_3
}
#這個(gè)函數(shù)大概就是遞歸編譯生成一堆*.o文件
do_comepile_file()
{
local _CMD="$CC $_LAN_OPTS $_FULL_FILE_NAME $_CFG_OPTS $_CL_OPTS -o $_OBJ_TARGET_DIR/$_OBJ_NAME"
$_CMD
}
#這個(gè)函數(shù)連接.o生成.so庫
do_compile_step_2()
{
local _LIB_FILE_NAME="lib$_LIB_NAME$_LIB_NAME_SUFFIX.so"
local _SONAME_OPT="-Wl,-soname,$_LIB_FILE_NAME.$VER_MAJOR"
local _OBJ_TARGET_DIR=$_LIB_TARGET_DIR/$OBJ_DIR/$_CFG_NAME
local _OBJ_FILES=($(find $_OBJ_TARGET_DIR -name *.o | xargs ls))
local _CMD="$CC -o $_LIB_TARGET_DIR/$_LIB_FILE_NAME $LINK_OPTS $_SONAME_OPT ${_OBJ_FILES[@]} $_LN_OPTS"
echo "> $_CMD"
}
#調(diào)用 post-link.sh腳本打包.a庫
do_compile_step_3()
{
local _LIB_FILE_NAME="lib$_LIB_NAME$_LIB_NAME_SUFFIX"
local _LIB_PATH=$PACKAGE_PATH/$_LIB_TARGET_DIR
local _CMD="$SCRIPT_DIR/post-link.sh $_AR_FLAG $_LIB_PATH $_LIB_FILE_NAME $PLATFORM $_CFG_NAME $VER_MAJOR $VER_MINOR $VER_REVISE"
echo "> $_CMD"
$_CMD
}
install.sh就不說了。無非就是將庫拉倒系統(tǒng)目錄或者指定目錄，把.h拉到系統(tǒng)目錄中去。
parse_args "$@"
print_config
if [ $IS_UNINSTALL -eq 0 ]; then
do_install
else
do_uninstall
fi
ldconfig > /dev/null 2>&1
do_install()
{
mkdir -p $PREFIX_PATH/$DEST_LIB_DIR
# copy *.a
cp_lib_a $HPSOCKET_LIB_TARGET_DIR
cp_lib_a $HPSOCKET4C_LIB_TARGET_DIR
# copy *.so
cp_lib_so $HPSOCKET_LIB_TARGET_DIR
cp_lib_so $HPSOCKET4C_LIB_TARGET_DIR
mkdir -p $PREFIX_PATH/$DEST_INC_DIR
# copy include dir
cp_inc $INC_DIR $PREFIX_PATH/$DEST_INC_DIR
if [[ $INSTALL_DEMO -eq 1 && -d $DEM_DIR/$PLATFORM && "$(ls -A $DEM_DIR/$PLATFORM)" != "" ]]; then
# copy demo .exe files
mkdir -p $PREFIX_PATH/$DEST_BIN_DIR
cp_bin_exe
# copy demo ssl cert files
mkdir -p $PREFIX_PATH/$DEST_BIN_DIR/$DEST_CER_DIR
cp_bin_cert
fi
}
至此，庫的編譯就完成了。
2.demo的編譯
庫的應(yīng)用代碼在demo目錄下，demo這里是用sln組織的。
我之前用testecho-http這個(gè)demo來學(xué)習(xí)這個(gè)庫的使用。
但這里有個(gè)大坑，我實(shí)際編譯的時(shí)候重寫成makefile，死活告訴我鏈接不到某幾個(gè)方法，但我已經(jīng)加入庫了。
后來知道是為什么了，用
nm libsocket.so | grep 鏈接不到的函數(shù)名
發(fā)現(xiàn)前面的是小寫？然后幫助文檔里有句話叫做
If the symbol is loacal(no-external), the symbol’s type is instead represented by the corresponding lowercase letter.
所以就是不能調(diào)用了哦。
然后這里有幾種解決方法：
鏈接到.a可以解決，因?yàn)?a是把.o打包
不要鏈接.so直接鏈接.o
修改代碼，換一種獲取類的方式
二、使用
環(huán)境：ubuntu
本文基于其readme中的C++程序來做分析
git中提供的《HP-Socket網(wǎng)絡(luò)通信框架開發(fā)指南》還是需要反復(fù)好好看的
1.工作流程
1)創(chuàng)建監(jiān)聽器
2)創(chuàng)建通信組件(同時(shí)綁定監(jiān)聽器)
3)啟動通信組件
4)連接到目標(biāo)主機(jī)(Agent組件)
5)處理通信事件(OnConnect/OnReceive/OnClose等)
6)停止通信組件(可選：在第7步銷毀通信組件時(shí)會自動停止組件)
7)銷毀通信組件
8)銷毀監(jiān)聽器
示例代碼
#include
/* Listener Class */
class CListenerImpl : public CTcpPullServerListener
{
public:
// 5. process network events
virtual EnHandleResult OnPrepareListen(ITcpServer* pSender, SOCKET soListen);
virtual EnHandleResult OnAccept(ITcpServer* pSender, CONNID dwConnID, UINT_PTR soClient);
virtual EnHandleResult OnHandShake(ITcpServer* pSender, CONNID dwConnID);
virtual EnHandleResult OnReceive(ITcpServer* pSender, CONNID dwConnID, int iLength);
virtual EnHandleResult OnSend(ITcpServer* pSender, CONNID dwConnID, const BYTE* pData, int iLength);
virtual EnHandleResult OnClose(ITcpServer* pSender, CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode);
virtual EnHandleResult OnShutdown(ITcpServer* pSender);
};
int main(int argc, char* const argv[])
{
// 1. Create listener object
CListenerImpl s_listener;
// 2. Create component object (and binding with listener object)
CTcpPullServerPtr s_pserver(&s_listener);
// 3. Start component object
if(!s_pserver->Start("0.0.0.0", 5555))
exit(1);
/* wait for exit */
// ... ...
// 6. (optional) Stop component object
s_pserver->Stop();
return 0;
// 7. Destroy component object automatically
// 8. Destroy listener object automatically
}
這里首先是兩點(diǎn)
a.創(chuàng)建監(jiān)聽器 CListenerImpl s_listener;
b.創(chuàng)建通信組件(同時(shí)綁定監(jiān)聽器) CTcpPullServerPtr s_pserver(&s_listener);
后續(xù)的通信的啟動、配置等功能，均是通過 s_pserver 來進(jìn)行的
2.關(guān)于 CListenerImpl
class CListenerImpl : public CTcpPullServerListener
{
public:
// 5. process network events
virtual EnHandleResult OnPrepareListen(ITcpServer* pSender, SOCKET soListen);
virtual EnHandleResult OnAccept(ITcpServer* pSender, CONNID dwConnID, UINT_PTR soClient);
virtual EnHandleResult OnHandShake(ITcpServer* pSender, CONNID dwConnID);
virtual EnHandleResult OnReceive(ITcpServer* pSender, CONNID dwConnID, int iLength);
virtual EnHandleResult OnSend(ITcpServer* pSender, CONNID dwConnID, const BYTE* pData, int iLength);
virtual EnHandleResult OnClose(ITcpServer* pSender, CONNID dwConnID, EnSocketOperation enOperation, int iErrorCode);
virtual EnHandleResult OnShutdown(ITcpServer* pSender);
};
1)其中OnPrepareListen等方法，需要自己去具體實(shí)現(xiàn)，他們分別會在各自O(shè)nXXXX的情況下觸發(fā)
2)關(guān)于基類 CTcpPullServerListener
在 Socketinterface.h 中
/************************************************************************
名稱：PUSH 模型服務(wù)端 Socket 監(jiān)聽器抽象基類
描述：定義某些事件的默認(rèn)處理方法(忽略事件)
************************************************************************/
class CTcpServerListener : public ITcpServerListener
/************************************************************************
名稱：PULL 模型服務(wù)端 Socket 監(jiān)聽器抽象基類
描述：定義某些事件的默認(rèn)處理方法(忽略事件)
************************************************************************/
class CTcpPullServerListener : public CTcpServerListener
逐級向上，此處可以結(jié)合pdf中 Server組件接口去看
3.關(guān)于 CTcpPullServerPtr
同樣我們可以跟蹤到
在HPSocket.h中
typedef CHPSocketPtrCTcpPullServerPtr;
其實(shí)此處有很多類似的
這里我們就會了解到，其實(shí)(在HPSocket。h開頭)具體的使用方法在開頭做了說明
Usage:
方法一：
--------------------------------------------------------------------------------------
0. 應(yīng)用程序包含 HPTypeDef.h / SocketInterface.h / HPSocket.h 頭文件
1. 調(diào)用 HP_Create_Xxx() 函數(shù)創(chuàng)建 HPSocket 對象
2. 使用完畢后調(diào)用 HP_Destroy_Xxx() 函數(shù)銷毀 HPSocket 對象
方法二：
--------------------------------------------------------------------------------------
0. 應(yīng)用程序包含 SocketInterface.h 和 HPSocket.h 頭文件
1. 創(chuàng)建 CXxxPtr 智能指針，通過智能指針使用 HPSocket 對象
Release:
1. x86/libhpsocket.so- (32位/MBCS/Release)
2. x86/libhpsocket_d.so- (32位/MBCS/DeBug)
3. x64/libhpsocket.so- (64位/MBCS/Release)
4. x64/libhpsocket_d.so- (64位/MBCS/DeBug)
1. x86/static/libhpsocket.a- (32位/MBCS/Release)
2. x86/static/libhpsocket_d.a- (32位/MBCS/DeBug)
3. x64/static/libhpsocket.a- (64位/MBCS/Release)
4. x64/static/libhpsocket_d.a- (64位/MBCS/DeBug)
這里使用的是方法二，也就是CXxxPtr 智能指針。
HP-Socket 的 TCP 組件支持 PUSH、 PULL 和 PACK 三種接收模型
1、PUSH 模型：組件接收到數(shù)據(jù)時(shí)會觸發(fā)監(jiān)聽器對象的 OnReceive(pSender, dwConnID,pData, iLength) 事件，把數(shù)據(jù)“推”給應(yīng)用程序。
2、 PULL 模型： 組件接收到數(shù)據(jù)時(shí)會觸發(fā)監(jiān)聽器對象的 OnReceive(pSender, dwConnID,iTotalLength) 事件，告訴應(yīng)用程序當(dāng)前已經(jīng)接收到多少數(shù)據(jù)，應(yīng)用程序檢查數(shù)據(jù)的長度，如果滿足需要則調(diào)用組件的 Fetch(dwConnID, pData, iDataLength) 方法把需要的數(shù)據(jù)“拉”出來。
3、 PACK 模型： PACK 模型系列組件是 PUSH 和 PULL 模型的結(jié)合體，應(yīng)用程序不必處理分包(如： PUSH)與數(shù)據(jù)抓取(如： PULL)， 組件保證每個(gè) OnReceive 事件都向應(yīng)用程序提供一個(gè)完整數(shù)據(jù)包。
對于CXxxPtr 智能指針的使用，以CTcpServerPtr為例，我們可以看到有如下方法
typedef CHPSocketPtr CTcpServerPtr;
下面考察主要的 ITcpServer
以其實(shí)對于通信socket的啟動關(guān)閉設(shè)置等功能均可以在此處進(jìn)行
回顧下上面的示例代碼
s_pserver->Start("0.0.0.0", 5555)
s_pserver->Stop();
三、總結(jié)
從簡單的使用來說，3個(gè)環(huán)節(jié)
1、創(chuàng)建監(jiān)聽器， 創(chuàng)建通信組件(同時(shí)綁定監(jiān)聽器)
2、填充OnXXXX等函數(shù)，比如OnReceive就打印出來，或者調(diào)用
virtual EnHandleResult OnReceive
(ITcpServer* pSender, CONNID dwConnID, const BYTE* pData, int iLength) override
{
printf("OnReceive\n");
if(pSender->Send(dwConnID, pData, iLength))
return HR_OK;
return HR_ERROR;
}
/***********************************/
EnHandleResult OnReceive
(ITcpServer* pSender, CONNID dwConnID, const BYTE* pData, int iLength)
中的 ITcpServer* pSender 進(jìn)行
pSender->Send(dwConnID, pData, iLength) 將數(shù)據(jù)發(fā)送出去
3、主程序中，使用 CXxxPtr 智能指針進(jìn)行基本的設(shè)置、啟動、關(guān)閉等動作
ps
可以在主程序return前，執(zhí)行while1，這樣程序會一直停留準(zhǔn)備進(jìn)行響應(yīng)
pps
1)使用g++編譯時(shí)，需要添加選項(xiàng) -std=c++11
2)如果出現(xiàn)編譯時(shí)候一些基本類型有問題， 建議添加 #include
使用HPSocket通訊不需要考慮邏輯結(jié)構(gòu)，直接按照方法調(diào)用就可以使用了，簡單明了。
改變自己，從現(xiàn)在做起-----------久館
創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎總結(jié)
以上是生活随笔為你收集整理的hpsocket java代码_HPSocket介绍与使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 文件保存了找不到了怎么办 文件保存丢失怎
- 下一篇： brainfuck 在线_酒店在线声誉持