本发明提供了一种基于反射机制的流式系统行情消息筛选方法，涉及行情数据处理技术领域，该方法包括以下的步骤：S1、连接至kafka流式系统，对流式系统中的行情消息进行预筛选；S2、解析行情消息，得到对应的protobuf消息，基于布尔表达式，对protobuf消息的内容进行精准筛选，完成行情消息的筛选，利用kafka流式消息系统的特性，减少消息订阅量，快速定位历史消息，并且支持循环筛选；基于protobuf反射机制动态加载任意新的协议消息格式，根据消息名称动态生成内存数据对象，并用于解析流式系统中的二进制消息，无需修改消费者程序；并且基于自定义布尔过滤器，针对解析后的protobuf消息的任意字段数据进行多条件组合筛选，最终得到满足过滤规则的行情消息。