We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
我这里目前部署的是3个节点,单节点消息pub、sub没有任何问题,但是跨节点就会出现pub之后丢消息,消息丢失之后导致多借点之间数据同步阻塞后续消息无法pub同步到其他节点。 节点配置如下 节点1: 节点2: 节点3:
我这里测试使用的是mqtt-stresser作为测试客户端。 测试命令为./build/mqtt-stresser-linux-amd64 -log-level=0 -broker=tcp://127.0.0.1:1887 -broker-sub=tcp://127.0.0.1:1885 -num-clients=1 -num-messages=25 其中-broker-sub 为我自己加的一个配置,专门用于测试夸节点消息同步是否可能会丢消息。 目前测试发现一般情况下-broker-sub 小于20大概率不会有问题,超过20消息必丢。 pub节点日志 sub节点日志
麻烦大佬帮忙看看是否为我的配置存在问题导致的消息丢失
The text was updated successfully, but these errors were encountered:
目前测试发现一般情况下-broker-sub 小于20大概率不会有问题,超过20消息必丢。
这句话啥意思?
Sorry, something went wrong.
抱歉,那个地方写的有问题, 是-num-messages=这个值小于20的情况下不会丢,大于25之后是必丢
No branches or pull requests
我这里目前部署的是3个节点,单节点消息pub、sub没有任何问题,但是跨节点就会出现pub之后丢消息,消息丢失之后导致多借点之间数据同步阻塞后续消息无法pub同步到其他节点。
![image](https://private-user-images.githubusercontent.com/12842114/258790723-953936c5-1d4a-4893-bc3e-81d28ea1f77d.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjAyNzUwNTAsIm5iZiI6MTcyMDI3NDc1MCwicGF0aCI6Ii8xMjg0MjExNC8yNTg3OTA3MjMtOTUzOTM2YzUtMWQ0YS00ODkzLWJjM2UtODFkMjhlYTFmNzdkLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MDYlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzA2VDE0MDU1MFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPWJmOTM4ZWViM2U3YTM3YjE5ODRiOWRiNjU4MzI2MzAxNDI0MjdmYTAxZDcyZWRmMDVhNzIyZWJhYjU4ZTYwYzEmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.vUY7qSr3iehb7oZScGx3Qa7AJKg5W7u8tDcoo-m_AMQ)
![image](https://private-user-images.githubusercontent.com/12842114/258790834-07a0741d-07f1-4976-8ff5-c786d7f9c3ae.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjAyNzUwNTAsIm5iZiI6MTcyMDI3NDc1MCwicGF0aCI6Ii8xMjg0MjExNC8yNTg3OTA4MzQtMDdhMDc0MWQtMDdmMS00OTc2LThmZjUtYzc4NmQ3ZjljM2FlLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MDYlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzA2VDE0MDU1MFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTRhZWFjYzU0NTIyYjM0ODFlNDkyMTEyZGJlZGI0ZjcxZWZhMTM5MGU2YTg0MmNmNjVkYzYwMGFkZDFlOWQ1ZjImWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.G3kiIfwmdbSm-pCrEX4QZ4IKIKi9Zd5JxHEMAMqEa00)
![image](https://private-user-images.githubusercontent.com/12842114/258790916-d5748352-2738-4e96-b721-385b2aa8e4da.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjAyNzUwNTAsIm5iZiI6MTcyMDI3NDc1MCwicGF0aCI6Ii8xMjg0MjExNC8yNTg3OTA5MTYtZDU3NDgzNTItMjczOC00ZTk2LWI3MjEtMzg1YjJhYThlNGRhLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MDYlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzA2VDE0MDU1MFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPWFjZGU0M2ZmYTBjNWZmNjI3MWQ1YjY1MmEzNGRkZjk4ODk1ZWI5OWI2Y2JiZWQxNDg3MjgwZWVmNDQ4YWFkZjYmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.O-zBeiEsNbkqDVIgUx_DRfVXIbjqQnN80BV4mroxoJ0)
节点配置如下
节点1:
节点2:
节点3:
我这里测试使用的是mqtt-stresser作为测试客户端。
![image](https://private-user-images.githubusercontent.com/12842114/258792357-f21cbeb0-d2ff-4be3-9b46-2157ca00cee8.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjAyNzUwNTAsIm5iZiI6MTcyMDI3NDc1MCwicGF0aCI6Ii8xMjg0MjExNC8yNTg3OTIzNTctZjIxY2JlYjAtZDJmZi00YmUzLTliNDYtMjE1N2NhMDBjZWU4LnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MDYlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzA2VDE0MDU1MFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPWZmNzcyY2E3ZmIxYzk3NmFiNGZjNjVhMTg1Y2NjYmEyMzZlM2UxNmFhMTk0ODA2YzlmMDUwMTNmMjIzNDE1NWQmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.iqaob0jDOSbfDnp6FT4-invSOSCJoSnaHyrknSe76uA)
![image](https://private-user-images.githubusercontent.com/12842114/258792746-c89f8c86-581b-4890-877b-16a8d39ad1d2.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjAyNzUwNTAsIm5iZiI6MTcyMDI3NDc1MCwicGF0aCI6Ii8xMjg0MjExNC8yNTg3OTI3NDYtYzg5ZjhjODYtNTgxYi00ODkwLTg3N2ItMTZhOGQzOWFkMWQyLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MDYlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzA2VDE0MDU1MFomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPWM5MDg4MzZjMDZkYTBhOWJiMzBiYWNjZmFlMWUzNzVkNmM0MjdhZmE4ZDJjNTRhZjEzZWVhNDA5NmY2YmZmNzcmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.q4zjDnnQNRGsaa1bH64iobodqDLXfr7oATbGX_s8W0M)
测试命令为./build/mqtt-stresser-linux-amd64 -log-level=0 -broker=tcp://127.0.0.1:1887 -broker-sub=tcp://127.0.0.1:1885 -num-clients=1 -num-messages=25
其中-broker-sub 为我自己加的一个配置,专门用于测试夸节点消息同步是否可能会丢消息。
目前测试发现一般情况下-broker-sub 小于20大概率不会有问题,超过20消息必丢。
pub节点日志
sub节点日志
麻烦大佬帮忙看看是否为我的配置存在问题导致的消息丢失
The text was updated successfully, but these errors were encountered: