diff --git a/dubbo-config/src/main/java/com/alibaba/dubbo/config/ServiceConfig.java b/dubbo-config/src/main/java/com/alibaba/dubbo/config/ServiceConfig.java index e07dae0125..c7c00483c5 100644 --- a/dubbo-config/src/main/java/com/alibaba/dubbo/config/ServiceConfig.java +++ b/dubbo-config/src/main/java/com/alibaba/dubbo/config/ServiceConfig.java @@ -394,7 +394,6 @@ public class ServiceConfig extends AbstractServiceConfig { } } if ("injvm".equals(protocolConfig.getName())) { - protocolConfig.setPort(0); protocolConfig.setRegister(false); map.put("notify", "false"); } diff --git a/dubbo-rpc-injvm/src/main/java/com/alibaba/dubbo/rpc/protocol/injvm/InjvmProtocol.java b/dubbo-rpc-injvm/src/main/java/com/alibaba/dubbo/rpc/protocol/injvm/InjvmProtocol.java index 325c40990f..a3e81392f6 100644 --- a/dubbo-rpc-injvm/src/main/java/com/alibaba/dubbo/rpc/protocol/injvm/InjvmProtocol.java +++ b/dubbo-rpc-injvm/src/main/java/com/alibaba/dubbo/rpc/protocol/injvm/InjvmProtocol.java @@ -15,12 +15,12 @@ */ package com.alibaba.dubbo.rpc.protocol.injvm; -import com.alibaba.dubbo.common.Extension; -import com.alibaba.dubbo.common.URL; -import com.alibaba.dubbo.rpc.Exporter; -import com.alibaba.dubbo.rpc.Invoker; -import com.alibaba.dubbo.rpc.Protocol; -import com.alibaba.dubbo.rpc.RpcException; +import com.alibaba.dubbo.common.Extension; +import com.alibaba.dubbo.common.URL; +import com.alibaba.dubbo.rpc.Exporter; +import com.alibaba.dubbo.rpc.Invoker; +import com.alibaba.dubbo.rpc.Protocol; +import com.alibaba.dubbo.rpc.RpcException; import com.alibaba.dubbo.rpc.protocol.AbstractProtocol; /** @@ -40,8 +40,8 @@ public class InjvmProtocol extends AbstractProtocol implements Protocol { return DEFAULT_PORT; } - public Exporter export(Invoker invoker) throws RpcException { - return new InjvmExporter(invoker, serviceKey(invoker.getUrl()), exporterMap); + public Exporter export(Invoker invoker) throws RpcException { + return new InjvmExporter(invoker, serviceKey(invoker.getUrl().setPort(DEFAULT_PORT)), exporterMap); } public Invoker refer(Class serviceType, URL url) throws RpcException {