精华内容
下载资源
问答
  • 表单不能正确处理中文的问题 , 虽然 application/x-www-form-urlencoded 编码下可以正确处理中文 .     纠正本问题需要提供 :Maven,Ant 两个工具以及 Turbine 源码 .     ...

    Turbineapache 项目中的server-side java技术,位于jakarta子项目,是基于servletweb应用框架.它提供了很多基础服务:访问控制,页面个性化,服务调度,表单确认,xml-rpc格式的web服务等等.可以做为开发面向服务架构应用的基础,因为turbine很容易开发其它服务,并在其服务管理框架下运行.其下一个版本为2.4,它明确使用亚瑟王神剑项目(该项目实现了IOC模式)来管理服务组件。

     

     

    本文描述的场景是:turbine2.31+velocity-1.4+torque-3.1。要解决在该场景下提交编码模式为multipart/form-data的表单不能正确处理中文的问题,虽然application/x-www-form-urlencoded编码下可以正确处理中文.

     

     

    纠正本问题需要提供:Maven,Ant两个工具以及Turbine源码.

     

     

    首先,Turbine的入口servlet Turbine.java中的代码片段,doGet方法:

    目的是看原始的web服务器请求对象(request)是如何被传递入Turbine中的,以及Turbine如何处理request对象.

        public final void doGet(HttpServletRequest req, HttpServletResponse res)

                throws IOException, ServletException

        {

            // set to true if the request is to be redirected by the page

            boolean requestRedirected = false;

     

     

            // Placeholder for the RunData object.

            RunData data = null;

            try

            {

                // Check to make sure that we started up properly.

                if (initFailure != null)

                {

                    throw initFailure;

                }

     

     

                // Get general RunData here...

                // Perform turbine specific initialization below.

     

     

                data = rundataService.getRunData(req, res, getServletConfig());

     

     

                // If this is the first invocation, perform some

                // initialization.  Certain services need RunData to initialize

                // themselves.

                if (firstDoGet)

                {

                    init(data);

                }

     

     

                // set the session timeout if specified in turbine's properties

                // file if this is a new session

                if (data.getSession().isNew())

                {

                    int timeout = configuration.getInt(SESSION_TIMEOUT_KEY,

                                                       SESSION_TIMEOUT_DEFAULT);

     

     

                    if (timeout != SESSION_TIMEOUT_DEFAULT)

                    {

                        data.getSession().setMaxInactiveInterval(timeout);

                    }

                }

     

     

                // Fill in the screen and action variables.

                data.setScreen(data.getParameters().getString(URIConstants.CGI_SCREEN_PARAM));

                data.setAction(data.getParameters().getString(URIConstants.CGI_ACTION_PARAM));

     

     

                // Special case for login and logout, this must happen before the

                // session validator is executed in order either to allow a user to

                // even login, or to ensure that the session validator gets to

                // mandate its page selection policy for non-logged in users

                // after the logout has taken place.

                if (data.hasAction())

                {

                    String action = data.getAction();

                    log.debug("action = " + action);

     

     

                    if (action.equalsIgnoreCase(

                            configuration.getString(ACTION_LOGIN_KEY,

                                                    ACTION_LOGIN_DEFAULT)))

                    {

                        loginAction(data);

                    }

                    else if (action.equalsIgnoreCase(

                            configuration.getString(ACTION_LOGOUT_KEY,

                                                    ACTION_LOGOUT_DEFAULT)))

                    {

                       logoutAction(data);

                    }

                }

     

     

                // This is where the validation of the Session information

                // is performed if the user has not logged in yet, then

                // the screen is set to be Login. This also handles the

                // case of not having a screen defined by also setting the

                // screen to Login. If you want people to go to another

                // screen other than Login, you need to change that within

                // TurbineResources.properties...screen.homepage; or, you

                // can specify your own SessionValidator action.

                ActionLoader.getInstance().exec(

                        data, configuration.getString(ACTION_SESSION_VALIDATOR_KEY,

                            ACTION_SESSION_VALIDATOR_DEFAULT));

     

     

                // Put the Access Control List into the RunData object, so

                // it is easily available to modules.  It is also placed

                // into the session for serialization.  Modules can null

                // out the ACL to force it to be rebuilt based on more

                // information.

                ActionLoader.getInstance().exec(

                        data, configuration.getString(ACTION_ACCESS_CONTROLLER_KEY,

                            ACTION_ACCESS_CONTROLLER_DEFAULT));

     

     

                // Start the execution phase. DefaultPage will execute the

                // appropriate action as well as get the Layout from the

                // Screen and then execute that. The Layout is then

                // responsible for executing the Navigation and Screen

                // modules.

                //

                // Note that by default, this cannot be overridden from

                // parameters passed in via post/query data. This is for

                // security purposes.  You should really never need more

                // than just the default page.  If you do, add logic to

                // DefaultPage to do what you want.

     

     

                String defaultPage = (templateService == null)

                        ? null :templateService.getDefaultPageName(data);

     

     

                if (defaultPage == null)

                {

                    /*

                     * In this case none of the template services are running.

                     * The application may be using ECS for views, or a

                     * decendent of RawScreen is trying to produce output.

                     * If there is a 'page.default' property in the TR.props

                     * then use that, otherwise return DefaultPage which will

                     * handle ECS view scenerios and RawScreen scenerios. The

                     * app developer can still specify the 'page.default'

                     * if they wish but the DefaultPage should work in

                     * most cases.

                     */

                    defaultPage = configuration.getString(PAGE_DEFAULT_KEY,

                            PAGE_DEFAULT_DEFAULT);

                }

     

     

                PageLoader.getInstance().exec(data, defaultPage);

     

     

                // If a module has set data.acl = null, remove acl from

                // the session.

                if (data.getACL() == null)

                {

                    try

                    {

                        data.getSession().removeAttribute(

                                AccessControlList.SESSION_KEY);

                    }

                    catch (IllegalStateException ignored)

                    {

                    }

                }

     

     

                // handle a redirect request

                requestRedirected = ((data.getRedirectURI() != null)

                                     && (data.getRedirectURI().length() > 0));

                if (requestRedirected)

                {

                    if (data.getResponse().isCommitted())

                    {

                        requestRedirected = false;

                        log.warn("redirect requested, response already committed: " +

                                 data.getRedirectURI());

                    }

                    else

                    {

                        data.getResponse().sendRedirect(data.getRedirectURI());

                    }

                }

     

     

                if (!requestRedirected)

                {

                    try

                    {

                        if (data.isPageSet() == false && data.isOutSet() == false)

                        {

                            throw new Exception("Nothing to output");

                        }

     

     

                        // We are all done! if isPageSet() output that way

                        // otherwise, data.getOut() has already been written

                        // to the data.getOut().close() happens below in the

                        // finally.

                        if (data.isPageSet() && data.isOutSet() == false)

                        {

                            // Modules can override these.

                            data.getResponse().setLocale(data.getLocale());

                            data.getResponse().setContentType(

                                    data.getContentType());

     

     

                            // Set the status code.

                            data.getResponse().setStatus(data.getStatusCode());

                            // Output the Page.

                            data.getPage().output(data.getOut());

                        }

                    }

                    catch (Exception e)

                    {

                        // The output stream was probably closed by the client

                        // end of things ie: the client clicked the Stop

                        // button on the browser, so ignore any errors that

                        // result.

                        log.debug("Output stream closed? ", e);

                    }

                }

            }

            catch (Exception e)

            {

                handleException(data, res, e);

            }

            catch (Throwable t)

            {

                handleException(data, res, t);

            }

            finally

            {

                // Return the used RunData to the factory for recycling.

                rundataService.putRunData(data);

            }

    }

     

     

    以及org.apache.turbine.services.rundata.TurbineRunDataService中的:

    public RunData getRunData(HttpServletRequest req,

                                  HttpServletResponse res,

                                  ServletConfig config)

                throws TurbineException

        {

            return getRunData(DEFAULT_CONFIG, req, res, config);

        }

     

     

        /**

         * Gets a RunData instance from a specific configuration.

         *

         * @param key a configuration key.

         * @param req a servlet request.

         * @param res a servlet response.

         * @param config a servlet config.

         * @return a new or recycled RunData object.

         * @throws TurbineException if the operation fails.

         * @throws IllegalArgumentException if any of the parameters are null.

         */

        public RunData getRunData(String key,

                                  HttpServletRequest req,

                                  HttpServletResponse res,

                                  ServletConfig config)

                throws TurbineException,

                IllegalArgumentException

        {

            // The RunData object caches all the information that is needed for

            // the execution lifetime of a single request. A RunData object

            // is created/recycled for each and every request and is passed

            // to each and every module. Since each thread has its own RunData

            // object, it is not necessary to perform syncronization for

            // the data within this object.

            if ((req == null)

                || (res == null)

                || (config == null))

            {

                throw new IllegalArgumentException("HttpServletRequest, "

                    + "HttpServletResponse or ServletConfig was null.");

            }

     

     

            // Get the specified configuration.

            String[] cfg = (String[]) configurations.get(key);

            if (cfg == null)

            {

                throw new TurbineException("RunTime configuration '" + key + "' is undefined");

            }

     

     

            TurbineRunData data;

            try

            {

                data = (TurbineRunData) pool.getInstance(cfg[0]);

                data.setParameterParser((ParameterParser) pool.getInstance(cfg[1]));

                data.setCookieParser((CookieParser) pool.getInstance(cfg[2]));

            }

            catch (ClassCastException x)

            {

                throw new TurbineException("RunData configuration '" + key + "' is illegal", x);

            }

     

     

            // Set the request and response.

            data.setRequest(req);

            data.setResponse(res);

     

     

            // Set the servlet configuration.

            data.setServletConfig(config);

     

     

            // Set the ServerData.

            data.setServerData(new ServerData(req));

     

     

            return data;

        }

     

     

    org.apache.turbine.services.rundata.DefaultTurbineRunData中的:

        /**

         * Sets the servlet request.

         *

         * @param req a request.

         */

        public void setRequest(HttpServletRequest req)

        {

            this.req = req;

        }

     

     

        /**

         * Sets the servlet response.

         *

         * @param res a response.

         */

        public void setResponse(HttpServletResponse res)

        {

            this.res = res;

        }

     

     

    在该类中request对象被不加修改的传递到了ParameterParser:

        /**

         * Gets the parameters.

         *

         * @return a parameter parser.

         */

        public ParameterParser getParameters()

        {

            // Parse the parameters first, if not yet done.

            if ((this.parameters != null) &&

                    (this.parameters.getRequest() != this.req))

            {

                this.parameters.setRequest(this.req);

            }

            return this.parameters;

        }

     

     

        /**

         * Gets the parameter parser without parsing the parameters.

         *

         * @return the parameter parser.

         */

        public ParameterParser getParameterParser()

        {

            return parameters;

        }

     

     

        /**

         * Sets the parameter parser.

         *

         * @param parser a parameter parser.

         */

        public void setParameterParser(ParameterParser parser)

        {

            parameters = parser;

        }

     

     

    以上类中展示的代码都涉及到了Request对象,从这些代码中看出在Turbine,实际上并没有对Request对象做任何修改,这样就可以按照通常的方法,加入对Request对象的处理代码.最后, 这里是关键的地方:在类DefaultParameterParser中对Request对象的处理,也就是通过对该处的修改,问题得到了解决:

        /**

         * Sets the servlet request to be parser.  This requires a

         * valid HttpServletRequest object.  It will attempt to parse out

         * the GET/POST/PATH_INFO data and store the data into a Map.

         * There are convenience methods for retrieving the data as a

         * number of different datatypes.  The PATH_INFO data must be a

         * URLEncoded() string.

         * <p>

         * To add name/value pairs to this set of parameters, use the

         * <code>add()</code> methods.

         *

         * @param request An HttpServletRequest.

         */

        public void setRequest(HttpServletRequest request)

        {

            clear();

     

     

            uploadData = null;

     

     

            //String enc = request.getCharacterEncoding();

    原来是:

            enc = request.getCharacterEncoding();

    setCharacterEncoding(enc != null ? enc : "US-ASCII");

        修改后:

            if(enc==null)    enc=org.apache.turbine.Turbine.getConfiguration().getString(CharacterEncoding_Key,"US-ASCII");               

            setCharacterEncoding(enc);

            // String object re-use at its best.

            String tmp = null;

     

     

            tmp = request.getHeader("Content-type");

     

     

            if (uploadServiceIsAvailable

                    && uploadService.getAutomatic()

                    && tmp != null

                    && tmp.startsWith("multipart/form-data"))

            {

                log.debug("Running the Turbine Upload Service");

                try

                {

                    TurbineUpload.parseRequest(request, this);

                }

                catch (TurbineException e)

                {

                    log.error("File upload failed", e);

                }

            }

     

     

            for (Enumeration names = request.getParameterNames();

                 names.hasMoreElements();)

            {

                tmp = (String) names.nextElement();

                add(convert(tmp),

                        request.getParameterValues(tmp));

            }

     

     

            // Also cache any pathinfo variables that are passed around as

            // if they are query string data.

            try

            {

                StringTokenizer st =

                        new StringTokenizer(request.getPathInfo(), "/");

                boolean isNameTok = true;

                String pathPart = null;

                while (st.hasMoreTokens())

                {

                    if (isNameTok)

                    {

                        tmp = URLDecoder.decode(st.nextToken());

                        isNameTok = false;

                    }

                    else

                    {

                        pathPart = URLDecoder.decode(st.nextToken());

                        if (tmp.length() > 0)

                        {

                            add(convert(tmp), pathPart);

                        }

                        isNameTok = true;

                    }

                }

            }

            catch (Exception e)

            {

                // If anything goes wrong above, don't worry about it.

                // Chances are that the path info was wrong anyways and

                // things that depend on it being right will fail later

                // and should be caught later.

            }

     

     

            this.request = request;

     

     

            if (log.isDebugEnabled())

            {

                log.debug("Parameters found in the Request:");

                for (Iterator it = keySet().iterator(); it.hasNext();)

                {

                    String key = (String) it.next();

                    log.debug("Key: " + key + " -> " + getString(key));

                }

            }

        }

     

     

    同时在配置文件TurbineResources.properties中加入一项:

    CharacterEncoding=gb2312.可以根据需要修改该值.

     

     

    完成以上修改后,Maven工具重新构建Turbine并得到了新的turbine.jar把它放入你的应用环境中,中文问题即得到正确显示.

       注意:以上代码片段来自Turbine源码.黑体字表示要关注的部分,代码中修改部分则给出了说明.


    原文链接: http://blog.csdn.net/keepeye/article/details/378496

    转载于:https://my.oschina.net/changpinghu/blog/72492

    展开全文
  • 上一篇涨介绍了HystrixDashboard来展示单个实例监测数据,但实际情况中,我们会部署N个微服务,那么不可能再用这种方式一个接着一个输入查看,基于这种场景,Hystrix可以利用Turbine实现数据聚合。对于老司机而...

    上一篇涨介绍了Hystrix的Dashboard来展示单个实例的监测数据,但实际情况中,我们会部署N个微服务,那么不可能再用这种方式一个接着一个输入查看,基于这种场景,Hystrix可以利用Turbine实现数据聚合。对于老司机而言,Turbine这个单词不会陌生,中文意思为涡轮机,所以顾名思义,用来描述聚合很形象。

    (一)创建一个hystrix-turbine监控数据聚合
    新建工程后,子pom.xml文件添加以下依赖:

    <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-turbine</artifactId>
            </dependency>
        </dependencies>
    

    然后创建一个application启动类(需要添加注解@EnableDiscoveryClient查看注册中心的注册服务):

    package com.ningmeng.turbine;
    
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
    import org.springframework.cloud.netflix.turbine.EnableTurbine;
    
    @EnableTurbine // 开启turbine监控数据聚合
    @EnableHystrixDashboard // 开启hystrix仪表盘
    @EnableDiscoveryClient
    @SpringBootApplication
    public class HystrixTurbineApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(HystrixTurbineApplication.class, args);
        }
    }
    
    

    最后配置application.yml文件:

    #工程端口号
    server:
      port: 5002
    
    spring:
      application:
        name: hystrix-turbine #工程名,后面各个服务间调用接口要用到
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest
    #eureka注册中心地址
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/ #eureka服务器所在的地址
    
    #聚合的工程  这里演示聚合ribbon-consumer,feign-consumer这两个消费工程
    turbine:
      aggregator:
        cluster-config: default
      app-config: ribbon-consumer,feign-consumer
      cluster-name-expression: new String("default")
    

    注意:new String(“default”)必须这么写,否则启动的时候会抛出异常org.springframework.expression.spel.SpelEvaluationException: EL1008E: Property or field ‘default‘ cannot be found on object of type ‘com.netflix.appinfo.InstanceInfo‘ - maybe not public or not valid?

    参数说明:
    turbine.aggregator.cluster-config参数设定cluster名字,当使用default,默认聚合turbine.appConfig中设定的所有服务名的数据;
    turbine.app-config参数设定需要收集监控信息的服务名;
    turbine.cluster-name-expression 参数指定了集群名称为 default,当我们服务数量非常多的时候,可以启动多个 Turbine 服务来构建不同的聚合集群,而该参数可以用来区分这些不同的聚合集群,同时该参数值可以在 Hystrix 仪表盘中用来定位不同的聚合集群,只需要在 Hystrix Stream 的 URL 中通过 cluster 参数来指定。

    最后依次启动eureka-server、service-provider(两个实例)、feign-consumer、ribbon-consumer以及hystrix-turbine工程,然后访问http://localhost:5002/hystrix,可看到页面:
    在这里插入图片描述
    我们能通过红色框中的两种方式查看监控聚合数据(注意与bashboard监控面板的区别,turbine拼接的是turbine-hostname:port(即hystrix-turbine的ip以及端口号),bashboard拼接的是hystrix-app:port(即调用服务的消费工程的ip以及端口号,比如ribbon-consumer或者feign-consumer))

    第一种方式:直接输入http://localhost:5002/turbine.stream,然后假如处于loading状态,我们先调用服务,之后能看到以下内容:
    在这里插入图片描述

    第二种方式在输入url后拼接cluster(即turbine.aggregator.cluster-config的值):
    修改application.yml配置文件:

    #工程端口号
    server:
      port: 5002
    
    spring:
      application:
        name: hystrix-turbine #工程名,后面各个服务间调用接口要用到
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest
    #eureka注册中心地址
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/ #eureka服务器所在的地址
    
    #聚合的工程  这里演示聚合ribbon-consumer,feign-consumer这两个消费工程
    turbine:
      aggregator:
        cluster-config: FEIGN-CONSUMER
      app-config: feign-consumer
    #  cluster-name-expression: new String("default")
    

    参数说明:cluster-config配置的名称必须为eureka注册中心上已经注册的服务名,且为大写。

    然后访问http://localhost:5002/turbine.stream?cluster=FEIGN-CONSUMER,cluster参数必须与turbine.aggregator.cluster-config中的条目匹配,只能看到feign-consumer服务的监控数据:
    在这里插入图片描述

    本篇完结!

    github代码地址:https://github.com/huijunzeng/springCloudDemo.git

    展开全文
  •  hystrix对应的中文名字是“豪猪”,豪猪周身长满了刺,能保护自己不受天敌的伤害,代表了一种防御机制,这与hystrix本身的功能不谋而合,因此Netflix团队将该框架命名为Hystrix,并使用了对应的卡通形象做作为logo...

    1.Hystrix断路器简介

    Hystrix断路器简介

      hystrix对应的中文名字是“豪猪”,豪猪周身长满了刺,能保护自己不受天敌的伤害,代表了一种防御机制,这与hystrix本身的功能不谋而合,因此Netflix团队将该框架命名为Hystrix,并使用了对应的卡通形象做作为logo。

      在一个分布式系统里,许多依赖不可避免的会调用失败,比如超时、异常等,如何能够保证在一个依赖出问题的情况下,不会导致整体服务失败,这个就是Hystrix需要做的事情。Hystrix提供了熔断、隔离、Fallback、cache、监控等功能,能够在一个、或多个依赖同时出现问题时保证系统依然可用。

    2.服务雪崩效应

    服务雪崩效应

     

    当一个请求依赖多个服务的时候:

    正常情况下的访问 

    20160423115740944.jpg

     

    但是,当请求的服务中出现无法访问、异常、超时等问题时(图中的I),那么用户的请求将会被阻塞。

    1.jpg

     

     

    如果多个用户的请求中,都存在无法访问的服务,那么他们都将陷入阻塞的状态中。

    2.jpg

     

    Hystrix的引入,可以通过服务熔断和服务降级来解决这个问题。

    3.Hystrix服务熔断服务降级@HystrixCommand fallbackMethod

    Hystrix服务熔断服务降级@HystrixCommand fallbackMethod

     

    熔断机制是应对雪崩效应的一种微服务链路保护机制。

    当某个服务不可用或者响应时间超时,会进行服务降级,进而熔断该节点的服务调用,快速返回自定义的错误影响页面信息。

     

    我们写个项目来测试下;

     

    我们写一个新的带服务熔断的服务提供者项目 microservice-student-provider-hystrix-1004

    把 配置和 代码 都复制一份到这个项目里;

     

    然后修改;

     

    1,pom.xml加下 hystrix支持

    <dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-hystrix</artifactId>

    </dependency>

     

    2,application.yml修改下端口和实例名称

    port: 1004

     instance-id: microservice-student-hystrix:1004 #客户端实例名称

     

    3,启动类名称改成StudentProviderHystrixApplication_1004

    以及加下注解支持 @EnableCircuitBreaker

     

    4,我们在( microservice-student-provider-hystrix-1004)新增方法getInfo

     1  /**
     2  * 获取信息
     3  * @return
     4  * @throws InterruptedException 
     5  */
     6 @ResponseBody
     7 @GetMapping(value="/getInfo")
     8 @HystrixCommand(fallbackMethod="getInfoFallback")
     9 public Map<String,Object> getInfo() throws InterruptedException{
    10     Thread.sleep(2000);
    11     Map<String,Object> map=new HashMap<String,Object>();
    12     map.put("code", 200);
    13     map.put("info", "业务数据xxxxx");
    14     return map;
    15 }
    16  
    17 public Map<String,Object> getInfoFallback() throws InterruptedException{
    18     Map<String,Object> map=new HashMap<String,Object>();
    19     map.put("code", 500);
    20     map.put("info", "系统出错,稍后重试");
    21     return map;
    22 }
    View Code

     

    这里我正常访问 返回的是 200  业务数据xxxxx 

    但是我们这里Thread.sleep(2000) 模拟超时;

    这里的话 我们加上@HystrixCommand注解 以及 fallbackMethod

    表明这个方法我们再 没有异常以及没有超时(hystrix默认1秒算超时)的情况,才返回正常的业务数据;

    否则,进入我们fallback指定的本地方法,我们搞的是500  系统出错,稍后重试,有效的解决雪崩效应,以及返回给用户界面

    很好的报错提示信息;

     

     

    ============================

     

    microservice-student-consumer-80项目也要对应的加个方法

     1 /**
     2  * 熔断器测试方法
     3  * @return
     4  */
     5 @SuppressWarnings("unchecked")
     6 @GetMapping(value="/getInfo")
     7 @ResponseBody
     8 public Map<String,Object> getInfo(){
     9     return restTemplate.getForObject(PRE_HOST+"/student/getInfo/", Map.class);
    10 }
    View Code

    然后我们来测试下;

    先启动三个eureka,再启动带hystrix的provider,最后启动普通的consumer;

    因为 Hystrix默认1算超时,所有 sleep了2秒 所以进入自定义fallback方法,防止服务雪崩;

     

    我们这里改sleep修改成100毫秒;

     

    4.Hystrix默认超时时间设置

    Hystrix默认超时时间设置

     

    Hystrix默认超时时间是1秒,我们可以通过hystrix源码看到,

    找到 hystrix-core.jar com.netflix.hystrix包下的HystrixCommandProperties类

    default_executionTimeoutInMilliseconds属性局势默认的超时时间

    a.jpg

     

    默认1000毫秒 1秒

     

    我们系统里假如要自定义设置hystrix的默认时间的话;

     

    application.yml配置文件加上 

     

    hystrix:

      command:

        default:

          execution:

            isolation:

              thread:

                timeoutInMilliseconds: 3000

     

    修改成3秒  然后 我们代码里sleep修改成2秒测试;

     

    5.Feign Hystrix整合&服务熔断服务降级彻底解耦

    Feign Hystrix整合&服务熔断服务降级彻底解耦

     

    前面的代码,用@HystrixCommand fallbackMethod是很不好的,因为和业务代码耦合度太高,不利于维护,所以需要解耦,这我们讲下Feign Hystrix整合。

     

    第一,microservice-student-provider-hystrix-1004项目修改

    我们不用原先那套。按照正常的逻辑来写;

    StudentService加新的接口方法:

    /**

     * 获取信息
     * @return
     */
    public Map<String,Object> getInfo();
     
    StudentServiceImpl写具体实现:
    @Override
    public Map<String, Object> getInfo() {
        Map<String,Object> map=new HashMap<String,Object>();
        map.put("code"200);
        map.put("info""业务数据xxxxx");
        return map;
    }
    StudentProviderController正常调用service方法:
    /**
     * 获取信息
     * @return
     * @throws InterruptedException 
     */
    @ResponseBody
    @GetMapping(value="/getInfo")
    public Map<String,Object> getInfo() throws InterruptedException{
        Thread.sleep(900);
        return studentService.getInfo();
    }
     

    第二步:microservice-common项目新建FallbackFactory类,解耦服务熔断服务降级

    StudentClientService接口,新增getInfo方法;

    /**

     * 获取信息
     * @return
     */
    @GetMapping(value="/student/getInfo")
    public Map<String,Object> getInfo();
     
    新建 StudentClientFallbackFactory 类,实现FallbackFactory<StudentClientService>接口;
     1 @Component
     2 public class StudentClientFallbackFactory implements FallbackFactory<StudentClientService>{
     3  
     4     @Override
     5     public StudentClientService create(Throwable cause) {
     6         // TODO Auto-generated method stub
     7         return new StudentClientService() {
     8              
     9             @Override
    10             public boolean save(Student student) {
    11                 // TODO Auto-generated method stub
    12                 return false;
    13             }
    14              
    15             @Override
    16             public List<Student> list() {
    17                 // TODO Auto-generated method stub
    18                 return null;
    19             }
    20              
    21             @Override
    22             public Map<String, Object> getInfo() {
    23                 Map<String,Object> map=new HashMap<String,Object>();
    24                 map.put("code", 500);
    25                 map.put("info", "系统出错,稍后重试");
    26                 return map;
    27             }
    28              
    29             @Override
    30             public Student get(Integer id) {
    31                 // TODO Auto-generated method stub
    32                 return null;
    33             }
    34              
    35             @Override
    36             public boolean delete(Integer id) {
    37                 // TODO Auto-generated method stub
    38                 return false;
    39             }
    40         };
    41     }
    42  
    43 }
    View Code

     

    StudentClientService接口的@FeignClient注解加下 fallbackFactory属性 

    @FeignClient(value="MICROSERVICE-STUDENT",fallbackFactory=StudentClientFallbackFactory.class)

     

    这类我们实现了 降级处理方法实现;

    最后测试即可。

    6.Hystrix服务监控Dashboard

    Hystrix服务监控Dashboard仪表盘

     

    Hystrix提供了 准实时的服务调用监控项目Dashboard,能够实时记录通过Hystrix发起的请求执行情况,

    可以通过图表的形式展现给用户看。

     

    我们新建项目:microservice-student-consumer-hystrix-dashboard-90

    加依赖:

     1 <dependency>
     2     <groupId>org.springframework.cloud</groupId>
     3     <artifactId>spring-cloud-starter-hystrix</artifactId>
     4 </dependency>
     5 <dependency>
     6     <groupId>org.springframework.cloud</groupId>
     7     <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
     8 </dependency>
     9 <dependency>
    10     <groupId>org.springframework.boot</groupId>
    11     <artifactId>spring-boot-starter-actuator</artifactId>
    12 </dependency>
    View Code

    application.yml配置

     

    server:

      port: 90

      context-path: /

     

    新建启动类:StudentConsumerDashBoardApplication_90

    加注解:@EnableHystrixDashboard

    1 @SpringBootApplication(exclude={DataSourceAutoConfiguration.class,HibernateJpaAutoConfiguration.class})
    2 @EnableHystrixDashboard
    3 public class StudentConsumerDashBoardApplication_90 {
    4  
    5     public static void main(String[] args) {
    6         SpringApplication.run(StudentConsumerDashBoardApplication_90.class, args);
    7     }
    8 }
    View Code

     

    这样就完事了。

     

    我们启动这个项目;

    然后浏览器输入:http://localhost:90/hystrix

    1234.png

     

     

    出现这个 就说明OK;

     

    然后我们来测试下;

    我们启动三个eureka,然后再启动microservice-student-provider-hystrix-1004

     

    我们直接请求http://localhost:1004/student/getInfo

    返回正常业务

     

    我们监控的话,http://localhost:1004/hystrix.stream 这个路径即可;

     

     

    一直是ping,然后data返回数据;

     

    用图形化的话 

    ca.png

     

    输入 ,然后点击按钮即可;

    14.jpg

     

     

    指标含义:

    qq.png

     

     

    各种情况:

    cc3.jpg

     

     

    7.Hystrix集群监控turbine

    前面Dashboard演示的仅仅是单机服务监控,实际项目基本都是集群,所以这里集群监控用的是turbine。

     

    turbine是基于Dashboard的。

     

    先搞个集群;

    再microservice-student-provider-hystrix-1004项目的基础上再搞一个microservice-student-provider-hystrix-1005

     

    代码和配置都复制一份,然后修改几个地方;

    第一 yml配置 

    server:

      port: 1005

    instance-id: microservice-student-hystrix:1005 #客户端实例名称 

     

    第二 启动类改成StudentProviderHystrixApplication_1005

     

    这样的话 就有了 hystrix集群服务;

     

    我们新建项目microservice-student-consumer-hystrix-turbine-91

    pom.xml加下依赖

    1 <dependency>
    2     <groupId>org.springframework.boot</groupId>
    3     <artifactId>spring-boot-starter-actuator</artifactId>
    4 </dependency>
    5 <dependency>
    6     <groupId>org.springframework.cloud</groupId>
    7     <artifactId>spring-cloud-starter-turbine</artifactId>
    8 </dependency>
    View Code

     

    8.Zuul API路由网关服务简介

    Zuul API路由网关服务简介

     

    QQ鎴浘20181022220910.jpg

     

    请看上图,这里的API 路由网关服务 由Zuul实现,主要就是对外提供服务接口的时候,起到了请求的路由和过滤作用,也因此能够隐藏内部服务的接口细节,从来有利于保护系统的安全性;

    9.SpringCloud Config简介

    SpringCloud Config简介

     

    Spring Cloud Config 是 Spring Cloud 团队创建的一个全新项目,用来为分布式系统中的基础设施和微服务应用提供集中化的外部配置支持,它分为服务端与客户端两个部分。其中服务端也称为分布式配置中心,它是一个独立的微服务应用,用来连接配置仓库并为客户端提供获取配置信息、加密 / 解密信息等访问接口;而客户端则是微服务架构中的各个微服务应用或基础设施,它们通过指定的配置中心来管理应用资源与业务相关的配置内容,并在启动的时候从配置中心获取和加载配置信息。Spring Cloud Config 实现了对服务端和客户端中环境变量和属性配置的抽象映射,所以它除了适用于 Spring 构建的应用程序之外,也可以在任何其他语言运行的应用程序中使用。由于 Spring Cloud Config 实现的配置中心默认采用 Git 来存储配置信息,所以使用 Spring Cloud Config 构建的配置服务器,天然就支持对微服务应用配置信息的版本管理,并且可以通过 Git 客户端工具来方便的管理和访问配置内容。当然它也提供了对其他存储方式的支持,比如:GIT仓库、SVN 仓库、本地化文件系统。

     

    QQ鎴浘20190302203730.jpg

    Config Server端主要和Git/SVN服务器

     

    通俗点,就是统一管理配置,包括方便切换环境配置,以及修改配置无需动代码,省心省力;

     

    如果用上SpringCloud Bus,能实现无需重启,自动感知配置变化以及应用新配置;

     

    QQ鎴浘20190302203742.jpg

     

    10.Config Server基本使用

    Config Server基本使用

     

    根据前面SpringCloud架构图,首先第一步,要搞个 configServer来联通远程GIT仓库,来读取远程配置;

     

    这里GIT仓库,我们一般选用GitHub https://github.com/,或者码云  https://gitee.com/  

    我们课程用GitHub演示,首先大伙去GitHub注册个账号,

     

    建个仓库 microservice-config  然后 Git下载本地;

     

    上传一个配置文件上到git仓库,application.yml 记住要utf-8编码,否则乱码,解析各种问题;

     

    转载于:https://www.cnblogs.com/newAndHui/p/10562102.html

    展开全文
  • velocity中文手册

    2009-02-04 08:56:00
    Velocity能力远不止web站点开发这个领域,例如,它可以从模板(template)产生SQL和PostScript、XML,它也可以被当作一个独立工具来产生源代码和...Velocity+Turbine提供一个模板服务方式允许一个web应用以一个真

     

    Velocity的能力远不止web站点开发这个领域,例如,它可以从模板(template)产生SQL和PostScript、XML,它也可以被当作一个独立工具来产生源代码和报告,或者作为其他系统的集成组件使用。Velocity也可以为Turbine web开发架构提供模板服务(template service)。Velocity+Turbine提供一个模板服务的方式允许一个web应用以一个真正的MVC模型进行开发。

    Velocity能为我们作什么?
    The Mud Store Example
    假设你是一家专门出售Mud的在线商店的页面设计人员,让我们暂且称它为“在线MUD商店”。你们的业务很旺,客户下了各种类型和数量的mud订单。他们都是通过输入用户名和密码后才登陆到你的网站,登陆后就允许他们查看订单并购买更多的mud。现在,一种非常流行的mud正在打折销售。另外有一些客户规律性的购买另外一种也在打折但是不是很流行的Bright Red Mud,由于购买的人并不多所以它被安置在页面的边缘。所有用户的信息都是被跟踪并存放于数据库中的,所以某天有一个问题可能会冒出来:为什么不使用velocity来使用户更好的浏览他们感兴趣的商品呢?
    Velocity使得web页面的客户化工作非常容易。作为一个web site的设计人员,你希望每个用户登陆时都拥有自己的页面。
    你会见了一些公司内的软件工程师,你发现他们每个人都同意客户应该拥有具有个性化的信息。那让我们把软件工程师应该作的事情发在一边,看一看你应该作些什么吧。
    你可能在页面内嵌套如下的VTL声明:
    Java代码 复制代码
    1. <html>   
    2. <body>   
    3. Hello $customer.Name!   
    4. <table>   
    5. #foreach( $mud in $nudsOnSpecial );    
    6. #if ( $customer.hasPurchased( $mud ); );    
    7. <tr><td>$flogger.getPromo( $mud );</td></tr>   
    8. #end   
    9. #end   
    10. </table>  
    <html>
    <body>
    Hello $customer.Name!
    <table>
    #foreach( $mud in $nudsOnSpecial ); 
    #if ( $customer.hasPurchased( $mud ); ); 
    <tr><td>$flogger.getPromo( $mud );</td></tr>
    #end
    #end
    </table>

    Velocity Template Language(VTL):AN introduction
    VTL意味着提供最简单、最容易并且最整洁的方式合并页面动态内容。
    VTL使用references来在web site内嵌套动态内容,一个变量就是一种类型的reference。变量是某种类型的refreence,它可以指向java代码中的定义,或者从当前页面内定义的VTL statement得到值。下面是一个VTL statement的例子,它可以被嵌套到HTML代码中:
    Java代码 复制代码
    1. #set ( $a = “Velocity” );  
     #set ( $a = “Velocity” );

    和所有的VTL statement一样,这个statement以#字符开始并且包含一个directive:set。当一个在线用户请求你的页面时,Velocity Templating Engine将查询整个页面以便发现所有#字符,然后确定哪些是VTL statement,哪些不需要VTL作任何事情。
    #字符后紧跟一个directive:set时,这个set directive使用一个表达式(使用括号封闭)――一个方程式分配一个值给变量。变量被列在左边,而它的值被列在右边,最后他们之间使用=号分割。
    在上面的例子中,变量是$a,而它的值是Velocity。和其他的references一样以$字符开始,而值总是以双引号封闭。Velocity中仅有String可以被赋值给变量。
    记住以下的规则:
    使用$字符开始的references用于得到什么;使用#字符开始的directives用于作些什么。
    Hello Velocity World!
    一旦某个变量被分配了一个值,那么你就可以在HTML文件的任何地方引用它。在下面的例子中,一个值被分配给$foo变量,并在其后被引用。
    <html>
    <body>
    #set ( $foo = “Velocity” )
    Hello $foo World!
    </body>
    </html>
    上面的实现结果是在页面上打印“Hello Velocity World!”
    为了使包含VTL directives的statement更具有可读性,我们鼓励你在新行开始每个VTL statement,尽管你不是必须这么作。Set directive将在后面详细描述。
    注释
    单行注释:
      ## This is a single line comment.
    多行注释:
      #*
       Thus begins a multi-line comment. Online visitors won’t
       see this text because the Velocity Templating Engine will
    ignore it.
      *#
    文档格式:
      #**
       This is a VTL comment block and
       may be used to store such information
    as the document author and versioning
       information:
       @version 5
       @author
      *#

    References
    在VTL中有三种类型的references:变量(variables)、属性(properties)、方法(methods)。作为一个使用VTL的页面设计者,你和你的工程师必须就references的名称达成共识,以便你可以在你的template中使用它们。
    Everything coming to and from a reference被作为一个String对象处理。如果有一个对象$foo是一个Integer对象,那么Velocity将调用它的toString()方法将这个对象转型为String类型。
      变量
      格式要求同java。
      属性
      例子:
        $customer.Address
        $purchase.Total
    $customer.Address有两种含义。它可以表示:查找hashtable对象customer中以Address为关键字的值;也可以表示调用customer对象的getAddress()方法。当你的页面被请求时,Velocity将确定以上两种方式选用那种,然后返回适当的值。
    方法
    一个方法就是被定义在java中的一段代码,并且它有完成某些有用工作的能力,例如一个执行计算和判断条件是否成立、满足等。方法是一个由$开始并跟随VTL标识符组成的References,一般还包括一个VTL方法体。例如:
      $customer.getAddress()
      $purchase.getTotal()
      $page.setTitle( “My Home Page” )
      $person.setAttributes( [“Strange”, “Weird”, “Excited”] )
    前两个例子$customer.getAddress()和$purchase.getTotal()看起来挺想上面的属性$customer.Address 和 $purchase.Total。如果你觉得他们之间有某种联系的话,那你是正确的。
    VTL属性可以作为VTL方法的缩写。$customer.Address属性和使用$customer.getAddress()方法具有相同的效果。如果可能的话使用属性的方式是比较合理的。属性和方法的不同点在于你能够给一个方法指定一个参数列表。
    正式reference标记
    reference的正是格式如下:
      ${mudSlinger}        变量
      ${customer.Address}    属性
      ${purchase.getTotal()}    方法
    非正是格式更见常用,但是有时还是使用正是格式比较适合。例如:你希望通过一个变量$vice来动态的组织一个字符串。
      Jack is a $vicemaniac.
    本来变量是$vice现在却变成了$vicemaniac,这样Veloctiy就不知道您到底要什么了。所以,应该使用正是格式书写
      Jack is a ${vice}maniac
    现在Velocity知道变量是$vice而不是$vicemaniac。
    Quiet reference notation
    例如:
      <input type=”text” name=”email” value=”$email” />
    当页面的form被初始加载时,变量$email还没有值,这时你肯定是希望它能够显示一个blank text来代替输出”$email”这样的字段。那么使用quiet reference notation就比较合适。
      <input type=”text” name=”email” value=”$!email”/>
    这样文本框的初始值就不会是email而是空值了。
    正式和quiet格式的reference notation也可一同使用,像下面这样:
      <input type=”text” name=”email” value=”$!{email}”/>
    Getting literal
    Velocity使用特殊字符$和#来帮助它工作,所以如果要在template里使用这些特殊字符要格外小心。本节将讨论$字符。
      货币字符
    在VTL中使用$2.5这样的货币标识是没有问题得的,VTL不会将它错认为是一个reference,因为VTL中的reference总是以一个大写或者小写的字母开始。
    Escaping valid VTL reference
    VTL中使用“/”作为逃逸符。
    例如:
      #set( $email = “foo” )
      $email
      /$email
      //$email
      ///$email
    将render为:
      foo
      $email
      /foo
      //$email
    如果email变量没有被定义则
      $email
      /$email
      //$email
      ///$email
    将被render为:
      $email
      /$email
      //$email
      ///$email
    注意:VTL中未被定义的变量将被认为是一个字符串,所以以下例子:
      #set( $foo = “gibbous” )
      $moon = $foo
    的输出结果是:
    $moon = gibbous
    Case substitution
    现在你已经对reference比较熟悉了,你可以将他们高效的应用于你的template了。Velocity利用了很多java规范以方便了设计人员的使用。例如:
      $foo
      $foo.getBar()
      ## is the same as
      $foo.Bar

      $data.getUser(“jon”)
      ## is the same as
      $data.User(“jon”)

      $data.getRequest().getServerName()
      # is the same as
      $data.Request.ServerName
      ## is the same as
      ${data.Request.ServerName}
    但是,注意VTL中不会将reference解释为对象的实例变量。例如:$foo.Name将被解释为Foo对象的getName()方法,而不是Foo对象的Name实例变量。
    Directives
    Reference允许设计者使用动态的内容,而directive使得你可以应用java代码来控制你的显示逻辑,从而达到你所期望的显示效果。
      #set
      #set directive被用于设置一个reference的值。例如:
        #set ( $primate = “monkey” )
        #set ( $customer.Behavior = $primate )
    赋值左侧的(LHS)必须是一个变量或者属性reference。右侧(RHS)可以是以下类型中一种:
    l  变量reference
    l  String literal
    l  属性reference
    l  方法reference
    l  number literal
    l  ArrayList
    下面是应用各种类型的RHS的例子:
      #set ( $monkey = $bill ) ##变量reference
      #set ( $monkey.Friend = “monica” ) ##String literal
      #set ( $monkey.Blame = $whitehouse.Leak )##属性reference
      #set ( $monkey.Plan = $spindoctor.weave($web) )##方法reference
      #set ( $monkey.Number = 123 )##Number literal
      #set ( $monkey.Say = [“Not”, $my, “fault”] )##ArrayList
    注意:最后一个例子的取值方法为:$monkey.Say.get(0)
    RHS也可以是一个简单的算术表达式:
      #set ( $value = $foo + 1 )
      #set ( $value = $bar -1 )
    #set ( $value = $foo * $bar )
    #set ( $value = $foo / $bar )
    如果你的RHS是一个null,VTL的处理将比较特殊:它将指向一个已经存在的reference,这对初学者来讲可能是比较费解的。例如:
      #set ( $resut = $query.criteria(“name”) )
      The result of the first query is $result

      #set ( $resut = $query.criteria(“address”) )
      The result of the second query is $result
    如果$query.criteria(“name”)返回一个“bill”,而$query.criteria(“address”)返回的是null,则显示的结果如下:
      The result of the first query is bill
      The result of the first query is bill
    看看下面的例子:
      #set( $criteria = ["name", "address"] )
    #foreach( $criterion in $criteria )
    #set( $result = $query.criteria($criterion) )
      #if( $result )
      Query was successful
         #end
    #end
    在上面的例子中,程序将不能智能的根据$result的值决定查询是否成功。在$result被#set后(added to the context),它不能被设置回null(removed from the context)。打印的结果将显示两次查询结果都成功了,但是实际上有一个查询是失败的。
    为了解决以上问题我们可以通过预先定义的方式:
      #set( $criteria = [“name”, “address”] )
      #foreach( $criterion in $criteria )
        #set( $result = false )
        #set( $result = $query.criteria( $criterion ) )
        #if( $result )
          Query was successful
        #end
      #end
      String Literals
      当你使用#set directive,String literal封闭在一对双引号内。
        #set ( $directoryRoot = “www” )
        #set ( $templateName = “index.vm” )
        #set ( $template = “$directoryRoot/$tempateName” )
        $template
      上面这段代码的输出结果为:www/index.vm
      但是,当string literal被封装在单引号内时,它将不被解析:
        #set ( $foo = “bar” )
        $foo
        #set ( $blargh = ‘$foo’ )
      结果:
        bar
        $foo
      上面这个特性可以通过修改velocity.properties文件的stringliterals.interpolate = false的值来改变上面的特性是否有效。
    条件语句
      if/elseif/else
    当一个web页面被生成时使用Velocity的#if directrive,如果条件成立的话可以在页面内嵌入文字。例如:
      #if ( $foo )
        <strong>Velocity!</strong>
      #end
    上例中的条件语句将在以下两种条件下成立:
    l  $foo是一个boolean型的变量,且它的值为true
    l  $foo变量的值不为null
    这里需要注意一点:Velocity context仅仅能够包含对象,所以当我们说“boolean”时实际上代表的时一个Boolean对象。即便某个方法返回的是一个boolean值,Velocity也会利用内省机制将它转换为一个Boolean的相同值。
    如果条件成立,那么#if和#end之间的内容将被显示。
    #elseif和#else元素可以同#if一同使用。例如:
      #if( $foo < 10 )
        <strong> Go North </strong>
      #elseif( $foo == 10 )
        <strong> Go East </strong>
      #elseif( $foo == 6 )
        <strong> Go South </strong>
      #else
        <strong> Go West </strong>
      #end
    注意这里的Velocity的数字是作为Integer来比较的――其他类型的对象将使得条件为false,但是与java不同它使用“==”来比较两个值,而且velocity要求等号两边的值类型相同。
    关系、逻辑运算符
    Velocity中使用等号操作符判断两个变量的关系。例如:
    #set ( $foo = “deoxyribonucleic acid” )
    #set ( $bar = “ribonucleic acid” )
    #if ( $foo == $foo )
      In this case it’s clear they aren’t equivalent.So…
    #else
      They are not equivalent and this will be the output.
    #end

    Velocity有AND、OR和NOT逻辑运算符。下面是一些例子:
      ## logical AND
      #if( $foo && $bar )
        <strong> This AND that </strong>
      #end

      ## logical OR
      #if ( $foo || $bar )
        <strong>This OR That </strong>
      #end

      ##logical NOT
      #if ( !$foo )
        <strong> NOT that </strong>
      #end
    循环
      Foreach循环
      例子:
        <ul>
          #foreach ( $product in $allProducts )
            <li> $product </li>
          #end
        </ul>
      每次循环$allProducts中的一个值都会赋给$product变量。
    $allProducts可以是一个Vector、Hashtable或者Array。分配给$product的值是一个java对象,并且可以通过变量被引用。例如:如果$product是一个java的Product类,并且这个产品的名字可以通过调用他的getName()方法得到。
    现在我们假设$allProducts是一个Hashtable,如果你希望得到它的key应该像下面这样:
    <ul>
    #foreach ( $key in $allProducts.keySet() )
    <li>Key: $key -> Value: $allProducts.get($key) </li>
    #end
    </ul>

    Velocity还特别提供了得到循环次数的方法,以便你可以像下面这样作:
    <table>
    #foreach ( $customer in $customerList )
    <tr><td>$velocityCount</td><td>$customer.Name</td></tr>
    #end
    </table>
    $velocityCount变量的名字是Velocity默认的名字,你也可以通过修改velocity.properties文件来改变它。默认情况下,计数从“1”开始,但是你可以在velocity.properties设置它是从“1”还是从“0”开始。下面就是文件中的配置:
      # Default name of loop counter
      # variable reference
      directive.foreach.counter.name = velocityCount

      # Default starting value of the loop
      # counter variable reference
      directive.foreach.counter.initial.value = 1

    include
    #include script element允许模板设计者引入本地文件。被引入文件的内容将不会通过模板引擎被render。为了安全的原因,被引入的本地文件只能在TEMPLATE_ROOT目录下。
      #inclued ( “one.txt” )
    如果您需要引入多个文件,可以用逗号分隔就行:
      #include ( “one.gif”, “two.txt”, “three.htm” )
    在括号内可以是文件名,但是更多的时候是使用变量的:
      #inclue ( “greetings.txt”, $seasonalstock )

    parse
    #parse script element允许模板设计者一个包含VTL的本地文件。Velocity将解析其中的VTL并render模板。
      #parse( “me.vm” )
    就像#include,#parse接受一个变量而不是一个模板。任何由#parse指向的模板都必须包含在TEMPLATE_ROOT目录下。与#include不同的是,#parse只能指定单个对象。
    你可以通过修改velocity.properties文件的parse_direcive.maxdepth的值来控制一个template可以包含的最多#parse的个数――默认值是10。#parse是可以递归调用的,例如:如果dofoo.vm包含如下行:
      Count down.
      #set ( $count = 8 )
      #parse ( “parsefoo.vm” )
      All done with dofoo.vm!
    那么在parsefoo.vm模板中,你可以包含如下VTL:
      $count
      #set ( $count = $count – 1 )
      #if ( $count > 0 )
        #parse( “parsefoo.vm” )
      #else
        All done with parsefoo.vm!
      #end
    的显示结果为:
      Count down.
      8
      7
      6
      5
      4
      3
      2
      1
      0
      All done with parsefoo.vm!
    All done with dofoo.vm!

    Stop
    #stop script element允许模板设计者停止执行模板引擎并返回。把它应用于debug是很有帮助的。
      #stop

    Velocimacros
    #macro script element允许模板设计者定义一段可重用的VTL template。例如:
      #macro ( d )
      <tr><td></td></tr>
      #end
    在上面的例子中Velocimacro被定义为d,然后你就可以在任何VTL directive中以如下方式调用它:
      #d()
    当你的template被调用时,Velocity将用<tr><td></td></tr>替换为#d()。
    每个Velocimacro可以拥有任意数量的参数――甚至0个参数,虽然定义时可以随意设置参数数量,但是调用这个Velocimacro时必须指定正确的参数。下面是一个拥有两个参数的Velocimacro,一个参数是color另一个参数是array:
      #macro ( tablerows $color $somelist )
      #foreach ( $something in $somelist )
        <tr><td bgcolor=$color>$something</td</tr>
      #end
      #end
    调用#tablerows Velocimacro:
      #set ( $greatlakes = [ “Superior”, “Michigan”, “Huron”, “Erie”, “Ontario” ] )
      #set ( $color = “blue” )
      <table>
        #tablerows( $color $greatlakes )
      </table>
    经过以上的调用将产生如下的显示结果:
      <table>
        <tr><td bgcolor=” blue”> Superior </td></tr>
        <tr><td bgcolor=” blue”> Michigan </td></tr>
        <tr><td bgcolor=” blue”> Huron </td></tr>
        <tr><td bgcolor=” blue”> Erie </td></tr>
        <tr><td bgcolor=” blue”> Ontario </td></tr>
      </table>
    Velocimacros可以在Velocity模板内实现行内定义(inline),也就意味着同一个web site内的其他Velocity模板不可以获得Velocimacros的定义。定义一个可以被所有模板共享的Velocimacro显然是有很多好处的:它减少了在一大堆模板中重复定义的数量、节省了工作时间、减少了出错的几率、保证了单点修改。
    上面定义的#tablerows( $color $list )Velocimacro被定义在一个Velocimacros模板库(在velocity.properties中定义)里,所以这个macro可以在任何规范的模板中被调用。它可以被多次应用并且可以应用于不同的目的。例如下面的调用:
      #set ( $parts = [ “volva”, “stipe”, “annulus”, “gills”, “pileus” ] )
      #set ( $cellbgcol = “#CC00FF” )
      <table>
        #tablerows( $cellbgcol $parts )
      </table>
    上面VTL将产生如下的输出:
      <table>
        <tr><td bgcolor=”#CC00FF”> volva </td</tr>
        <tr><td bgcolor=”#CC00FF”> stipe </td</tr>
        <tr><td bgcolor=”#CC00FF”> annulus </td</tr>
        <tr><td bgcolor=”#CC00FF”> gills </td</tr>
        <tr><td bgcolor=”#CC00FF”> pileus </td</tr>
      </table>
      Velocimacro arguments
      Velocimacro可以使用以下任何元素作为参数:
    l  Reference:任何以$开头的reference
    l  String literal:
    l  Number literal:
    l  IntegerRange:[1….3]或者[$foo….$bar]
    l  对象数组:[“a”,”b”,”c”]
    l  boolean值:true、false
    当将一个reference作为参数传递给Velocimacro时,请注意reference作为参数时是以名字的形式传递的。这就意味着参数的值在每次Velocimacro内执行时才会被产生。这个特性使得你可以将一个方法调用作为参数传递给Velocimacro,而每次Velocimacro执行时都是通过这个方法调用产生不同的值来执行的。例如:
      #macro ( callme $a )
        $a $a $a
      #end
      #callme( $foo.bar() )
    执行的结果是:reference $foo的bar()方法被执行了三次。
    如果你不需要这样的特性可以通过以下方法:
      #set ( $myval = $foo.bar() )
      #callme ( $myval )

    Velocimacro properties
    Velocity.properties文件中的某几行能够使Velocimacros的实现更加灵活。注意更多的内容可以看Developer Guide。
    Velocity.properties文件中的velocimacro.libraary:一个以逗号分隔的模板库列表。默认情况下,velocity查找唯一的一个库:VM_global_library.vm。你可以通过配置这个属性来指定自己的模板库。
    Velocity.properties文件中的velocimacro.permissions.allow.inline属性:有两个可选的值true或者false,通过它可以确定Velocimacros是否可以被定义在regular template内。默认值是ture――允许设计者在他们自己的模板中定义Velocimacros。
    Velocity.properties文件中的
    velocimacro.permissions.allow.inline.replace.global属性有两个可选值true和false,这个属性允许使用者确定inline的Velocimacro定义是否可以替代全局Velocimacro定义(比如在velocimacro.library属性中指定的文件内定义的Velocimacro)。默认情况下,此值为false。这样就阻止本地Velocimacro定义覆盖全局定义。
    Velocity.properties文件中的
    velocimacro.permissions.allow.inline.local.scale属性也是有true和false两个可选值,默认是false。它的作用是用于确定你inline定义的Velocimacros是否仅仅在被定义的template内可见。换句话说,如果这个属性设置为true,一个inline定义的Velocimacros只能在定义它的template内使用。你可以使用此设置实现一个奇妙的VM敲门:a template can define a private implementation of the second VM that will be called by the first VM when invoked by that template. All other templates are unaffected。
    Velocity.properties文件中的velocimacro.context.localscope属性有true和false两个可选值,默认值为false。当设置为true时,任何在Velocimacro内通过#set()对context的修改被认为是针对此velocimacro的本地设置,而不会永久的影响内容。
    Velocity.properties文件中的velocimacro.library.autoreload属性控制Velocimacro库的自动加载。默认是false。当设置为ture时,对于一个Velocimacro的调用将自动检查原始库是否发生了变化,如果变化将重新加载它。这个属性使得你可以不用重新启动servlet容器而达到重新加载的效果,就像你使用regular模板一样。这个属性可以使用的前提就是resource loader缓存是off状态(file.resource.loader.cache = false)。注意这个属性实际上是针对开发而非产品的。
    Velocimacro Trivia
    Velocimacro必须被定义在他们被使用之前。也就是说,你的#macro()声明应该出现在使用Velocimacros之前。
    特别要注意的是,如果你试图#parse()一个包含#macro()的模板。因为#parse()发生在运行期,但是解析器在parsetiem决定一个看似VM元素的元素是否是一个VM元素,这样#parse()-ing一组VM声明将不按照预期的样子工作。为了得到预期的结果,只需要你简单的使用velocimacro.library使得Velocity在启动时加载你的VMs。
    Escaping VTL directives
    VTL directives can be escaped with “/”号,使用方式跟VTL的reference使用逃逸符的格式差不多。
      ## #include( “a.txt” ) renders as <ontents of a.txt>(注释行)
      #include( “a.txt” )

      ## /#include( “a.txt” ) renders as /#include( “a.txt” )
      /#include( “a.txt” )

      ## //#include ( “a.txt” ) renders as /<contents of a.txt>
      //#include( “a.txt” )
    在对在一个directive内包含多个script元素的VTL directives使用逃逸符时要特别小心(比如在一个if-else-end statement内)。下面是VTL的if-statement的典型应用:
      #if ( $jazz )
        Vyacheslav Ganelin
      #end
    如果$jazz是ture,输出将是:
      Vyacheslav Ganelin
    如果$jazz是false,将没有输出。使用逃逸符将改变输出。考虑一下下面的情况:
      /#if ( $jazz )
        Vyacheslav Ganelin
      /#end
    现在无论$jazz是true还是false,输出结果都是:
      #if ( $jazz )
        Vyacheslav Ganelin
      #end
    事实上,由于你使用了逃逸符,$jazz根本就没有被解析为boolean型值。在逃逸符前使用逃逸符是合法的,例如:
      //#if ( $jazz )
        Vyacheslav Ganelin
      //#end
    以上程序的显示结果为:
      / Vyacheslav Ganelin
      /
    但是如果$jazz为false,那么将没有输出。(书上说会没有输出,但是我觉得应该还有有“/”字符被输出。)
    VTL:Formatting issues
    尽管在此用户手册中VTL通常都开始一个新行,如下所示:
      #set ( $imperial = [ “Munetaka”, “Koreyasu”, “Hisakira”, “Morikune” ] )
      #foreach ( $shogun in $imperial )
        $shogun
      #end
    但是像下面这种写法也是可以的:
      Send me #set($foo = [“$10 and”,”a cake”])#foreach($a in $foo)$a #end please.
    上面的代码可以被改写为:
      Send me
      #set ( $foo = [“$10 and “,”a cake”] )
      #foreach ( $a in $foo )
        $a
      #end
      please.
    或者
      Send me
      #set($foo = [“$10 and “,”a cake”])
            #foreach ($a in $foo )$a
          #end please.
    这两种的输出结构将一样。
    其他特性和杂项
      math   在模板中可以使用Velocity内建的算术函数,如:加、减、乘、除
        #set ( $foo = $bar + 3 )
        #set ( $foo = $bar - 4 )
        #set ( $foo = $bar * 6 )
        #set ( $foo = $bar / 2 )
      当执行除法时将返回一个Integer类型的结果。而余数你可以使用%来得到:
        #set ( $foo = $bar % 5 )
    在Velocity内使用数学计算公式时,只能使用像-n,-2,-1,0,1,2,n这样的整数,而不能使用其它类型数据。当一个非整型的对象被使用时它将被logged并且将以null作为输出结果。
    Range Operator
    Range operator可以被用于与#set和#foreach statement联合使用。对于处理一个整型数组它是很有用的,Range operator具有以下构造形式:
      [n..m]
    m和n都必须是整型,而m是否大于n则无关紧要。例子:
      First example:
      #foreach ( $foo in [1..5] )
        $foo
      #end

      Second example:
      #foreach ( $bar in [2..-2] )
        $bar
      #end

      Third example:
      #set ( $arr = [0..1] )
      #foreach ( $i in $arr )
        $i
      #end

      Fourth example:
      [1..3]
    上面四个例子的输出结果为:
      First example:
      1 2 3 4 5

      Second example:
      2 1 0 -1 -2

      Third example:
      0 1

      Fourth example:
      [1..3]
    注意:range operator只在#set和#foreach中有效。
    Advanced Issue:Escaping and!
    当一个reference被“!”分隔时,并且在它之前有逃逸符时,reference将以特殊的方式处理。注意这种方式与标准的逃逸方式时不同的。对照如下:
    #set ( $foo = “bar” )
    特殊形式  标准格式
    Render前  Render后  Render前  Render后
    $/!foo  $!foo  /$foo  /$foo
    $/!{foo}  $!{foo}  /$!foo  /$!foo
    $//!foo  $/!foo  /$!{foo}  /$!{foo}
    $///!foo  $//!foo  //$!{foo}  /bar
    Velocimacro杂记
      Can I user a directive or another VM as an argument to a VM?
      例如:#center ( #bold( “hello” ) )
      不可以。一个directive的参数使用另外一个directive是不合法的。
      但是,还是有些事情你可以作的。最简单的方式就是使用双引号:
        #set ( $stuff = “#bold( ‘hello’ )” )
        #center ( $stuff )
      上面的格式也可以缩写为一行:
        #center ( “#bold( ‘hello’ ) )
    请注意在下面的例子中参数被evaluated在Velocimacro内部,而不是在calling level。例子:
      #macro ( inner $foo )
        inner : $foo
      #end

      #macro ( outer $foo )
        #set ( $bar = “outerlala” )
        outer : $foo
      #end
     
      #set ( $bar = ‘calltimelala’ )
      #outer( “#inner($bar)” )
    输出结果为:
      outer : inner : outerlala
    记住Veloctiy的特性:参数的传递是By Name的。例如:
      #macro ( foo $color )
        <tr bgcolor = $color ><td>Hi</td></tr>
        <tr bgcolor = $color ><td>There</td></tr>
      #end

      #foo ( $bar.rowColor() )
    以上代码将导致rowColor()方法两次调用,而不是一次。为了避免这种现象的出现,我们可以按照下面的方式执行:
      #set ( $color = $bar.rowColor() )
      #foo ( $color )
    can I register velocimacros via #parse()?
    目前,Velocimacros必须在第一次被模板调用前被定义。这就意味着你的#macro()声明应该出现在使用Velocimacros之前。
    如果你试图#parse()一个包含#macro() directive的模板,这一点是需要牢记的。因为#parse()发生在运行期,但是解析器在parsetiem决定一个看似VM元素的元素是否是一个VM元素,这样#parse()-ing一组VM声明将不按照预期的样子工作。为了得到预期的结果,只需要你简单的使用velocimacro.library使得Velocity在启动时加载你的VMs。
    What is velocimacro autoreloading?
    velocimacro.library.autoreload是专门为开发而非产品使用的一个属性。此属性的默认值是false。
    String concatenation
    开发人员最常问的问题是我如何作字符拼接?在java中是使用“+”号来完成的。
    在VTL里要想实现同样的功能你只需要将需要联合的reference放到一起就行了。例如:
    #set ( $size = “Big” )
    #set ( $name = “Ben” )
    The clock is $size$name.
    输出结果将是:The clock is BigBen.。更有趣的情况是:
      #set ( $size = “Big” )
      #set ( $name = “Ben” )
      #set ( $clokc = “$size$name” )
      The clock is $clock.
    上例也会得到同样的结果。最后一个例子,当你希望混合固定字段到你的reference时,你需要使用标准格式:
      #set ( $size = “Big” )
      #set ( $name = “Ben” )
      #set ( $clock = “${size}Tall$name” )
      The clock is $clock.
    输出结果是:The clock is BigTallBen.。使用这种格式主要是为了使得$size不被解释为$sizeTall。

    几个写法汇总:
    Java代码 复制代码
    1. --关于链接的写法--   
    2. <a href="abc.jsp?num=$var">url</a>  
    --关于链接的写法--
    <a href="abc.jsp?num=$var">url</a>
    展开全文
  • Maven中文手册

    2012-08-20 14:36:36
    Maven最早始于Jarkarta Turbine项目,目的是为了简化构建过程。这个项目下面有 几个子项目,每个子项目都有自己Ant文件,但是区别很小,而且生成JAR 文件都要check in到CVS中。我们希望有一种标准方式来...
  • QBlade 0.6 多语中文版(桨叶模拟设计工具)是使用叶片元素动量法 (BEM) 和使用多重加倍进行流设计(DMS) 桨叶设计器,对于垂直轴风力涡轮机(VAWT)或水平轴风力涡轮机 (HAWT) 集成仿真 是基于软件XFLR5(机翼...
  • Maven简单中文手册

    千次阅读 2006-10-23 16:17:00
    Maven最早始于Jarkarta Turbine项目,目的是为了简化构建过程。这个项目下面有 几个子项目,每个子项目都有自己Ant文件,但是区别很小,而且生成JAR 文件都要check in到CVS中。我们希望有一种标准方式来...
  • Velocity用户手册---中文版(学习修改版)Velocity能力远不止web站点开发这个领域,例如,它可以从模板(template)产生SQL和PostScript、XML,它也可以被当作一个独立工具来产生源代码和报告,或者作为其他...
  • Velocity能力远不止web站点开发这个领域,例如,它可以从模板(template)产生SQL和PostScript、XML,它也可以被当作一个独立工具来产生源...Velocity+Turbine提供一个模板服务方式允许一个web应用以一个真正M...
  • Velocity能力远不止web站点开发这个领域,例如,它可以从模板(template)产生SQL和PostScript、XML,它也可以被当作一个独立工具来产生源...Velocity+Turbine提供一个模板服务方式允许一个web应用以一个真正M...
  • http://airport.javaeye.com/blog/23634Velocity能力远不止web站点开发这个领域,例如,它可以从模板(template)产生SQL和Post...Velocity也可以为Turbine web开发架构提供模板服务(template service)。Veloc...
  • .它具有以下特点: 1.其它系统一样都具有特点:数据输入,查询,报告,通知到相关当事人,注释协作积累,依赖追踪等. 2.Scarab通过一组管理页面可无限制地,自由地定制模块数量...4.Scarab采用turbine框架实现,安装
  • - [hystrix-dashboard-turbine](https://github.com/ityouknow/spring-cloud-examples/tree/master/hystrix-dashboard-turbine):熔断监控Hystrix Dashboard和Turbine的示例 - [spring-cloud-config-git]...
  • 微服务(完)\\07-Hystrix监控与Turbine聚合-诸葛;目录中文件数:3个 ├─(138) 07.hystrix&feign;监控dashboard与turbine聚合-.mp4 ├─(139) Hystrix&Feign;监控Dashboard与Turbine聚合.pdf ├─(140) 微服务07-...
  • velocity 用户手册

    2009-10-02 22:17:38
    Velocity用户手册---中文版(学习修改版) Velocity能力远不止web站点开发这个领域,例如,它可以从模板(template)产生SQL和PostScript、XML,它也可以被当作一个独立工具来产生源代码和报告,或者作为其他系统...
  • hystrix-dashboard-turbine:熔断监控Hystrix Dashboard和Turbine的示例 spring-cloud-config-git:配置中心git版本示例 spring-cloud-config-svn-refresh:配置中心svn版本示例,客户端refresh版本示例 spring-...
  • 29_ElasticSearchIK中文分词器安装和使用 30_ElasticSearch IK分词器配置文件 以及自定义词库 31_ElasticSearch 修改IK分词器源码来基于mysql热更新词库 32_ElasticSearch bucket与metric两个核心概念 ...

空空如也

空空如也

1 2
收藏数 29
精华内容 11
关键字:

turbine的中文