Java PropertyLoader类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中cn.gyyx.elves.util.mq.PropertyLoader类的典型用法代码示例。如果您正苦于以下问题：Java PropertyLoader类的具体用法？Java PropertyLoader怎么用？Java PropertyLoader使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

PropertyLoader类属于cn.gyyx.elves.util.mq包，在下文中一共展示了PropertyLoader类的9个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: registerZooKeeper

import cn.gyyx.elves.util.mq.PropertyLoader; //导入依赖的package包/类
/**
 * 注册模块到zk节点
 */
private static void registerZooKeeper() throws Exception{
	if("true".equalsIgnoreCase(PropertyLoader.ZOOKEEPER_ENABLED)){
		LOG.info("regist zookeeper ...."+PropertyLoader.ZOOKEEPER_HOST);
		ZookeeperExcutor zke=new ZookeeperExcutor(PropertyLoader.ZOOKEEPER_HOST,
				PropertyLoader.ZOOKEEPER_OUT_TIME, PropertyLoader.ZOOKEEPER_OUT_TIME);

		//创建模块根节点
		if(null==zke.getClient().checkExists().forPath(PropertyLoader.ZOOKEEPER_ROOT)){
			zke.getClient().create().creatingParentsIfNeeded().forPath(PropertyLoader.ZOOKEEPER_ROOT);
		}
		if(null==zke.getClient().checkExists().forPath(PropertyLoader.ZOOKEEPER_ROOT+"/scheduler")){
			zke.getClient().create().creatingParentsIfNeeded().forPath(PropertyLoader.ZOOKEEPER_ROOT+"/scheduler");
		}

		//创建节点
		String nodeName=zke.createNode(PropertyLoader.ZOOKEEPER_ROOT+"/scheduler/", "");
		if(null!=nodeName){
			//添加创建的节点监听，断线重连
			zke.addListener(PropertyLoader.ZOOKEEPER_ROOT+"/scheduler/", "");
		}
		LOG.info("registerZooKeeper success!");
	}
}

开发者ID:elves-project，项目名称:scheduler，代码行数:27，代码来源:ProgramEntrance.java

示例2: startSchedulerThriftService

import cn.gyyx.elves.util.mq.PropertyLoader; //导入依赖的package包/类
/**
 * @Title: startSchedulerThriftService
 * @Description: 开启scheduler 同步、异步调用服务
 * @return void 返回类型
 */
private static void startSchedulerThriftService() {
	LOG.info("start scheduler thrift service....");
	new Thread() {
		@Override
		public void run(){
			try {
				SchedulerServiceImpl schedulerServiceImpl =  SpringUtil.getBean(SchedulerServiceImpl.class); 
				TProcessor tprocessor = new SchedulerService.Processor<SchedulerService.Iface>(schedulerServiceImpl);
				TServerSocket serverTransport = new TServerSocket(PropertyLoader.THRIFT_SCHEDULER_PORT);
				TThreadPoolServer.Args ttpsArgs = new TThreadPoolServer.Args(serverTransport);
				ttpsArgs.processor(tprocessor);
				ttpsArgs.protocolFactory(new TBinaryProtocol.Factory());
				//线程池服务模型，使用标准的阻塞式IO，预先创建一组线程处理请求。
				TServer server = new TThreadPoolServer(ttpsArgs);
				server.serve();
			} catch (Exception e) {
				LOG.error("start scheduler thrift service error,msg:"+ExceptionUtil.getStackTraceAsString(e));
			}
		}
	}.start();
	LOG.info("start scheduler thrift server success!");
}

开发者ID:elves-project，项目名称:scheduler，代码行数:28，代码来源:ProgramEntrance.java

示例3: contextInitialized

import cn.gyyx.elves.util.mq.PropertyLoader; //导入依赖的package包/类
@Override
	public void contextInitialized(ServletContextEvent event) {
		//设置conf.properties 文件路径
//		String openapiPath=System.getProperty("OPENAPI_PATH");
//		if(StringUtils.isBlank(openapiPath)){
//			throw new RuntimeException("get system properties fail,key is opeanapi-path");
//		}

        ServletContext context = event.getServletContext();
        ApplicationContext ctx = WebApplicationContextUtils.getRequiredWebApplicationContext(context);
        SpringUtil.app=ctx;

		if("true".equalsIgnoreCase(PropertyLoader.ZOOKEEPER_ENABLED)){
			try {
				ZookeeperExcutor zke=new ZookeeperExcutor(PropertyLoader.ZOOKEEPER_HOST,
						PropertyLoader.ZOOKEEPER_OUT_TIME, PropertyLoader.ZOOKEEPER_OUT_TIME);

				//创建模块根节点
				if(null==zke.getClient().checkExists().forPath(PropertyLoader.ZOOKEEPER_ROOT)){
					zke.getClient().create().creatingParentsIfNeeded().forPath(PropertyLoader.ZOOKEEPER_ROOT);
				}
				if(null==zke.getClient().checkExists().forPath(PropertyLoader.ZOOKEEPER_ROOT+"/openapi")){
					zke.getClient().create().creatingParentsIfNeeded().forPath(PropertyLoader.ZOOKEEPER_ROOT+"/openapi");
				}

				String nodeName=zke.createNode(PropertyLoader.ZOOKEEPER_ROOT+"/openapi/", "");
				if(null!=nodeName){
					zke.addListener(PropertyLoader.ZOOKEEPER_ROOT+"/openapi/", "");
					LOG.info("register zookeeper openapi node success");
				}
			}catch (Exception e){
				LOG.error("register zookeeper openapi node fail , msg:"+ ExceptionUtil.getStackTraceAsString(e));
			}

		}
		
		
	}

