# HPSocket4Python

**Repository Path**: kk3950/HPSocket4Python

## Basic Information

- **Project Name**: HPSocket4Python
- **Description**: 这个是HPSocket的Python绑定
- **Primary Language**: Python
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 15
- **Created**: 2018-03-12
- **Last Updated**: 2020-12-20

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# HPSocket4Python
这个是 HPSocket 的 Python 绑定，力图在 Python 上更方便的使用 HPSocket 组件。目前已经可以通过继承类的方式来使用 Tcp_Pull_Server。
代码形如：
```
# coding: utf-8

import time,sys,os
sys.path.append(os.getcwd())
sys.path.append(os.getcwd()+'\\..\\')

from HPSocket import TcpPull
from HPSocket import helper
import HPSocket.pyhpsocket as HPSocket

class Server(TcpPull.HP_TcpPullServer):
    def Start(self, host, port):
        if super().Start(host,port):
            print('Start server success, listen on %s:%d'%(host,port))
            return True
        else:
            print('Start server fail.')
            return False

    @TcpPull.HP_TcpPullServer.EventDescription
    def OnPrepareListen(self, Sender, SocketHandler):
        return HPSocket.EnHandleResult.HR_OK

    @TcpPull.HP_TcpPullServer.EventDescription
    def OnSend(self, Sender, ConnID, Data):
        print('[TRACR] [Server] send to %d -> [length=%d]%s'%(ConnID, len(Data), repr(Data)))
        return HPSocket.EnHandleResult.HR_OK

    @TcpPull.HP_TcpPullServer.EventDescription
    def OnClose(self, Sender, ConnID, Operation, ErrorCode):
        print('The custom out: %d[Opt=%d, Err=%d]'%(ConnID, Operation, ErrorCode))
        return HPSocket.EnHandleResult.HR_OK

    @TcpPull.HP_TcpPullServer.EventDescription
    def OnAccept(self, Sender, ConnID, Client):
        self.pkg = helper.TPkgInfo(True, helper.TPkgHeaderSize)     # 这块内存需要保护起来
        HPSocket.HP_Server_SetConnectionExtra(Sender, ConnID, self.pkg)
        print('New custom in: %d'%ConnID)
        return HPSocket.EnHandleResult.HR_OK

    @TcpPull.HP_TcpPullServer.EventDescription
    def OnReceiveHead(self, Sender, ConnID, Seq:int, Length:int):
        print('[TRACR] [Server] head -> seq: %d, body_len: %d' % (Seq, Length))

    @TcpPull.HP_TcpPullServer.EventDescription
    def OnReceiveBody(self, Sender, ConnID, Body: bytes):
        (name, age, desc) = helper.GeneratePkg(Body)
        print('[TRACE] body -> name: %s, age: %d, desc: %s' % (name,age,desc))
        Buf = helper.GeneratePkgBuffer(seq=-1,name=name,age=age,desc=desc)
        self.Send(Sender, ConnID, Buf)


svr = Server()
if svr.Start('0.0.0.0',5555):
    while True:
        time.sleep(1)

```