12345678910111213141516171819202122232425262728293031323334353637383940 |
- package com.ssj.dubbo.config;
- import java.lang.management.ManagementFactory;
- import java.util.Set;
- import javax.management.MBeanServer;
- import javax.management.ObjectName;
- import javax.management.Query;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.context.annotation.Bean;
- import org.springframework.context.annotation.Configuration;
- import com.alibaba.dubbo.config.RegistryConfig;
- @Configuration
- public class DubboCustomConfig {
- @Value("${dubbo.application.name}")
- private String app_name;
- @Value("${dubbo.application.path}")
- private String path;
- @Autowired
- private RegistryConfig registryConfig;
- @Bean
- public RegistryConfig registryConfig() throws Exception {
- // String path="/www/data/dubbo/";
- MBeanServer beanServer = ManagementFactory.getPlatformMBeanServer();
- Set<ObjectName> objectNames = beanServer.queryNames(new ObjectName("*:type=Connector,*"),
- Query.match(Query.attr("protocol"), Query.value("HTTP/1.1")));
- String serverPort = objectNames.iterator().next().getKeyProperty("port");
- registryConfig.setFile(path+app_name+"_"+serverPort+".cache");
- return registryConfig;
- }
- }
|