| ///* |
| // * Licensed to the Apache Software Foundation (ASF) under one or more |
| // * contributor license agreements. See the NOTICE file distributed with |
| // * this work for additional information regarding copyright ownership. |
| // * The ASF licenses this file to You under the Apache License, Version 2.0 |
| // * (the "License"); you may not use this file except in compliance with |
| // * the License. You may obtain a copy of the License at |
| // * |
| // * http://www.apache.org/licenses/LICENSE-2.0 |
| // * |
| // * Unless required by applicable law or agreed to in writing, software |
| // * distributed under the License is distributed on an "AS IS" BASIS, |
| // * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // * See the License for the specific language governing permissions and |
| // * limitations under the License. |
| // */ |
| //package org.apache.dubbo.admin.web.mvc.governance; |
| // |
| //import com.alibaba.dubbo.common.utils.CollectionUtils; |
| //import org.apache.dubbo.admin.governance.service.OverrideService; |
| //import org.apache.dubbo.admin.governance.service.ProviderService; |
| //import org.apache.dubbo.admin.registry.common.domain.Provider; |
| //import org.apache.dubbo.admin.registry.common.domain.Weight; |
| //import org.apache.dubbo.admin.registry.common.util.OverrideUtils; |
| //import org.apache.dubbo.admin.web.mvc.BaseController; |
| //import org.apache.dubbo.admin.web.pulltool.Tool; |
| //import org.apache.commons.lang3.StringUtils; |
| //import org.apache.commons.lang3.math.NumberUtils; |
| //import org.springframework.beans.factory.annotation.Autowired; |
| //import org.springframework.stereotype.Controller; |
| //import org.springframework.ui.Model; |
| //import org.springframework.validation.support.BindingAwareModelMap; |
| //import org.springframework.web.bind.annotation.RequestMapping; |
| //import org.springframework.web.bind.annotation.RequestMethod; |
| //import org.springframework.web.bind.annotation.RequestParam; |
| // |
| //import javax.servlet.http.HttpServletRequest; |
| //import javax.servlet.http.HttpServletResponse; |
| //import java.io.BufferedReader; |
| //import java.io.StringReader; |
| //import java.util.ArrayList; |
| //import java.util.HashSet; |
| //import java.util.List; |
| //import java.util.Set; |
| //import java.util.regex.Pattern; |
| // |
| ///** |
| // * ProvidersController. |
| // * URI: /services/$service/weights |
| // * |
| // */ |
| //@Controller |
| //@RequestMapping("/governance/weights") |
| //public class WeightsController extends BaseController { |
| // |
| // private static final Pattern IP_PATTERN = Pattern.compile("\\d{1,3}(\\.\\d{1,3}){3}$"); |
| // private static final Pattern LOCAL_IP_PATTERN = Pattern.compile("127(\\.\\d{1,3}){3}$"); |
| // private static final Pattern ALL_IP_PATTERN = Pattern.compile("0{1,3}(\\.0{1,3}){3}$"); |
| // @Autowired |
| // private OverrideService overrideService; |
| // @Autowired |
| // private ProviderService providerService; |
| // |
| // @RequestMapping("") |
| // public String index(HttpServletRequest request, HttpServletResponse response, Model model) { |
| // prepare(request, response, model, "index", "weights"); |
| // BindingAwareModelMap newModel = (BindingAwareModelMap)model; |
| // String service = (String)newModel.get("service"); |
| // String address = (String)newModel.get("address"); |
| // service = StringUtils.trimToNull(service); |
| // address = Tool.getIP(address); |
| // List<Weight> weights; |
| // if (service != null && service.length() > 0) { |
| // weights = OverrideUtils.overridesToWeights(overrideService.findByService(service)); |
| // } else if (address != null && address.length() > 0) { |
| // weights = OverrideUtils.overridesToWeights(overrideService.findByAddress(address)); |
| // } else { |
| // weights = OverrideUtils.overridesToWeights(overrideService.findAll()); |
| // } |
| // model.addAttribute("weights", weights); |
| // return "governance/screen/weights/index"; |
| // } |
| // |
| // /** |
| // * load page for the adding |
| // * |
| // */ |
| // @RequestMapping("/add") |
| // public String add(HttpServletRequest request, HttpServletResponse response, Model model) { |
| // prepare(request, response, model, "add", "weights"); |
| // BindingAwareModelMap newModel = (BindingAwareModelMap)model; |
| // String service = (String)newModel.get("service"); |
| // String input = request.getParameter("input"); |
| // if (service != null && service.length() > 0 && !service.contains("*")) { |
| // List<Provider> providerList = providerService.findByService(service); |
| // List<String> addressList = new ArrayList<String>(); |
| // for (Provider provider : providerList) { |
| // addressList.add(provider.getUrl().split("://")[1].split("/")[0]); |
| // } |
| // model.addAttribute("addressList", addressList); |
| // model.addAttribute("service", service); |
| // model.addAttribute("methods", CollectionUtils.sort(providerService.findMethodsByService(service))); |
| // } else { |
| // List<String> serviceList = Tool.sortSimpleName(providerService.findServices()); |
| // model.addAttribute("serviceList", serviceList); |
| // } |
| // if (input != null) model.addAttribute("input", input); |
| // return "governance/screen/weights/add"; |
| // } |
| // |
| // |
| // @RequestMapping("/create") |
| // public String create(HttpServletRequest request, HttpServletResponse response, Model model) throws Exception { |
| // prepare(request, response, model, "create", "weights"); |
| // String addr = request.getParameter("address"); |
| // String services = request.getParameter("multiservice"); |
| // if (services == null || services.trim().length() == 0) { |
| // services = request.getParameter("service"); |
| // } |
| // String weight = request.getParameter("weight"); |
| // |
| // int w = Integer.parseInt(weight); |
| // |
| // Set<String> addresses = new HashSet<String>(); |
| // BufferedReader reader = new BufferedReader(new StringReader(addr)); |
| // while (true) { |
| // String line = reader.readLine(); |
| // if (null == line) |
| // break; |
| // |
| // String[] split = line.split("[\\s,;]+"); |
| // for (String s : split) { |
| // if (s.length() == 0) |
| // continue; |
| // |
| // String ip = s; |
| // String port = null; |
| // if (s.indexOf(":") != -1) { |
| // ip = s.substring(0, s.indexOf(":")); |
| // port = s.substring(s.indexOf(":") + 1, s.length()); |
| // if (port.trim().length() == 0) port = null; |
| // } |
| // if (!IP_PATTERN.matcher(ip).matches()) { |
| // model.addAttribute("message", "illegal IP: " + s); |
| // model.addAttribute("success", false); |
| // model.addAttribute("redirect", "../weights"); |
| // return "governance/screen/redirect"; |
| // } |
| // if (LOCAL_IP_PATTERN.matcher(ip).matches() || ALL_IP_PATTERN.matcher(ip).matches()) { |
| // model.addAttribute("message", "local IP or any host ip is illegal: " + s); |
| // model.addAttribute("success", false); |
| // model.addAttribute("redirect", "../weights"); |
| // return "governance/screen/redirect"; |
| // } |
| // if (port != null) { |
| // if (!NumberUtils.isDigits(port)) { |
| // model.addAttribute("message", "illegal port: " + s); |
| // model.addAttribute("success", false); |
| // model.addAttribute("redirect", "../weights"); |
| // return "governance/screen/redirect"; |
| // } |
| // } |
| // addresses.add(s); |
| // } |
| // } |
| // |
| // Set<String> aimServices = new HashSet<String>(); |
| // reader = new BufferedReader(new StringReader(services)); |
| // while (true) { |
| // String line = reader.readLine(); |
| // if (null == line) |
| // break; |
| // |
| // String[] split = line.split("[\\s,;]+"); |
| // for (String s : split) { |
| // if (s.length() == 0) |
| // continue; |
| // if (!super.currentUser.hasServicePrivilege(s)) { |
| // model.addAttribute("message", getMessage("HaveNoServicePrivilege", s)); |
| // model.addAttribute("success", false); |
| // model.addAttribute("redirect", "../weights"); |
| // return "governance/screen/redirect"; |
| // } |
| // aimServices.add(s); |
| // } |
| // } |
| // |
| // for (String aimService : aimServices) { |
| // for (String a : addresses) { |
| // Weight wt = new Weight(); |
| // wt.setUsername((String) ((BindingAwareModelMap)model).get("operator")); |
| // wt.setAddress(Tool.getIP(a)); |
| // wt.setService(aimService); |
| // wt.setWeight(w); |
| // overrideService.saveOverride(OverrideUtils.weightToOverride(wt)); |
| // } |
| // } |
| // model.addAttribute("success", true); |
| // model.addAttribute("redirect", "../weights"); |
| // return "governance/screen/redirect"; |
| // } |
| // |
| // @RequestMapping("/edit") |
| // public String edit(@RequestParam("id") Long id, HttpServletRequest request, HttpServletResponse response, Model model) { |
| // prepare(request, response, model, "edit", "weights"); |
| // String service = request.getParameter("service"); |
| // String input = request.getParameter("input"); |
| // |
| // if (service != null && service.length() > 0 && !service.contains("*")) { |
| // List<Provider> providerList = providerService.findByService(service); |
| // List<String> addressList = new ArrayList<String>(); |
| // for (Provider provider : providerList) { |
| // addressList.add(provider.getUrl().split("://")[1].split("/")[0]); |
| // } |
| // model.addAttribute("addressList", addressList); |
| // model.addAttribute("service", service); |
| // model.addAttribute("methods", CollectionUtils.sort(providerService.findMethodsByService(service))); |
| // } else { |
| // List<String> serviceList = Tool.sortSimpleName(providerService.findServices()); |
| // model.addAttribute("serviceList", serviceList); |
| // } |
| // if (input != null) model.addAttribute("input", input); |
| // Weight weight = OverrideUtils.overrideToWeight(overrideService.findById(id)); |
| // model.addAttribute("weight", weight); |
| // model.addAttribute("service", overrideService.findById(id).getService()); |
| // return "governance/screen/weights/edit"; |
| // } |
| // |
| // /** |
| // * load weight for editing |
| // * |
| // * @param id |
| // |
| // */ |
| // @RequestMapping("/detail") |
| // public String show(@RequestParam("id") Long id, HttpServletRequest request, HttpServletResponse response, Model model) { |
| // prepare(request, response, model, "show", "weights"); |
| // Weight weight = OverrideUtils.overrideToWeight(overrideService.findById(id)); |
| // model.addAttribute("weight", weight); |
| // return "governance/screen/weights/show"; |
| // } |
| // |
| // @RequestMapping(value = "/update", method = RequestMethod.POST) //post |
| // public String update(Weight weight, HttpServletRequest request, HttpServletResponse response, Model model) { |
| // prepare(request, response, model, "update", "weights"); |
| // boolean success = true; |
| // if (!super.currentUser.hasServicePrivilege(weight.getService())) { |
| // model.addAttribute("message", getMessage("HaveNoServicePrivilege", weight.getService())); |
| // success = false; |
| // } else { |
| // weight.setAddress(Tool.getIP(weight.getAddress())); |
| // overrideService.updateOverride(OverrideUtils.weightToOverride(weight)); |
| // } |
| // model.addAttribute("success", success); |
| // model.addAttribute("redirect", "governance/weights"); |
| // return "governance/screen/redirect"; |
| // } |
| // |
| // /** |
| // * delete |
| // * |
| // * @param ids |
| // * @return |
| // */ |
| // @RequestMapping("/delete") |
| // public String delete(@RequestParam("ids") Long[] ids, HttpServletRequest request, HttpServletResponse response, Model model) { |
| // prepare(request, response, model, "delete", "weights"); |
| // boolean success = true; |
| // for (Long id : ids) { |
| // Weight w = OverrideUtils.overrideToWeight(overrideService.findById(id)); |
| // if (!super.currentUser.hasServicePrivilege(w.getService())) { |
| // model.addAttribute("message", getMessage("HaveNoServicePrivilege", w.getService())); |
| // success = false; |
| // model.addAttribute("success", success); |
| // model.addAttribute("redirect", "../../weights"); |
| // return "governance/screen/redirect"; |
| // } |
| // } |
| // |
| // for (Long id : ids) { |
| // overrideService.deleteOverride(id); |
| // } |
| // model.addAttribute("success", success); |
| // model.addAttribute("redirect", "../../weights"); |
| // return "governance/screen/redirect"; |
| // } |
| // |
| //} |
