将路由到流
使用Mule，是否有方法拦截所有流？我的用例是查看流名称，如果流名称与http请求中的特定参数匹配，我需要采取一些操作。我不想为每个流编写拦截器配置。那太乏味了，也不理想。
我想要一个类似于Spring AOP的东西，横切应用程序中的所有流，然后在流执行之前编写一个可以由Mule调用的java类。我会在那里检查流名称，如果它与请求中的参数匹配，我可以采取行动，否则，我将不需要做任何事情。
我是骡子的新手。有人能告诉我正确的方向吗？
您可以使用服务器通知来实现这一点，我已经实现了一种类似的方法，可以监听PRE/AFTER调用HTTP端点。
这是代码：
<spring:beans>
<spring:bean name="MuleMessageProcessorNoticationBean" class="com.alexfrndz.MPLogger"></spring:bean>
</spring:beans>
package com.alexfrndz;
import org.mule.api.MuleEvent;
import org.mule.api.MuleMessage;
import org.mule.api.context.notification.MessageProcessorNotificationListener;
import org.mule.api.processor.LoggerMessageProcessor;
import org.mule.api.processor.MessageProcessor;
import org.mule.context.notification.MessageProcessorNotification;
import org.mule.endpoint.AbstractEndpoint;
import org.mule.endpoint.DefaultOutboundEndpoint;
import org.mule.processor.AsyncDelegateMessageProcessor;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.log4j.Logger;
public class MPLogger implements MessageProcessorNotificationListener<MessageProcessorNotification> {
private Logger log = Logger.getLogger(MPLogger.class);
private long startTime = System.currentTimeMillis();
private long endTime = System.currentTimeMillis();
@Override
public void onNotification(MessageProcessorNotification m) {
MuleEvent ev = m.getSource();
MuleMessage msg = ev.getMessage();
Object payload = msg.getPayload();
String ref = payload != null ? payload.toString() : "null";
MessageProcessor proc = m.getProcessor();
boolean inc = true;
if (m.getAction() == MessageProcessorNotification.MESSAGE_PROCESSOR_PRE_INVOKE) {
startTime = System.currentTimeMillis();
}
if (m.getAction() == MessageProcessorNotification.MESSAGE_PROCESSOR_POST_INVOKE) {
long executionTime = System.currentTimeMillis() - startTime;
AbstractEndpoint ep = (AbstractEndpoint) proc;
log.info("Http call to : "+ ep.getName() + " took " + executionTime + "ms response time");
}
boolean outgoing = proc instanceof DefaultOutboundEndpoint;
if (inc) {
if (outgoing) {
AbstractEndpoint ep = (AbstractEndpoint) proc;
log.warn(msg.getMessageRootId() + " [OUTBOUND] Message " + ref + " -> " + ep.getEndpointURI());
ep.getResponseTimeout();
} else {
log.warn(msg.getMessageRootId() + " [PROCESSING] Message " + ref + " <> " + proc.getClass().getSimpleName());
}
}
}
}
从上面的代码中，您可以四处寻找消息处理器或流的名称，并拦截有效负载。
这对有何帮助
因此，如果你想基于http url控制流，你可以使用一个通用流，并使用以下选项：-
<http:listener-config name="HTTP_Listener_Configuration" protocol="HTTP" host="0.0.0.0" port="${port}" basePath="mainpath" doc:name="HTTP Listener Configuration"/>
<flow name="Entry_Point">
<http:listener config-ref="HTTP_Listener_Configuration" path="/*" doc:name="HTTP" parseRequest="false">
<http:error-response-builder statusCode="404" reasonPhrase="Path Not Found"/>
</http:listener>
<set-variable variableName="requestUri" value="#[message.inboundProperties['http.request.uri'].replace('/mainpath/','')]" doc:name="Variable"/>
<logger level="INFO" message="PATH :-> #[requestUri]" doc:name="Logger" />
<choice doc:name="Route Message By Path">
<when
expression="#[regex('service/.+', requestUri, java.util.regex.Pattern.CASE_INSENSITIVE)]">
<flow-ref name="flow1" doc:name="flow1" />
</when>
<when
expression="#[regex('audit/.+', requestUri, java.util.regex.Pattern.CASE_INSENSITIVE)]">
<flow-ref name="flow2" doc:name="flow2" />
</when>
//////////// so on
但是，如果您想根据HTTP请求控制流，那么根据该请求，您可以使用XPATH（如果是XML请求）或JSON到对象转换器（如果是JSON请求）并提取元素值，根据元素值，您可以使用Choice路由器
我想向您推荐一种满足需求的方法。
定义一个以http为入口点的公共流，然后定义一个选择路由器，用于评估所考虑的参数。基于条件评估的SO使用flow-ref调用相应的流。
建议的方法可行！
但是，根据你对场景的描述，我觉得你会更好地使用APIkit。
当然，它可能有更多您需要的功能，但简而言之，基于REST API定义（这是http请求的一部分），它将自动将其路由到实现API该部分的流。
最酷的是，你只需要编写RAML，工作室就会为你生成流。
希望这能有所帮助；）
为什么不使用简单的"Choice router"呢。根据您在输入处设置的请求参数，可以调用与条件匹配的适当流。