- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我正在尝试在 MQL5 中设置一个 PUB 套接字,在 Python 中设置一个 SUB 套接字来接收消息。
我在 MQL5 中有这个:
#include <Zmq/Zmq.mqh>
Context context("helloworld");
Socket socket(context,ZMQ_PUB);
string BROKER;
int OnInit()
{
if (socket.bind("tcp://*:5556"))
{
Print("Error");
}
else
Print("Bound");
BROKER = AccountInfoString(ACCOUNT_COMPANY);
return(INIT_SUCCEEDED);
}
void OnTick()
{
MqlTick last_tick;
string str;
if(SymbolInfoTick(Symbol(),last_tick))
{
StringConcatenate(str, BROKER, ",", Symbol(), ",", last_tick.time_msc, ",", last_tick.ask, ",", last_tick.bid, ",", last_tick.last, ",", last_tick.volume);
}
else
str = "FAIL";
Print(str);
ZmqMsg reply(str);
socket.send(reply);
}
在 Python 中:
import zmq
import random
import sys
import time
context = zmq.Context()
socket = context.socket(zmq.SUB)
ports = [5556]
for port in ports:
print(port)
socket.connect("tcp://localhost:{}".format(port))
socket.setsockopt_string(zmq.SUBSCRIBE, '')
print('connected')
f = open('metatrader-1.csv', 'a')
while True:
msg = socket.recv()
print(msg)
f.write(str(msg) + '\n')
这个问题是,这似乎在 Python 端没有收到任何东西,recv 调用只是永远阻塞。 OnTick 方法在 MT 中触发,因为可以看到指纹。
我怎样才能让它工作?
请注意,如果我切换到 REP/REQ 对,它会起作用。
MQL5:
#include <Zmq/Zmq.mqh>
Context context("helloworld");
Socket socket(context,ZMQ_REQ);
string BROKER;
int OnInit()
{
if (socket.connect("tcp://localhost:5555"))
{
Print("Error");
}
else
Print("Bound");
BROKER = AccountInfoString(ACCOUNT_COMPANY);
return(INIT_SUCCEEDED);
}
void OnTick()
{
MqlTick last_tick;
string str;
if(SymbolInfoTick(Symbol(),last_tick))
{
StringConcatenate(str, BROKER, ",", Symbol(), ",", last_tick.time_msc, ",", last_tick.ask, ",", last_tick.bid, ",", last_tick.last, ",", last_tick.volume);
}
else
str = "FAIL";
Print(str);
ZmqMsg reply(str);
socket.send(reply);
socket.recv(reply);
}
python :
import zmq
import random
import sys
import time
context = zmq.Context()
socket = context.socket(zmq.REP)
ports = [5555]
for port in ports:
print(port)
socket.bind("tcp://*:{}".format(port))
#socket.setsockopt_string(zmq.SUBSCRIBE, '')
print('connected')
f = open('metatrader-1.csv', 'a')
while True:
msg = socket.recv()
socket.send_string('ack')
print(msg)
f.write(str(msg) + '\n')
但这有一些缺点,所以如果可以的话我宁愿不使用它。
最佳答案
您的套接字选项必须放在套接字连接之前,因此您的代码将是:
import zmq
import random
import sys
import time
context = zmq.Context()
socket = context.socket(zmq.SUB)
ports = [5556]
socket.setsockopt(zmq.SUBSCRIBE, b"") # Note.
for port in ports:
print(port)
socket.connect("tcp://localhost:{}".format(port))
print('connected')
f = open('metatrader-1.csv', 'a')
while True:
msg = socket.recv()
print(msg)
f.write(str(msg) + '\n')
此外,这部分:
if (socket.bind("tcp://*:5556"))
{
Print("Error");
}
else
Print("Bound");
应该是反过来的。当套接字成功绑定(bind)时,这实际上会打印错误。
关于python - Python zmq SUB 套接字未接收到 MQL5 Zmq PUB 套接字,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53548582/
当我尝试运行文件时收到此错误? can't find package zmq while executing "package require zmq" 如何在 Ubuntu 中安装 zmq? 谢谢
我已经使用 Installation on Linux / bsd without root access 中提到的步骤安装了 zmq已成功安装,但在启动应用程序时出现错误。我在没有根访问权限的环境中
我正在尝试通过 czmqz (4.0.2) 使用 libzmq (4.2.2) 在 Python 程序和我的 C++ 应用程序之间建立 IPC 通信 channel 。 我正在使用 ZMQ 发布者/订
更新我的问题 如何在我的 python zmq 服务器中表示到达的消息以显示其内容? 根据这种行为,我是否可以假设 btnState 数据无论如何都会发送到 python 服务器? 上下文: 我正在发
我有一个客户端使用一对套接字与单个服务器通信: context = zmq.Context() socket = context.socket(zmq.PAIR) socket.setsockopt(
我有一个名为 GenericMessage 的类,显示在下面的第一个代码片段中(在 GenericMessage.hxx 中定义)。 我有一个名为 TestFE.cpp 的 .cpp 文件(参见下面的
我试图在 Go 应用程序中包含 ZMQ 套接字,但 zmq4 和 gozmq(Go 的引用 ZMQ 绑定(bind)库)都给我带来了问题。我想了解为什么 zmq4 特别不能在我的系统上导入。 我运行的
我遇到了一个关于 ZeroMQ 的问题,因为我在 ZMQ 套接字上为 zmq::proxy 和 zmq::poll 使用了指针。这样做会发生错误 88 的异常(非套接字上的套接字操作)。 实际上 Ze
我正在尝试在 MQL5 中设置一个 PUB 套接字,在 Python 中设置一个 SUB 套接字来接收消息。 我在 MQL5 中有这个: #include Context context("hell
我想用 React 做一个异步路由器到经销商消息传递,但它不工作。 http://zguide.zeromq.org/php:rtdealer中的代码正在工作,但我无法确定我在做什么不同。我正在使用
我有一个 Python 脚本,我在其中绑定(bind)了多个(例如 5 个)ZMQ 接收器套接字,如下所示: receiver_1 = context.socket(zmq.PULL) receive
在Linux-Ubuntu上安装ZeroMQ,一个网站 https://tuananh.org/2015/06/16/how-to-install-zeromq-on-ubuntu/ 说要运行以下命令
如何创建允许多个发布者和这些发布者的多个订阅者的网络? 还是绝对有必要使用消息代理? import time import zmq from multiprocessing import Proces
我研究 zmq 有一段时间了,并实现了一个简化的 poc - 模仿我的基础架构设计 - 使用它(特别是使用 NetMQ 包装器),取得了很好的效果。 我的情况是这样的: 将来我计划在一台机器上运行多个
我一直在阅读 ZMQ documentation在心跳上并阅读应该使用乒乓方法而不是用于偏执海盗模式的方法 For Paranoid Pirate, we chose the second appro
我正在寻找一种支持 ZMQ 的解决方案,用于连接到 0 或 1 个对等点的绑定(bind)端点之间的通信,仅此而已。通信是双向的,连接可以随时结束或切断;并且可以与新的对等点或同一对等点重新建立连接。
我正在使用 ZMQ PUB 套接字来发布不同主题的新闻。但是其中一些消息的计算成本很高。有没有办法有一个 on_subscribe 回调,这样我就可以只计算实际需要的东西? 最佳答案 只是为了记录我找
我有兴趣了解 ZMQ 在发送消息之前是否已经压缩了消息,这样我自己就不会这样做,因为压缩消息两次是多余的。 如果确实这样做,它是自动的,还是有一个选项参数可以指定? 我正在使用java,但这确实不重要
我在我的 Java 应用程序中使用 ZMQ。我发现它的行为不均匀,即如果我发送大约 100 条消息,其中一个消费者说需要 1 秒,那么如果我们继续增加消费者,所花费的时间将变为 2,1.5,3,这样。
所以我有 8 个工作线程(PULL 套接字),它们从单个绑定(bind)的 PUSH 套接字提供数据。它们每秒处理大量数据,有时会随机崩溃。显然,我应该尝试处理这些崩溃,但我很好奇这个系统目前的弹性如
我是一名优秀的程序员,十分优秀!