当前位置: 首页 > news >正文

网站建设电话营销培训ppt课件移动端购物网站建设

网站建设电话营销培训ppt课件,移动端购物网站建设,虚拟服务器价格,国家企业信用公示信息系统官网camel seda 协议Apache Camel中的seda组件与我在先前的博客中介绍的direct组件非常相似#xff0c;但是以异步的方式。 为此#xff0c;它使用java.util.concurrent.BlockingQueue作为默认实现来使消息排队并与主Route线程断开连接#xff0c;然后在单独的线程中处理消息。 … camel seda 协议 Apache Camel中的seda组件与我在先前的博客中介绍的direct组件非常相似但是以异步的方式。 为此它使用java.util.concurrent.BlockingQueue作为默认实现来使消息排队并与主Route线程断开连接然后在单独的线程中处理消息。 由于此BlockingQueue 您需要了解用法和配置选项。 需要注意的一个选项是异步处理默认情况下队列大小是不受限制的这意味着它会增长到您允许的内存。 为此请设置size1000 。 让我们来看一个例子。 package camelcoredemo;import org.slf4j.*; import org.apache.camel.*; import org.apache.camel.builder.*; import org.apache.camel.main.Main; import java.io.*;public class SedaDemoCamel extends Main {static Logger LOG LoggerFactory.getLogger(SedaDemoCamel.class);public static void main(String[] args) throws Exception {SedaDemoCamel main new SedaDemoCamel();main.enableHangupSupport();main.addRouteBuilder(createRouteBuilder1());main.addRouteBuilder(createRouteBuilder2());main.addRouteBuilder(createRouteBuilder3());main.run(args);}// The file poller routestatic RouteBuilder createRouteBuilder1() {return new RouteBuilder() {public void configure() {from(file://target/input?preMovestagingmove.processed).process(new Processor() {public void process(Exchange msg) {CamelContext camelContext msg.getContext();ProducerTemplate producer camelContext.createProducerTemplate();String text msg.getIn().getBody(String.class);String fileName (String)msg.getIn().getHeader(CamelFileName);boolean specialFile fileName.endsWith(_SPECIAL.dat);if (specialFile)producer.sendBody(seda:specialRoute, text);elseproducer.sendBody(seda:normalRoute, text);}});}};}// The special file processing routestatic RouteBuilder createRouteBuilder2() {return new RouteBuilder() {public void configure() {from(seda:specialRoute).process(new Processor() {public void process(Exchange msg) {LOG.info(Processing special file: msg);}});}};}// The normal file processing routestatic RouteBuilder createRouteBuilder3() {return new RouteBuilder() {public void configure() {from(seda:normalRoute).process(new Processor() {public void process(Exchange msg) {LOG.info(Processing normal file: msg);}});}};} } 您会注意到该演示代码与direct组件演示非常相似几乎没有区别。 首先我们使用seda端点。 其次在文件轮询器中我们读取了整个文件的内容文本。 之所以这样做是因为我们现在要传递给异步Route 该Route将在单独的线程上运行。 轮询器配置为在第一个Route结束后立即将处理后的文件移动到其他文件夹中。 因此我们必须确保处理Route不依赖于File的路径因此我们将加载整个文本。 另一个有趣的seda选项是您可以设置并发线程数以接收消息以处理它们 假设您的普通文件流量很大那么您可以配置为在该部分使用更多线程默认值是一个线程。 from(seda:normalRoute?concurrentConsumers10) .process(new Processor() {public void process(Exchange msg) {LOG.info(Processing normal file: msg);} }); 要验证您正在同时运行可以轻松配置记录器以显示线程名称。 例如使用log4j 可以使用以下模式 log4j.rootLoggerINFO, stdout log4j.appender.stdoutorg.apache.log4j.ConsoleAppender log4j.appender.stdout.layoutorg.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern%d %p %t [%c] - %m%n 您可以探索Seda组件中提供的更多选项。 尝试一下路线 亲自体验一下。 参考 A程序员杂志博客上的JCG合作伙伴 Zemian Deng 探索Apache Camel Core – Seda组件 。 翻译自: https://www.javacodegeeks.com/2013/09/exploring-apache-camel-core-seda-component.htmlcamel seda 协议
http://www.huolong8.cn/news/203142/

相关文章:

  • 进入 网站cms樟木头镇仿做网站
  • 海南网站备案招生网站模板
  • 电大亿唐网不做网站做品牌品牌建设的过程
  • 郑州做网站msgg东莞app软件开发公司
  • 地方网站运营教程免费企业网站程序asp
  • 深圳本地网站建设关键词seo
  • 个人信息网站建设方案书框架栏目免费快速建站工具
  • 摄像头监控视频怎么做直播网站免费网上商城模板
  • 关键词排名怎么查seo网站分析案例
  • 手机回收网站开发网站建设跟pc官网一样吗
  • 枣庄手机网站建设报价网站内容栏由什么构成
  • 网站响应式布局大公司需要seo是什么职业
  • 网站伪静态有什么用wordpress主题模块添加
  • 建站程序选择seo优化网
  • 网站打开404错误怎么解决方法云主机怎么做网站
  • 个人做 网站2019南宁平面设计公司
  • 如何查找网站根目录wordpress设置固定链接后
  • 网站站点建设分为模板做图 网站有哪些内容
  • 自己录入数据做问卷的网站网站版块设计
  • 深圳做微信网站公司义务网站建设
  • 微信网站推广手机怎么做网站免费的
  • 贵州公明建设投资咨询有限公司官方网站晋江论坛网站
  • 推上网站网站知识架构
  • 网站建设基本流程教学视频百度分公司 网站外包
  • 电子商务网站 注意东家乐装修公司简介
  • 企业网站建设三个原则石家庄网络推广公司有哪些
  • 建一个购物网站大约多少钱wordpress .
  • 怎样 建设电子商务网站怎么美化网站
  • 太原门户网站品牌设计与vi设计的区别
  • 自适应网站什么意思基于c 的网站开发