webhook压测、java版Exhook的message.publish钩子如何获取用户属性User-Property

ealdan · 2024 年11 月 6 日 10:06

环境信息

EMQX 版本：5.8.1开源版
操作系统及版本：阿里云k8s，4c8g，pod数3
webhook桥接的SpringBoot：阿里云k8s，4c8g，pod数3，接口内业务的接口开启多线程，核心线程数12，最大线程数30，线程池队列大小80

问题描述

使用webhook可以获取pubProps和User-Property。java版Exhook的message.publish钩子，如何获取用户属性User-Property？

目前webhook流转消息发布，2万条消息/秒吞吐，开始出现“已丢弃”，随后出现“成功“数不再增加，且"成功"数每次只+1、+2的情况。出现大面积消息丢弃时，EMQX集群的cpu占用86%，内存占用23%。SpringBoot服务的cpu占用29%，内存占用54%

所以想用 exhook 或插件替换掉webhook，试一下能否突破瓶颈，但是我们的业务需要获取用户属性。

配置文件及日志

zhongwencool · 2024 年11 月 7 日 02:03

github.com

emqx/emqx/blob/master/apps/emqx_exhook/priv/protos/exhook.proto

//------------------------------------------------------------------------------
// Copyright (c) 2020-2024 EMQ Technologies Co., Ltd. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//------------------------------------------------------------------------------

syntax = "proto3";

option csharp_namespace = "Emqx.Exhook.V2";
option go_package = "emqx.io/grpc/exhook";

该文件已被截断。显示原文

requestmeta 中应该就有

ealdan · 2024 年11 月 7 日 02:18

你好，打印的requestMeta里面没有

zhongwencool · 2024 年11 月 7 日 02:30

sorry 应该是在 Property 里面，不过 publish message 没有，connect subscribe 有.我去反馈一下，看是否要加一下，不过近期你应该是用不上了

ealdan · 2024 年11 月 7 日 02:35

好的，谢谢。connect subscribe我们能获取到，目前正在使用。
那么后面关于publish message是否确定要加上，我应该在哪里关注呢？

zhongwencool · 2024 年11 月 7 日 02:49

下周我们会安排会议决定是不是加，到时候会更新到这里吧

ealdan · 2024 年11 月 7 日 02:51

好的，谢谢

heeejianbo · 2024 年11 月 11 日 13:50

感谢，各位。已加入到5.9.0的版本追踪里面