Comments (8)
c899588
Fixed。请pull以上commit后重试。
原因是样例配置有误,导致3个consumer用了同一块共享内存。共享内存里保存的是consumer到队列的处理关系,所以3个consumer处理了同一批队列,导致部分队列没有consumer消费。
from phxqueue.
@unixliang git pull后也编译现了,现在连消息都收不到了
from phxqueue.
方便打包日志发送到 [email protected] 吗?
from phxqueue.
已经发送log到 phxteam邮箱了
from phxqueue.
$ grep 'ChildRun' consumer.0/*
consumer.0/test.iZuf6hx16c6lym9fxx51xcZ.root.log.INFO.20170916-203731.12931:I0916 20:37:31.094595 12931 logger_google.cpp:73] INFO: PN8phxqueue8consumer8ConsumerE::ChildRun:481 INFO: start vpid 0
consumer.0/test.iZuf6hx16c6lym9fxx51xcZ.root.log.INFO.20170916-203731.12932:I0916 20:37:31.094126 12932 logger_google.cpp:73] INFO: PN8phxqueue8consumer8ConsumerE::ChildRun:481 INFO: start vpid 1
$ grep 'ChildRun' consumer.1/*
consumer.1/test.iZuf6hx16c6lym9fxx51xcZ.root.log.INFO.20170916-203746.12938:I0916 20:37:46.119879 12938 logger_google.cpp:73] INFO: PN8phxqueue8consumer8ConsumerE::ChildRun:481 INFO: start vpid 0
consumer.1/test.iZuf6hx16c6lym9fxx51xcZ.root.log.INFO.20170916-203746.12939:I0916 20:37:46.119526 12939 logger_google.cpp:73] INFO: PN8phxqueue8consumer8ConsumerE::ChildRun:481 INFO: start vpid 1
$ grep 'ChildRun' consumer.2/*
consumer.2/test.iZuf6hx16c6lym9fxx51xcZ.root.log.INFO.20170916-203750.12946:I0916 20:37:50.740314 12946 logger_google.cpp:73] INFO: PN8phxqueue8consumer8ConsumerE::ChildRun:481 INFO: start vpid 1
从日志看来,consumer.2有一个进程没启动(vpid 0)。
麻烦贴一下dmesg信息,重启consumer.2试试。
from phxqueue.
在我的环境中,kill掉任何一个处理进程(例如vpid 0),其父进程都会拉起新进程并继续处理,应该是符合设计预期的。
from phxqueue.
[root@iZuf6hx16c6lym9fxx51xcZ ~]# ps -ef | grep consumer_main
root 12928 9248 0 20:37 pts/1 00:00:00 bin/consumer_main -c etc/consumer_server.0.conf
root 12929 12928 0 20:37 pts/1 00:00:00 bin/consumer_main -c etc/consumer_server.0.conf
root 12930 12928 0 20:37 pts/1 00:00:00 bin/consumer_main -c etc/consumer_server.0.conf
root 12931 12928 0 20:37 pts/1 00:00:14 bin/consumer_main -c etc/consumer_server.0.conf
root 12932 12928 0 20:37 pts/1 00:00:15 bin/consumer_main -c etc/consumer_server.0.conf
root 12935 9380 0 20:37 pts/2 00:00:00 bin/consumer_main -c etc/consumer_server.1.conf
root 12936 12935 0 20:37 pts/2 00:00:00 bin/consumer_main -c etc/consumer_server.1.conf
root 12937 12935 0 20:37 pts/2 00:00:00 bin/consumer_main -c etc/consumer_server.1.conf
root 12938 12935 0 20:37 pts/2 00:00:14 bin/consumer_main -c etc/consumer_server.1.conf
root 12939 12935 0 20:37 pts/2 00:00:14 bin/consumer_main -c etc/consumer_server.1.conf
root 12942 9516 0 20:37 pts/3 00:00:00 bin/consumer_main -c etc/consumer_server.2.conf
root 12943 12942 0 20:37 pts/3 00:00:00 bin/consumer_main -c etc/consumer_server.2.conf
root 12944 12942 0 20:37 pts/3 00:00:00 bin/consumer_main -c etc/consumer_server.2.conf
root 12945 12942 0 20:37 pts/3 00:00:14 bin/consumer_main -c etc/consumer_server.2.conf
root 12946 12942 0 20:37 pts/3 00:00:14 bin/consumer_main -c etc/consumer_server.2.conf
vpid 0是什么了? 我ps看到consumer_main 在运行啊
from phxqueue.
@unixliang 又重启了一次好像可以了
from phxqueue.
Related Issues (20)
- bash build.sh 报错 HOT 1
- make[1]: *** 没有规则可以创建“test_propose_batch”需要的目标“test_propose_batch.o”。 停止 HOT 1
- 有计划支持C#的时间表吗 HOT 27
- PhxQueue可以用于跨大洲的消息队列吗?如果可以,性能和实时性如何? HOT 2
- 是否支持延迟投递的消息 HOT 1
- make报错 error: 'BaseDispatcher' in namespace 'phxrpc' does not name a template type HOT 1
- 启动store_server 报错 HOT 1
- should be auto read_sz = fread(buf.get(), 1, fileStat.st_size, fp ); instead of auto read_sz = fread(buf.get(), fileStat.st_size, 1, fp ) ?
- phxqueue文档能否丰富下? HOT 1
- 自动build失败 HOT 1
- Branch master sha1 df6c8de, git submodule phxrpc did not contain a1b7ce5c5ae633bac3d9df85ee874a1e8a82d353 HOT 2
- 执行build.sh编译,报错 HOT 3
- 消息队列与消息总线 HOT 1
- KeepSyncThread master 5s做一次消费进度同步,主从自动切换时会不会导致重复消费? HOT 1
- phxqueue/phxqueue/comm/utils/memory_util.h
- 假如一个storeId三个节点,某一个paxos instance实例slave所在节点重启,另外一个slave数据又有落后,可能会直接导致客户端消息发送失败?
- phxqueue的运行环境
- build.sh 出错
- phxqueue/producer/producer.cpp:105中打印顺序反了导致coredump
- 问下这个开源项目还有人维护吗? HOT 2
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from phxqueue.