Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-03 22:45:13 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

添加底层函数

Browse Source
This commit is contained in:
lifeiyi
2020-04-08 11:59:53 +08:00
parent f2eda1c635
commit 89fd5b8525
2 changed files with 45 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
example/GateService/GateService.go
View File

@@ -1,6 +1,7 @@
package GateService
import (
"encoding/json"
"fmt"
"github.com/duanhf2012/origin/event"
"github.com/duanhf2012/origin/network"
@@ -25,7 +26,8 @@ func (slf *GateService) OnInit() error{
slf.httpRouter = sysservice.NewHttpHttpRouter(slf)
httpervice.SetHttpRouter(slf.httpRouter)
slf.httpRouter.RegRouter(sysservice.METHOD_GET,"/get/query",slf.HttpTest)
slf.httpRouter.GET("/get/query", slf.HttpTest)
slf.httpRouter.POST("/post/query", slf.HttpTestPost)
slf.httpRouter.SetServeFile(sysservice.METHOD_GET,"/img/head/","d:/img")
return nil
}
@@ -38,6 +40,26 @@ func (slf *GateService) HttpTest(session *sysservice.HttpSession) {
fmt.Print(string(session.GetBody()),"\n",v,"\n",v2)
}
func (slf *GateService) HttpTestPost(session *sysservice.HttpSession) {
session.SetHeader("a","b")
v,_:=session.Query("a")
v2,_:=session.Query("b")
byteBody := session.GetBody()
fmt.Print(string(session.GetBody()),"\n",v,"\n",v2)
testa := struct {
AA int `json:"aa"`
BB string `json:"bb"`
}{}
json.Unmarshal(byteBody, &testa)
fmt.Println(testa)
testa.AA = 100
testa.BB = "this is a test"
session.WriteJson("asdasda")
}
func (slf *GateService) OnEventHandler(ev *event.Event) error{
if ev.Type == event.Sys_Event_Tcp_RecvPack {
pPack := ev.Data.(*sysservice.TcpPack)

24
sysservice/httpservice.go
View File

@@ -1,6 +1,7 @@
package sysservice
import (
"encoding/json"
"fmt"
"github.com/duanhf2012/origin/event"
"github.com/duanhf2012/origin/network"
@@ -51,7 +52,9 @@ type routerServeFileData struct {
}
type IHttpRouter interface {
RegRouter(method HTTP_METHOD, url string, handle HttpHandle) bool
//RegRouter(method HTTP_METHOD, url string, handle HttpHandle) bool
GET(url string, handle HttpHandle) bool
POST(url string, handle HttpHandle) bool
Router(session *HttpSession)
PutHttpSession(httpSession *HttpSession)
@@ -163,6 +166,15 @@ func (slf *HttpSession) Write(msg []byte) {
slf.msg = msg
}
func (slf *HttpSession) WriteJson(msgJson interface{}) error {
msg, err := json.Marshal(msgJson)
if err == nil {
slf.Write(msg)
}
return err
}
func (slf *HttpSession) flush() {
slf.w.WriteHeader(slf.statusCode)
if slf.msg!=nil {
@@ -215,7 +227,15 @@ func (slf *HttpRouter) PutHttpSession(httpSession *HttpSession){
slf.eventReciver.NotifyEvent(&event.Event{Type:event.Sys_Event_Http_Event,Data:httpSession})
}
func (slf *HttpRouter) RegRouter(method HTTP_METHOD, url string, handle HttpHandle) bool{
func (slf *HttpRouter) GET(url string, handle HttpHandle) bool {
return slf.regRouter(METHOD_GET, url, handle)
}
func (slf *HttpRouter) POST(url string, handle HttpHandle) bool {
return slf.regRouter(METHOD_POST, url, handle)
}
func (slf *HttpRouter) regRouter(method HTTP_METHOD, url string, handle HttpHandle) bool{
mapRouter,ok := slf.pathRouter[method]
if ok == false{
return false