开发者ID:elves-project，项目名称:openapi，代码行数:39，代码来源:zookeeperEnrollListener.java

示例4: doFilter

import cn.gyyx.elves.util.mq.PropertyLoader; //导入依赖的package包/类
/**
 * 过滤方法
 */
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
	Map<String, Object> map = new HashMap<String, Object>();
	if (!"true".equalsIgnoreCase((PropertyLoader.CRON_ENABLED))) {
		map.put("flag", "false");
		map.put("error", Errorcode.ERR402_2.getValue());
		PrintWriter out = response.getWriter();
		out.write(JSON.toJSONString(map));
		out.close();
	}else{
		chain.doFilter(request, response);
	}
}

开发者ID:elves-project，项目名称:openapi，代码行数:17，代码来源:CronFilter.java

示例5: doFilter

import cn.gyyx.elves.util.mq.PropertyLoader; //导入依赖的package包/类
/**
 * 过滤方法
 */
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
	Map<String, Object> map = new HashMap<String, Object>();
	if (!"supervisor".equalsIgnoreCase(PropertyLoader.AUTH_MODE)) {
		map.put("flag", "false");
		map.put("error", Errorcode.ERR402_1.getValue());
		PrintWriter out = response.getWriter();
		out.write(JSON.toJSONString(map));
		out.close();
	}else{
		chain.doFilter(request, response);
	}
}

开发者ID:elves-project，项目名称:openapi，代码行数:17，代码来源:InfoFilter.java

示例6: doFilter

import cn.gyyx.elves.util.mq.PropertyLoader; //导入依赖的package包/类
/**
 * 过滤方法
 */
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
	Map<String, Object> map = new HashMap<String, Object>();
	if (!"true".equalsIgnoreCase((PropertyLoader.QUEUE_ENABLED))) {
		map.put("flag", "false");
		map.put("error", Errorcode.ERR402_3.getValue());
		PrintWriter out = response.getWriter();
		out.write(JSON.toJSONString(map));
		out.close();
	}else{
		chain.doFilter(request, response);
	}
}

开发者ID:elves-project，项目名称:openapi，代码行数:17，代码来源:QueueFilter.java

示例7: syncJob

import cn.gyyx.elves.util.mq.PropertyLoader; //导入依赖的package包/类
@Override
public Map<String, Object> syncJob(Map<String, Object> params){
	LOG.info("elves scheduler reveive sync job , params : "+params);
	Map<String,Object> rs=new HashMap<String,Object>();
	
	String id = SecurityUtil.getUniqueKey();
	
	String ip = params.get("ip")==null?"": params.get("ip").toString().trim();
	String mode = params.get("mode")==null?"":params.get("mode").toString().trim();
	String app = params.get("app")==null?"":params.get("app").toString().trim();
	String func = params.get("func")==null?"":params.get("func").toString().trim();
	String param = params.get("param")==null?"":params.get("param").toString().trim();
	String timeout = params.get("timeout")==null?"":params.get("timeout").toString().trim();
	String proxy = params.get("proxy")==null?"":params.get("proxy").toString().trim();
	
	//默认90s
	int outTime = 90;
	if(StringUtils.isNotBlank(timeout)){
		outTime = Integer.parseInt(timeout);
	}
	
	Instruct ins=new Instruct(id, ip, "rt", mode, app, func, param, outTime, proxy);
	Reinstruct back=sendDataSync(ip,outTime*1000+PropertyLoader.THRIFT_OUT_TIME, ins);
	LOG.info("sync job send to agent return data ："+back);
	if(null!=back){
		Map<String,Object> data=new HashMap<String,Object>();
		data.put("id",id);
		data.put("worker_flag",back.getFlag());
		data.put("worker_message",  back.getResult()==null?"":back.getResult());
		data.put("worker_costtime", back.getCosttime());
		
		rs.put("flag","true");
		rs.put("error","");
		rs.put("result",data);
	}else{
		rs.put("flag", "false");
		rs.put("error", "[410.0]Send Job To Agent Fail");
	}
	return rs;
}

