Das Szenario sieht wie folgt aus:
Der Kunde sendet die ursprüngliche Nachricht über das SDK. Nach Erhalt der Nachricht extrahiert und konvertiert das Modul, das ich gerade entwickle, die Nachricht entsprechend der Konfiguration, um ein neues Nachrichtenformat zu generieren Übergeben Sie es über mq an das Downstream-Modul.
Vielleicht habe ich es nicht klar beschrieben, was zu Missverständnissen geführt hat. Bitte beschreiben Sie die Szene im Detail:
你所完成的功能是一个转换器,限定死要求来的数据的格式,譬如id,type,content,你可以写一个接口,拥有getId,getType,getContent方法,要求实现方必须提供这几个值。
经过你的转换器后,得到不同的对象。
我想可以这样来实现:
针对不同的消息,有不同的消息处理器(Handler)来完成对应的功能,消息提取和新消息的生成等;
这些Handler实现了一个共同的接口,后续还可以继续增加新的Handler;
所有Handler形成一个处理链,每个Handler有个match方法来判断是否该由自己处理,不能处理的,交给后续的Handler。
所以我觉得可以考虑责任链模式,策略模式等。
这么简单的需求,adapter,适配一下就可以了