package dde /* #include #include */ import "C" import ( "fmt" ddeml "go-dde/ddeml" . "go-dde/types" "time" "unsafe" ) const ( MAX_BUFFER_SIZE = 2147483647 ) type DdeMeta struct { IdInst DWORD //全局句柄 HConv HCONV //会话句柄 Callback FNCALLBACK //回调函数 AppName VString //服务名称 TopicName VString //主题名称 Items []VString //单元项目字符串数组 HszApp HSZ //服务字符串句柄 HszTopic HSZ //主题字符串句柄 HszItem []HSZ //单元项目字符串句柄数组 } type DdeClient struct { DdeMeta } func (c *DdeClient) Run() bool { var cmd DWORD = DWORD(APPCLASS_STANDARD | APPCMD_CLIENTONLY) var res DWORD = 0 if c.Callback == nil { c.Callback = c.MetaCallBackfunc } iReturn := ddeml.DdeInitialize(&c.IdInst, c.Callback, cmd, res) if int(iReturn) != DMLERR_NO_ERROR { fmt.Printf("DDE Initialization Failed") } c.HszApp = ddeml.DdeCreateStringHandle(c.IdInst, c.AppName, 0) c.HszTopic = ddeml.DdeCreateStringHandle(c.IdInst, c.TopicName, 0) c.HszItem = make([]HSZ, len(c.Items)) for i := 0; i < len(c.Items); i++ { c.HszItem[i] = ddeml.DdeCreateStringHandle(c.IdInst, c.Items[i], 0) } c.HConv = ddeml.DdeConnect(c.IdInst, c.HszApp, c.HszTopic, nil) if c.HConv == HCONV(NULL) { fmt.Printf("DDE Connection Failed.\n") time.Sleep(2e9) //2e9 相当于2秒 c.DestoryClient() return false } return true } func (c *DdeClient) DestoryClient() { ddeml.DdeFreeStringHandle(c.IdInst, c.HszApp) ddeml.DdeFreeStringHandle(c.IdInst, c.HszTopic) for i := 0; i < len(c.Items); i++ { ddeml.DdeFreeStringHandle(c.IdInst, c.HszItem[i]) } fmt.Printf("客户端关闭") ddeml.DdeDisconnect(c.HConv) ddeml.DdeUninitialize(c.IdInst) } type DdeServer struct { DdeMeta close bool //服务状态 } func (c *DdeServer) RunServer() bool { if c.Callback == nil { c.Callback = c.MetaCallBackfunc } iReturn := ddeml.DdeInitialize(&c.IdInst, c.Callback, DWORD(APPCLASS_STANDARD), 0) if int(iReturn) != DMLERR_NO_ERROR { fmt.Printf("DDE Initialization Failed") } c.HszApp = ddeml.DdeCreateStringHandle(c.IdInst, c.AppName, 0) c.HszTopic = ddeml.DdeCreateStringHandle(c.IdInst, c.TopicName, 0) c.HszItem = make([]HSZ, len(c.Items)) for i := 0; i < len(c.Items); i++ { c.HszItem[i] = ddeml.DdeCreateStringHandle(c.IdInst, c.Items[i], 0) } sever := ddeml.DdeNameService(c.IdInst, c.HszApp, 0, UINT(DNS_REGISTER)) defer c.DestoryServer() if int(sever) != TRUE { fmt.Printf("DdeNameService() failed!") return false } c.close = false fmt.Printf("服务端开启") for { //do something var msg TagMSG if int(ddeml.GetMessage(&msg, 0, 0, 0)) <= 0 { if c.close { break } } ddeml.TranslateMessage(&msg) ddeml.DispatchMessage(&msg) } return true } func (c *DdeServer) DestoryServer() { c.close = true ddeml.DdeFreeStringHandle(c.IdInst, c.HszApp) ddeml.DdeFreeStringHandle(c.IdInst, c.HszTopic) for i := 0; i < len(c.Items); i++ { ddeml.DdeFreeStringHandle(c.IdInst, c.HszItem[i]) } fmt.Printf("服务端关闭") ddeml.DdeNameService(c.IdInst, c.HszApp, 0, UINT(DNS_UNREGISTER)) ddeml.DdeUninitialize(c.IdInst) } func (c *DdeServer) IsHSZItem(hsz2 HSZ) HSZ { for i := 0; i < len(c.Items); i++ { if ddeml.DdeCmpStringHandles(HSZ(hsz2), c.HszItem[i]) <= 0 { return c.HszItem[i] } } return 0 } func (c *DdeMeta) MetaCallBackfunc(wType UINT, wFmt UINT, hConv HCONV, hsz1 HSZ, hsz2 HSZ, hData HDDEDATA, dwData1 ULONG_PTR, dwData2 ULONG_PTR) HDDEDATA { return 0 } func (c *DdeServer) MetaCallBackfunc(wType UINT, wFmt UINT, hConv HCONV, hsz1 HSZ, hsz2 HSZ, hData HDDEDATA, dwData1 ULONG_PTR, dwData2 ULONG_PTR) HDDEDATA { selectItem := c.IsHSZItem(hsz2) var res HDDEDATA switch wType { case XTYP_CONNECT: //接受客户端链接; if ddeml.DdeCmpStringHandles(HSZ(hsz1), c.HszTopic) <= 0 && ddeml.DdeCmpStringHandles(HSZ(hsz2), c.HszApp) <= 0 { res = HDDEDATA(TRUE) } else { res = HDDEDATA(FALSE) //接受客户端链接 } case XTYP_ADVSTART: //客户端启动咨询循环。 if ddeml.DdeCmpStringHandles(HSZ(hsz1), c.HszTopic) <= 0 && ddeml.DdeCmpStringHandles(HSZ(hsz2), selectItem) <= 0 { res = HDDEDATA(TRUE) } else { res = HDDEDATA(FALSE) //接受客户端链接 } case XTYP_ADVREQ: if ddeml.DdeCmpStringHandles(HSZ(hsz1), c.HszTopic) <= 0 && ddeml.DdeCmpStringHandles(HSZ(hsz2), selectItem) <= 0 { res = c.SendMessage("XTYP_ADVREQ", selectItem, UINT(wFmt)) } //广播数据; case XTYP_REQUEST: if ddeml.DdeCmpStringHandles(HSZ(hsz1), c.HszTopic) <= 0 && ddeml.DdeCmpStringHandles(HSZ(hsz2), selectItem) <= 0 { res = c.SendMessage("XTYP_REQUEST哈哈", selectItem, UINT(wFmt)) } //数据请求; case XTYP_POKE: if ddeml.DdeCmpStringHandles(HSZ(hsz1), c.HszTopic) <= 0 && ddeml.DdeCmpStringHandles(HSZ(hsz2), selectItem) <= 0 { message := c.GetMessage(hData) fmt.Printf("message: %v\n", message) res = HDDEDATA(DDE_FACK) } case XTYP_DISCONNECT: fmt.Println("Disconnect notification received from server") //接受客户端发送的数据; default: res = HDDEDATA(NULL) } return res } func (c *DdeMeta) Request(hszItem HSZ) string { hData := ddeml.DdeClientTransaction(nil, 0, c.HConv, hszItem, UINT(CF_TEXT), UINT(XTYP_REQUEST), 5000, nil) if hData == 0 { return "Request failed" } else { return DDEGetMessage(hData) } } func (c *DdeMeta) Poke(hszItem HSZ, szData string) { cs := C.CString(szData) ddeml.DdeClientTransaction((*BYTE)(unsafe.Pointer(cs)), DWORD(len(szData)+1), c.HConv, hszItem, UINT(CF_TEXT), UINT(XTYP_POKE), 3000, nil) C.free(unsafe.Pointer(cs)) } func (c *DdeMeta) SendMessage(Src string, Item HSZ, Fmt UINT) HDDEDATA { cs := C.CString(Src) hdata := ddeml.DdeCreateDataHandle(c.IdInst, (*BYTE)(unsafe.Pointer(cs)), DWORD(len(Src)+1), 0, Item, Fmt, 0) C.free(unsafe.Pointer(cs)) return hdata } func (c *DdeMeta) GetMessage(hData HDDEDATA) string { size := ddeml.DdeGetData(hData, nil, 0, 0) var str BYTE ddeml.DdeGetData(hData, &str, size, 0) buffer := (*[MAX_BUFFER_SIZE]byte)(unsafe.Pointer(&str))[:size-1] return string(buffer) } func DDERequest(idInst DWORD, hConv HCONV, hszItem HSZ) string { hData := ddeml.DdeClientTransaction(nil, 0, hConv, hszItem, UINT(CF_TEXT), UINT(XTYP_REQUEST), 5000, nil) if hData == 0 { return "Request failed" } else { return DDEGetMessage(hData) } } func DDEPoke(idInst DWORD, hConv HCONV, hszItem HSZ, szData string) { cs := C.CString(szData) ddeml.DdeClientTransaction((*BYTE)(unsafe.Pointer(cs)), DWORD(len(szData)+1), hConv, hszItem, UINT(CF_TEXT), UINT(XTYP_POKE), 3000, nil) C.free(unsafe.Pointer(cs)) } func DDESendMessage(Inst DWORD, Src string, Item HSZ, Fmt UINT) HDDEDATA { cs := C.CString(Src) hdata := ddeml.DdeCreateDataHandle(Inst, (*BYTE)(unsafe.Pointer(cs)), DWORD(len(Src)+1), 0, Item, Fmt, 0) C.free(unsafe.Pointer(cs)) return hdata } func DDEGetMessage(hData HDDEDATA) string { size := ddeml.DdeGetData(hData, nil, 0, 0) var str BYTE ddeml.DdeGetData(hData, &str, size, 0) buffer := (*[MAX_BUFFER_SIZE]byte)(unsafe.Pointer(&str))[:size-1] return string(buffer) }