开发者ID:elves-project，项目名称:scheduler，代码行数:41，代码来源:SchedulerServiceImpl.java

示例8: contextInitialized

import cn.gyyx.elves.util.mq.PropertyLoader; //导入依赖的package包/类
public void contextInitialized(ServletContextEvent event) {
	ServletContext context = event.getServletContext();
	ApplicationContext ctx = WebApplicationContextUtils.getRequiredWebApplicationContext(context);
	SpringUtil.app=ctx;
	LOG.info("WebApplicationContext listener start ,ctx :" + ctx);

	if("true".equalsIgnoreCase(PropertyLoader.ZOOKEEPER_ENABLED)){
		try {
			ZookeeperExcutor zke=new ZookeeperExcutor(PropertyLoader.ZOOKEEPER_HOST,
					PropertyLoader.ZOOKEEPER_OUT_TIME, PropertyLoader.ZOOKEEPER_OUT_TIME);

			//创建模块根节点
			if(null==zke.getClient().checkExists().forPath(PropertyLoader.ZOOKEEPER_ROOT)){
				zke.getClient().create().creatingParentsIfNeeded().forPath(PropertyLoader.ZOOKEEPER_ROOT);
			}
			if(null==zke.getClient().checkExists().forPath(PropertyLoader.ZOOKEEPER_ROOT+"/supervisor")){
				zke.getClient().create().creatingParentsIfNeeded().forPath(PropertyLoader.ZOOKEEPER_ROOT+"/supervisor");
			}

			String nodeName=zke.createNode(PropertyLoader.ZOOKEEPER_ROOT+"/supervisor/", "");
			if(null!=nodeName){
				zke.addListener(PropertyLoader.ZOOKEEPER_ROOT+"/supervisor/", "");
				LOG.info("register zookeeper supervisor node success");
			}
		}catch (Exception e){
			LOG.error("register zookeeper supervisor node fail , msg:"+ ExceptionUtil.getStackTraceAsString(e));
		}

	}
}

开发者ID:elves-project，项目名称:supervisor，代码行数:31，代码来源:SpringContextLoaderListener.java

示例9: getAgentsDetail

import cn.gyyx.elves.util.mq.PropertyLoader; //导入依赖的package包/类
/**
 * 获取AGENT详情
 */
@RequestMapping(value="/agents/detail",method= {RequestMethod.POST,RequestMethod.GET})
@ResponseBody
public String getAgentsDetail(String ip,String showcron){
	LOG.info("request /api/v2/info/agents/detail start");
	Map<String,Object>  result = new HashMap<String, Object>();
	result.put("flag", "false");
	if("true".equals(showcron)&&!"true".equalsIgnoreCase((PropertyLoader.CRON_ENABLED))){
		result.put("error", Errorcode.ERR402_2.getValue());
		return JSON.toJSONString(result,JsonFilter.filter);
	}
	if(StringUtils.isEmpty(ip)){
		result.put("error", Errorcode.ERR403_1.getValue());
		return JSON.toJSONString(result,JsonFilter.filter);
	}
	try{
		Map<String,Object>  mqrequest = new HashMap<String, Object>();
		mqrequest.put("ip",ip );
		Map<String,Object> heartBeatBackResult = messageProducer.call("openapi.heartbeat","agentInfo", mqrequest, 5000);
		if(!"true".equals(heartBeatBackResult.get("flag"))){
			return JSON.toJSONString(result,JsonFilter.filter);
		}
		Map<String,Object> agentInfo = JSON.parseObject(heartBeatBackResult.get("result").toString(), new TypeReference<Map<String,Object>>(){});
		agentInfo.remove("apps");
		if("true".equals(showcron)){
			Map<String,Object>  mqcrequest = new HashMap<String, Object>();
			mqcrequest.put("ip",ip);
			Map<String,Object> cronBackResult=messageProducer.call("openapi.cron","cronList", mqcrequest, 5000);
			if(!"true".equals(cronBackResult.get("flag"))){
				return JSON.toJSONString(result,JsonFilter.filter);
			}
			List<String> cronList = JSON.parseObject(cronBackResult.get("result").toString(), new TypeReference<List<String>>(){});
			agentInfo.put("cron_list", cronList);
		}
		result.put("flag", "true");
		result.put("error", "");
		result.put("result", agentInfo);
	}catch(Exception e){
		result.put("flag", "false");
		result.put("error", Errorcode.ERR500.getValue()+",openapi try/catch:"+ExceptionUtil.getStackTraceAsString(e));
	}
	return JSON.toJSONString(result,JsonFilter.filter);
}

开发者ID:elves-project，项目名称:openapi，代码行数:46，代码来源:InfoWebService.java

注：本文中的cn.gyyx.elves.util.mq.PropertyLoader类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。