Message Dispatch Extension
Expansion Description
Channel information dispatcher, used to specify the thread pool model.
Extension ports
org.apache.dubbo.remoting.Dispatcher
Extended configuration
<dubbo:protocol dispatcher="xxx" />
<!-- The default value setting, when <dubbo:protocol> does not configure the dispatcher attribute, use this configuration -->
<dubbo:provider dispatcher="xxx" />
Known extensions
org.apache.dubbo.remoting.transport.dispatcher.all.AllDispatcher
org.apache.dubbo.remoting.transport.dispatcher.direct.DirectDispatcher
org.apache.dubbo.remoting.transport.dispatcher.message.MessageOnlyDispatcher
org.apache.dubbo.remoting.transport.dispatcher.execution.ExecutionDispatcher
org.apache.dubbo.remoting.transport.dispatcher.connection.ConnectionOrderedDispatcher
Extended example
Maven project structure:
src
|-main
|-java
|-com
|-xxx
|-XxxDispatcher.java (implements the Dispatcher interface)
|-resources
|-META-INF
|-dubbo
|-org.apache.dubbo.remoting.Dispatcher (plain text file, content: xxx=com.xxx.XxxDispatcher)
XxxDispatcher.java:
package com.xxx;
import org.apache.dubbo.remoting.Dispatcher;
public class XxxDispatcher implements Dispatcher {
public Group lookup(URL url) {
//...
}
}
META-INF/dubbo/org.apache.dubbo.remoting.Dispatcher:
xxx=com.xxx.XxxDispatcher
Feedback
Was this page helpful?
Glad to hear it! Please tell us how we can improve.
Sorry to hear that. Please tell us how we can improve.
Last modified January 2, 2023: Enhance en docs (#1798) (95a9f4f6c1)