在python创建DDE服务器并持续发送数据

Question

我正在尝试在 python 中编写 DDE 服务器，它需要将不断变化的字符串发送到作为 DDE 客户端连接的程序。

连接到 DDE 服务器的程序使用以下 DDE 设置来连接 [服务：Orbitron，主题：跟踪，项目：跟踪]。该程序必须接收 DDE 服务器以下列字符串格式发送的信息： "UP0 DN145000001 UMusb DMfm AZ040 EL005 SNNO SATELLITE".

此字符串的内容大约每秒更改一次，我希望 DDE 服务器将新字符串发送到连接的 DDE 客户端，例如每秒。

我目前正在使用下面的代码，它是原始 ddeserver.py 文件 see here.

的略微修改版本

import win32ui
from pywin.mfc import object
import dde


class MySystemTopic(object.Object):
        def __init__(self):
                object.Object.__init__(self, dde.CreateServerSystemTopic())

        def Exec(self, cmd):
                print "System Topic asked to exec", cmd

class MyOtherTopic(object.Object):
        def __init__(self, topicName):
                object.Object.__init__(self, dde.CreateTopic(topicName))

        def Exec(self, cmd):
                print "Other Topic asked to exec", cmd

class MyRequestTopic(object.Object):
        def __init__(self, topicName):
                topic = dde.CreateTopic(topicName)
                topic.AddItem(dde.CreateStringItem(""))
                object.Object.__init__(self, topic)

        def Request(self, aString):
                print "Request Topic sent: ", aString
                a="UP0 DN145800001 UMusb DMfm AZ040 EL005 SNNO SATELLITE"
                print a
                return(a)


server = dde.CreateServer()
server.AddTopic(MyRequestTopic("Tracking"))
server.Create('Orbitron')    

while 1:
        win32ui.PumpWaitingMessages(0, -1)

当我运行代码时，我可以成功连接程序并且字符串（如代码中提供的那样）被接收一次。我尝试了一些不同的东西，但我还想不出一种方法如何更改为 python 代码，以便让 DDE 服务器在循环或类似的情况下连续重新发送字符串。

非常欢迎任何建议。

P.S。我对 python、DDE 和这个论坛比较陌生，如果有什么不清楚的地方，我深表歉意。请告诉我。

Answer 1

# coded by JayleoPlayGround
# use Portable Python 2.7.5.1 + pywin32-214


import time
import win32ui, dde
from pywin.mfc import object


class DDETopic(object.Object):
    def __init__(self, topicName):
        self.topic = dde.CreateTopic(topicName)
        object.Object.__init__(self, self.topic)
        self.items = {}

    def setData(self, itemName, value):
        try:
            self.items[itemName].SetData( str(value) )
        except KeyError:
            if itemName not in self.items:
                self.items[itemName] = dde.CreateStringItem(itemName)
                self.topic.AddItem( self.items[itemName] )
                self.items[itemName].SetData( str(value) )


ddeServer = dde.CreateServer()
ddeServer.Create('Orbitron')
ddeTopic = DDETopic('Tracking')
ddeServer.AddTopic(ddeTopic)

while True:
    yourData = time.ctime() + ' UP0 DN145000001 UMusb DMfm AZ040 EL005 SNNO SATELLITE'
    ddeTopic.setData('Tracking', yourData)
    win32ui.PumpWaitingMessages(0, -1)
    time.sleep(0.1)

在python创建DDE服务器并持续发送数据

Create DDE server in python and send data continuously

python

dde

server