当前位置:编程学习 > JAVA >>

开始serviceMix

1.     serviceMix 特点:
支持的协议有:
File;FTP;Http/s;jms;smtp;soap;tcp;xmpp
与其他引擎的支持:
Apache Camel;apache cxf;apache ode;drools;os workflow;pojos;quartz;scripting;saxon Xquery and xslt;ws-notification
支持的安全:
JAAS,WS-Security
与web 容器的集成
JBoss,Geronimo,jetty,tomcat,weblogic,websphere
 
2.     eclipse IDE tooling for serviceMix
http://eclipse.org/stp
http://spagic.com
http://sopera.de/en/products/sopera-servicemixtools
 
3.     安装:
A. 官方下载http://servicemix.apache.org/downloads.html.并解压
B. 进入bin目录执行servicemix.bat或者shell script
C. Sericemix是osgi结构的,
通过osgi:list 命令可以查看所有有效的osgi bundles
通过osgi:list | grep camel 命令 查看camel相关的bundles
通过log:display命令 来显示日志
通过log:display-exception  显示最近的异常日志
通过log:set DEBUG  设置日志的级别
通过log:display | grep DEBUG 显示只是debug级别的日志
          通过features:list 来查看所有的特性,并从而可以分析当前特性是否安装
          若没有安装 可以通过 features:install来安装,比如:features:install webconsole
4.     与Camel 集成
先查看是否存在camel相关features,没有则按照相应的bundles
接下来我们做一个例子:分别设置两个目录input和output,在input放入文件后则被传送到output中。而这个过程就是通过serviceMix调用camel router来完成
A. Blueprint xml file
下面是一个配置的router文件描述,你可以通过自己写文件,当然最好还是用可视化工具,后面我们再花时间聊聊这东东,这个时候就绕不开Enterprise Integration pattern 又是标准,老外厉害。
 我们这里直接先贴上文件:
<?xml version="1.0" encoding="UTF-8"?>
<blueprint
    xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
 
    <camelContext xmlns="http://camel.apache.org/schema/blueprint">
        <route>
            <from uri="file:bgao/input" />
            <log message="happy day!!!" />
            <to uri="file:bgao/output" />
        </route>
    </camelContext>
</blueprint>
并命名为firstCamelRouter.xml
 
B. 配置到serviceMix
将文件放入到serviceMix的deploy中,这个时候后再serviceMix目录下发现bgao的目录并下面有个input文件夹,这时候如果在input文件夹放入一个文件,这bgao目录下会出现output目录并且将input目录的文件移到output上。通过log:display  可以查看到当前这个动作的日志。
 
通过karaf@root> osgi:list | grep xml
[  43] [Active     ] [GracePeriod ] [       ] [   60] activemq-broker.xml (0.0.0
)
[ 129] [Active     ] [            ] [       ] [   60] Apache ServiceMix :: Bundl
es :: xmlsec (1.4.5.1)
[ 138] [Active     ] [            ] [       ] [   60] Apache ServiceMix :: Bundl
es :: xmlbeans (2.4.0.4)
[ 142] [Active     ] [            ] [       ] [   60] Apache ServiceMix :: Bundl
es :: xmlresolver (1.2.0.3)
[ 163] [Active     ] [Created     ] [       ] [   60] firstCamelRouter.xml (0.0.
0)
得到当前ID为163;通过osgi:stop 163或者  osgi:start 163 来启动或者关闭当前bundle
 
5.     与ActiveMQ集成
先查看是否存在camel相关features, 没有则按照相应的bundles
我们做一个例子:
对两个文件进行文件移动,同时对MQ队列产生一个event 消息并捕获消息打出到日志。
第一个文件:firstMq.xml
<?xml version="1.0" encoding="UTF-8"?>
<blueprint
    xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
 
    <camelContext xmlns="http://camel.apache.org/schema/blueprint">
        <route>
            <from uri="file:bgao/mq/input" />
            <to uri="file:bgao/mq/output" />         
                <setBody>
                <易做图>
                File Move Event (${file:name},${date:now:hh:MM:ss.SSS})
                </易做图>
                </setBody>
                <to uri="activemq://event" />
        </route>         
    </camelContext>
</blueprint>
这时候,文件已经移到output,现在是event message都在队列里面,但还没有人去处理他,现在通过secondeMq里处理她。
设置第二个文件 secondMq.xml 放入deloy文件夹中
<?xml version="1.0" encoding="UTF-8"?>
<blueprint
    xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
 
    <camelContext xmlns="http://camel.apache.org/schema/blueprint">
        <route>
        <from uri="activemq://event" />
            <from uri="file:bgao/mq/input" />
         

补充:软件开发 , Java ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,