{"id":36704,"date":"2022-11-13T13:30:07","date_gmt":"2024-02-14T22:43:25","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/"},"modified":"2024-04-29T00:28:46","modified_gmt":"2024-04-28T16:28:46","slug":"apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/","title":{"rendered":"Apache Camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b"},"content":{"rendered":"<h1>\u603b\u7ed3<\/h1>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">\u30ea\u30a2\u30af\u30c6\u30a3\u30d6\u30d7\u30ed\u30b0\u30e9\u30df\u30f3\u30b0\u3068\u306f<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">Camel + Reactive Streams<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">Camel + Vert.x<\/ul>\n<hr \/>\n<h1>\u54cd\u5e94\u5f0f\u7f16\u7a0b\u662f\u6307\u4e00\u79cd\u7f16\u7a0b\u8303\u5f0f\uff0c\u5176\u4e2d\u6570\u636e\u6d41\u901a\u8fc7\u5f02\u6b65\u7684\u65b9\u5f0f\u6d41\u52a8\uff0c\u5e76\u4e14\u53ef\u4ee5\u5728\u4e0d\u540c\u7684\u65f6\u95f4\u70b9\u88ab\u5904\u7406\u6216\u64cd\u4f5c\u3002<\/h1>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">\u30ea\u30a2\u30af\u30c6\u30a3\u30d6\u30b7\u30b9\u30c6\u30e0\u306e\u7279\u5fb4<\/ul>\n<\/li>\n<\/ul>\n<p>\u5373\u5fdc\u6027\uff08Responsive\uff09\u2015 \u5373\u6642\u306b\u5fdc\u7b54\u3092\u8fd4\u3059<\/p>\n<p>\u8010\u969c\u5bb3\u6027\uff08Resilient\uff09\u2015 \u969c\u5bb3\u304c\u3042\u3063\u3066\u3082\u5fdc\u7b54\u3059\u308b<\/p>\n<p>\u5f3e\u529b\u6027\uff08Elastic\uff09\u2015 \u9ad8\u8ca0\u8377\u3067\u3042\u3063\u3066\u3082\u5fdc\u7b54\u3059\u308b<\/p>\n<p>\u30e1\u30c3\u30bb\u30fc\u30b8\u99c6\u52d5\uff08Message Driven\uff09\u2015 \u758e\u7d50\u5408\u306a\u975e\u540c\u671f\u901a\u4fe1\u306b\u57fa\u3065\u304f<\/p>\n<hr \/>\n<h2>\u80cc\u538b .<\/h2>\n<blockquote><p>\u5982\u679c\u4e00\u4e2a\u7ec4\u4ef6\u4e0d\u80fd\u8ddf\u4e0a\u6574\u4f53\u7684\u8fdb\u5ea6\uff0c\u7cfb\u7edf\u4f5c\u4e3a\u4e00\u4e2a\u6574\u4f53\u9700\u8981\u6709\u4e00\u4e9b\u5904\u7406\u624b\u6bb5\u3002\u8fc7\u8f7d\u72b6\u6001\u4e0b\u7684\u7ec4\u4ef6\u4e0d\u80fd\u5f7b\u5e95\u5d29\u6e83\u6216\u4e27\u5931\u6d88\u606f\u7684\u63a7\u5236\u3002\u5982\u679c\u5904\u7406\u65e0\u6cd5\u8ddf\u4e0a\uff0c\u5e76\u4e14\u4e0d\u80fd\u5d29\u6e83\uff0c\u90a3\u4e48\u7ec4\u4ef6\u5e94\u8be5\u5411\u4e0a\u6e38\u7ec4\u4ef6\u901a\u77e5\u81ea\u5df1\u5904\u4e8e\u8fc7\u8f7d\u72b6\u6001\u5e76\u8bf7\u6c42\u51cf\u8f7b\u8d1f\u8f7d\u3002\u8fd9\u79cd\u88ab\u79f0\u4e3a\u53cd\u538b\uff08back-pressure\uff09\u7684\u673a\u5236\u662f\u5728\u8fc7\u8f7d\u60c5\u51b5\u4e0b\u7cfb\u7edf\u4e0d\u4f1a\u5d29\u6e83\u5e76\u80fd\u6301\u7eed\u7f13\u6162\u54cd\u5e94\u7684\u91cd\u8981\u53cd\u9988\u673a\u5236\u3002\u53cd\u538b\u673a\u5236\u53ef\u4ee5\u4f20\u9012\u7ed9\u7528\u6237\uff0c\u8fd9\u6837\u5904\u7406\u54cd\u5e94\u6027\u4f1a\u964d\u4f4e\uff0c\u4f46\u7cfb\u7edf\u7684\u6297\u6545\u969c\u6027\u5728\u8d1f\u8f7d\u4e0b\u5f97\u5230\u4fdd\u8bc1\u3002\u6b64\u5916\uff0c\u7cfb\u7edf\u53ef\u4ee5\u5229\u7528\u8fd9\u4e9b\u4fe1\u606f\u6765\u91cd\u65b0\u8c03\u914d\u5176\u4ed6\u8d44\u6e90\uff0c\u4fc3\u8fdb\u8d1f\u8f7d\u5747\u8861\u3002<\/p><\/blockquote>\n<hr \/>\n<h2>\u53cd\u5e94\u5f0f\u6d41\u7684\u793a\u4f8b<\/h2>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">JDK 9\u306ejava.util.concurrent.Flow\u30681:1\u306b\u5bfe\u5fdc<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">back pressure\u306e\u30b5\u30dd\u30fc\u30c8<\/ul>\n<pre class=\"post-pre\"><code><span class=\"kn\">import<\/span> <span class=\"nn\">org.reactivestreams.*<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">io.reactivex.rxjava3.core.*<\/span><span class=\"o\">;<\/span>\r\n\r\n<span class=\"c1\">\/\/ Hello world<\/span>\r\n<span class=\"nc\">Flowable<\/span><span class=\"o\">.<\/span><span class=\"na\">just<\/span><span class=\"o\">(<\/span><span class=\"s\">\"Hello World\"<\/span><span class=\"o\">).<\/span><span class=\"na\">subscribe<\/span><span class=\"o\">(<\/span><span class=\"nc\">System<\/span><span class=\"o\">.<\/span><span class=\"na\">out<\/span><span class=\"o\">::<\/span><span class=\"n\">println<\/span><span class=\"o\">);<\/span>\r\n\r\n<span class=\"c1\">\/\/ Publisher\/Subscriber example<\/span>\r\n<span class=\"nc\">Publisher<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">Integer<\/span><span class=\"o\">&gt;<\/span> <span class=\"n\">publisher<\/span> <span class=\"o\">=<\/span> <span class=\"nc\">Flowable<\/span><span class=\"o\">.<\/span><span class=\"na\">just<\/span><span class=\"o\">(<\/span><span class=\"mi\">1<\/span><span class=\"o\">,<\/span> <span class=\"mi\">2<\/span><span class=\"o\">,<\/span> <span class=\"mi\">3<\/span><span class=\"o\">,<\/span> <span class=\"mi\">4<\/span><span class=\"o\">,<\/span> <span class=\"mi\">5<\/span><span class=\"o\">);<\/span>\r\n<span class=\"nc\">Flowable<\/span><span class=\"o\">.<\/span><span class=\"na\">fromPublisher<\/span><span class=\"o\">(<\/span><span class=\"n\">publisher<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">map<\/span><span class=\"o\">(<\/span><span class=\"n\">i<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"n\">i<\/span><span class=\"o\">*<\/span><span class=\"n\">i<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">doOnNext<\/span><span class=\"o\">(<\/span><span class=\"nc\">System<\/span><span class=\"o\">.<\/span><span class=\"na\">out<\/span><span class=\"o\">::<\/span><span class=\"n\">println<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">subscribe<\/span><span class=\"o\">();<\/span>\r\n<\/code><\/pre>\n<hr \/>\n<h1>\u9a86\u9a7c + \u54cd\u5e94\u5f0f\u6d41<\/h1>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">Camel\u30eb\u30fc\u30c8\u3068Reactive Streams\u30d5\u30ed\u30fc\u3068\u306e\u53cc\u65b9\u5411\u306e\u9023\u643a\u3092\u53ef\u80fd\u306b\u3059\u308b<\/ul>\n<\/li>\n<\/ul>\n<p>reactive-streams:xxxxx[?options]<\/p>\n<p>\u4ee5\u4e0b\u306e\u30ea\u30a2\u30af\u30c6\u30a3\u30d6\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af\u5b9f\u88c5\u306b\u5bfe\u5fdc<\/p>\n<p>Reactor Core<br \/>\nRxJava<\/p>\n<p>Back pressure\u306b\u3082\u5bfe\u5fdc<\/p>\n<hr \/>\n<h2>\u9a86\u9a7c\uff08\u9152\u5427\uff09\u2192 \u54cd\u5e94\u5f0f\u6d41\uff08\u8ba2\u9605\u8005\uff09<\/h2>\n<ul class=\"post-ul\">Camel\u306e\u30d7\u30ed\u30c7\u30e5\u30fc\u30b5\u30fc\u30a8\u30f3\u30c9\u30dd\u30a4\u30f3\u30c8\uff08to\uff09\u304b\u3089Reactive Streams\u306e\u30d5\u30ed\u30fc\u3078<\/ul>\n<pre class=\"post-pre\"><code><span class=\"nc\">CamelContext<\/span> <span class=\"n\">camel<\/span> <span class=\"o\">=<\/span> <span class=\"k\">new<\/span> <span class=\"nc\">DefaultCamelContext<\/span><span class=\"o\">();<\/span>\r\n<span class=\"nc\">CamelReactiveStreamsService<\/span> <span class=\"n\">rsCamel<\/span> <span class=\"o\">=<\/span> <span class=\"nc\">CamelReactiveStreams<\/span><span class=\"o\">.<\/span><span class=\"na\">get<\/span><span class=\"o\">(<\/span><span class=\"n\">camel<\/span><span class=\"o\">);<\/span>\r\n<span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">start<\/span><span class=\"o\">();<\/span>\r\n\r\n<span class=\"c1\">\/\/ Camel (pub) \u2192 Reactive Streams (sub)<\/span>\r\n<span class=\"c1\">\/\/Publisher&lt;Integer&gt; publisher = rsCamel.from(\"seda:input\", Integer.class);<\/span>\r\n<span class=\"nc\">Publisher<\/span><span class=\"o\">&lt;<\/span><span class=\"nc\">Integer<\/span><span class=\"o\">&gt;<\/span> <span class=\"n\">publisher<\/span> <span class=\"o\">=<\/span> <span class=\"n\">rsCamel<\/span><span class=\"o\">.<\/span><span class=\"na\">fromStream<\/span><span class=\"o\">(<\/span><span class=\"s\">\"input\"<\/span><span class=\"o\">,<\/span> <span class=\"nc\">Integer<\/span><span class=\"o\">.<\/span><span class=\"na\">class<\/span><span class=\"o\">);<\/span>\r\n<span class=\"nc\">Flowable<\/span><span class=\"o\">.<\/span><span class=\"na\">fromPublisher<\/span><span class=\"o\">(<\/span><span class=\"n\">publisher<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">map<\/span><span class=\"o\">(<\/span><span class=\"n\">i<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"n\">i<\/span><span class=\"o\">*<\/span><span class=\"n\">i<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">doOnNext<\/span><span class=\"o\">(<\/span><span class=\"nc\">System<\/span><span class=\"o\">.<\/span><span class=\"na\">out<\/span><span class=\"o\">::<\/span><span class=\"n\">println<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">subscribe<\/span><span class=\"o\">();<\/span>\r\n\r\n<span class=\"nc\">FluentProducerTemplate<\/span> <span class=\"n\">template<\/span> <span class=\"o\">=<\/span> <span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">createFluentProducerTemplate<\/span><span class=\"o\">();<\/span>\r\n<span class=\"nc\">IntStream<\/span><span class=\"o\">.<\/span><span class=\"na\">rangeClosed<\/span><span class=\"o\">(<\/span><span class=\"mi\">1<\/span><span class=\"o\">,<\/span> <span class=\"mi\">5<\/span><span class=\"o\">).<\/span><span class=\"na\">forEach<\/span><span class=\"o\">(<\/span><span class=\"n\">i<\/span> <span class=\"o\">-&gt;<\/span>\r\n    <span class=\"c1\">\/\/template.withBody(i).to(\"seda:input\").send());<\/span>\r\n    <span class=\"n\">template<\/span><span class=\"o\">.<\/span><span class=\"na\">withBody<\/span><span class=\"o\">(<\/span><span class=\"n\">i<\/span><span class=\"o\">).<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"reactive-streams:input\"<\/span><span class=\"o\">).<\/span><span class=\"na\">send<\/span><span class=\"o\">());<\/span>\r\n<\/code><\/pre>\n<hr \/>\n<h2>\u54cd\u5e94\u5f0f\u6d41\uff08\u53d1\u5e03\uff09\u2192 \u9a86\u9a7c\uff08\u8ba2\u9605\uff09<\/h2>\n<ul class=\"post-ul\">Reactive Streams\u306e\u30d5\u30ed\u30fc\u304b\u3089Camel\u306e\u30b3\u30f3\u30b7\u30e5\u30fc\u30de\u30fc\u30a8\u30f3\u30c9\u30dd\u30a4\u30f3\u30c8\uff08from\uff09\u3078<\/ul>\n<pre class=\"post-pre\"><code><span class=\"nc\">CamelContext<\/span> <span class=\"n\">camel<\/span> <span class=\"o\">=<\/span> <span class=\"k\">new<\/span> <span class=\"nc\">DefaultCamelContext<\/span><span class=\"o\">();<\/span>\r\n<span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">addRoutes<\/span><span class=\"o\">(<\/span><span class=\"k\">new<\/span> <span class=\"nc\">RouteBuilder<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n    <span class=\"kd\">public<\/span> <span class=\"kt\">void<\/span> <span class=\"nf\">configure<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"n\">from<\/span><span class=\"o\">(<\/span><span class=\"s\">\"reactive-streams:input\"<\/span><span class=\"o\">)<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"stream:out\"<\/span><span class=\"o\">);<\/span>\r\n    <span class=\"o\">}<\/span>\r\n<span class=\"o\">});<\/span>\r\n<span class=\"nc\">CamelReactiveStreamsService<\/span> <span class=\"n\">rsCamel<\/span> <span class=\"o\">=<\/span> <span class=\"nc\">CamelReactiveStreams<\/span><span class=\"o\">.<\/span><span class=\"na\">get<\/span><span class=\"o\">(<\/span><span class=\"n\">camel<\/span><span class=\"o\">);<\/span>\r\n<span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">start<\/span><span class=\"o\">();<\/span>\r\n\r\n<span class=\"c1\">\/\/ Reactive Streams (pub) \u2192 Camel (sub)<\/span>\r\n<span class=\"nc\">Flowable<\/span><span class=\"o\">.<\/span><span class=\"na\">just<\/span><span class=\"o\">(<\/span><span class=\"mi\">1<\/span><span class=\"o\">,<\/span> <span class=\"mi\">2<\/span><span class=\"o\">,<\/span> <span class=\"mi\">3<\/span><span class=\"o\">,<\/span> <span class=\"mi\">4<\/span><span class=\"o\">,<\/span> <span class=\"mi\">5<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">map<\/span><span class=\"o\">(<\/span><span class=\"n\">i<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"n\">i<\/span><span class=\"o\">*<\/span><span class=\"n\">i<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">subscribe<\/span><span class=\"o\">(<\/span><span class=\"n\">rsCamel<\/span><span class=\"o\">.<\/span><span class=\"na\">streamSubscriber<\/span><span class=\"o\">(<\/span><span class=\"s\">\"input\"<\/span><span class=\"o\">,<\/span> <span class=\"nc\">Integer<\/span><span class=\"o\">.<\/span><span class=\"na\">class<\/span><span class=\"o\">));<\/span>\r\n<\/code><\/pre>\n<hr \/>\n<h2>\u4f7f\u7528\u53cd\u5e94\u5f0f\u6d41\u5b9e\u73b0Camel\u8def\u7531<\/h2>\n<ul class=\"post-ul\">\u30eb\u30fc\u30c8\u3068\u30d5\u30ed\u30fc\u306e\u30df\u30c3\u30af\u30b9\u5b9f\u88c5\u3082\u3067\u304d\u308b<\/ul>\n<pre class=\"post-pre\"><code><span class=\"nc\">CamelContext<\/span> <span class=\"n\">camel<\/span> <span class=\"o\">=<\/span> <span class=\"k\">new<\/span> <span class=\"nc\">DefaultCamelContext<\/span><span class=\"o\">();<\/span>\r\n<span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">addRoutes<\/span><span class=\"o\">(<\/span><span class=\"k\">new<\/span> <span class=\"nc\">RouteBuilder<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n    <span class=\"kd\">public<\/span> <span class=\"kt\">void<\/span> <span class=\"nf\">configure<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"n\">from<\/span><span class=\"o\">(<\/span><span class=\"s\">\"reactive-streams:input\"<\/span><span class=\"o\">)<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"stream:out\"<\/span><span class=\"o\">);<\/span>\r\n        <span class=\"n\">from<\/span><span class=\"o\">(<\/span><span class=\"s\">\"direct:output\"<\/span><span class=\"o\">)<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">log<\/span><span class=\"o\">(<\/span><span class=\"s\">\"Done: ${body}\"<\/span><span class=\"o\">);<\/span>\r\n    <span class=\"o\">}<\/span>\r\n<span class=\"o\">});<\/span>\r\n<span class=\"nc\">CamelReactiveStreamsService<\/span> <span class=\"n\">rsCamel<\/span> <span class=\"o\">=<\/span> <span class=\"nc\">CamelReactiveStreams<\/span><span class=\"o\">.<\/span><span class=\"na\">get<\/span><span class=\"o\">(<\/span><span class=\"n\">camel<\/span><span class=\"o\">);<\/span>\r\n<span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">start<\/span><span class=\"o\">();<\/span>\r\n\r\n<span class=\"c1\">\/\/ Camel route &amp; Reactive Streams flow<\/span>\r\n<span class=\"nc\">Flowable<\/span><span class=\"o\">.<\/span><span class=\"na\">fromPublisher<\/span><span class=\"o\">(<\/span><span class=\"n\">rsCamel<\/span><span class=\"o\">.<\/span><span class=\"na\">from<\/span><span class=\"o\">(<\/span><span class=\"s\">\"seda:input\"<\/span><span class=\"o\">))<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">map<\/span><span class=\"o\">(<\/span><span class=\"n\">e<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"kt\">int<\/span> <span class=\"n\">i<\/span> <span class=\"o\">=<\/span> <span class=\"n\">e<\/span><span class=\"o\">.<\/span><span class=\"na\">getMessage<\/span><span class=\"o\">().<\/span><span class=\"na\">getBody<\/span><span class=\"o\">(<\/span><span class=\"nc\">Integer<\/span><span class=\"o\">.<\/span><span class=\"na\">class<\/span><span class=\"o\">);<\/span>\r\n        <span class=\"n\">e<\/span><span class=\"o\">.<\/span><span class=\"na\">getMessage<\/span><span class=\"o\">().<\/span><span class=\"na\">setBody<\/span><span class=\"o\">(<\/span><span class=\"n\">i<\/span> <span class=\"o\">*<\/span> <span class=\"n\">i<\/span><span class=\"o\">);<\/span>\r\n        <span class=\"k\">return<\/span> <span class=\"n\">e<\/span><span class=\"o\">;<\/span>\r\n    <span class=\"o\">})<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">doOnNext<\/span><span class=\"o\">(<\/span><span class=\"n\">e<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"n\">rsCamel<\/span><span class=\"o\">.<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"stream:out\"<\/span><span class=\"o\">,<\/span> <span class=\"n\">e<\/span><span class=\"o\">))<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">subscribe<\/span><span class=\"o\">(<\/span><span class=\"n\">rsCamel<\/span><span class=\"o\">.<\/span><span class=\"na\">subscriber<\/span><span class=\"o\">(<\/span><span class=\"s\">\"direct:output\"<\/span><span class=\"o\">));<\/span>\r\n\r\n<span class=\"nc\">FluentProducerTemplate<\/span> <span class=\"n\">template<\/span> <span class=\"o\">=<\/span> <span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">createFluentProducerTemplate<\/span><span class=\"o\">();<\/span>\r\n<span class=\"nc\">IntStream<\/span><span class=\"o\">.<\/span><span class=\"na\">rangeClosed<\/span><span class=\"o\">(<\/span><span class=\"mi\">1<\/span><span class=\"o\">,<\/span> <span class=\"mi\">5<\/span><span class=\"o\">).<\/span><span class=\"na\">forEach<\/span><span class=\"o\">(<\/span><span class=\"n\">i<\/span> <span class=\"o\">-&gt;<\/span>\r\n    <span class=\"n\">template<\/span><span class=\"o\">.<\/span><span class=\"na\">withBody<\/span><span class=\"o\">(<\/span><span class=\"n\">i<\/span><span class=\"o\">).<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"seda:input\"<\/span><span class=\"o\">).<\/span><span class=\"na\">send<\/span><span class=\"o\">());<\/span>\r\n<\/code><\/pre>\n<hr \/>\n<h2>\u99f1\u99dd\u7684\u80cc\u58d3\u652f\u6301<\/h2>\n<ul class=\"post-ul\">\u51e6\u7406\u4e2d\uff08in-flight\uff09\u30a8\u30af\u30b9\u30c1\u30a7\u30f3\u30b8\u306e\u6570\u3092\u5236\u9650\u3059\u308b\u3053\u3068\u3067back pressure\u3092\u5b9f\u73fe\u3067\u304d\u308b<\/ul>\n<h3>\u5236\u7247\u4eba\u65b9<\/h3>\n<p>ThrottlingInflightRoutePolicy\u30dd\u30ea\u30b7\u30fc<\/p>\n<p>\u30b9\u30ed\u30c3\u30c8\u30eb\u4e2d\u306f\u30eb\u30fc\u30c8\u304c\u4e00\u6642\u505c\u6b62\u3059\u308b<\/p>\n<pre class=\"post-pre\"><code><span class=\"nc\">ThrottlingInflightRoutePolicy<\/span> <span class=\"n\">policy<\/span> <span class=\"o\">=<\/span> <span class=\"k\">new<\/span> <span class=\"nc\">ThrottlingInflightRoutePolicy<\/span><span class=\"o\">();<\/span>\r\n<span class=\"n\">policy<\/span><span class=\"o\">.<\/span><span class=\"na\">setMaxInflightExchanges<\/span><span class=\"o\">(<\/span><span class=\"mi\">10<\/span><span class=\"o\">);<\/span>\r\n\r\n<span class=\"n\">from<\/span><span class=\"o\">(<\/span><span class=\"s\">\"jms:queue1\"<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">routePolicy<\/span><span class=\"o\">(<\/span><span class=\"n\">policy<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"reactive-streams:flow1\"<\/span><span class=\"o\">);<\/span>\r\n<\/code><\/pre>\n<p>backpressureStrategy\u30aa\u30d7\u30b7\u30e7\u30f3<\/p>\n<p>BUFFER, LATEST, OLDEST<\/p>\n<pre class=\"post-pre\"><code><span class=\"n\">from<\/span><span class=\"o\">(<\/span><span class=\"s\">\"jms:queue2\"<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"reactive-streams:flow2?backpressureStrategy=LATEST\"<\/span><span class=\"o\">);<\/span>\r\n<\/code><\/pre>\n<h3>\u6d88\u8d39\u8005\u65b9<\/h3>\n<p>maxInflightExchanges\u30aa\u30d7\u30b7\u30e7\u30f3<\/p>\n<pre class=\"post-pre\"><code><span class=\"n\">from<\/span><span class=\"o\">(<\/span><span class=\"s\">\"reactive-streams:numbers?maxInflightExchanges=10\"<\/span><span class=\"o\">)<\/span>\r\n    <span class=\"o\">.<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"direct:endpoint\"<\/span><span class=\"o\">);<\/span>\r\n<\/code><\/pre>\n<hr \/>\n<h1>\u9a86\u9a7c + Vert.x<\/h1>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">Vert.x\u306eEventBus\u3068\u30a4\u30d9\u30f3\u30c8\u306e\u3084\u308a\u53d6\u308a\u3092\u53ef\u80fd\u306b\u3059\u308b<\/ul>\n<\/li>\n<\/ul>\n<p>vertx:xxxxx[?options]<\/p>\n<hr \/>\n<h2>Vert.x\u662f\u4ec0\u4e48<\/h2>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">JVM\u7248\u306eNode.js\u306e\u3088\u3046\u306a\u3082\u306e<\/ul>\n<\/li>\n<\/ul>\n<p>Verticle\uff08= Actor\uff09\u3068\u30a4\u30d9\u30f3\u30c8\u30d0\u30b9<\/p>\n<pre class=\"post-pre\"><code><span class=\"kn\">import<\/span> <span class=\"nn\">io.vertx.core.Vertx<\/span><span class=\"o\">;<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">io.vertx.core.eventbus.EventBus<\/span><span class=\"o\">;<\/span>\r\n\r\n<span class=\"kd\">class<\/span> <span class=\"nc\">HttpServer<\/span> <span class=\"o\">{<\/span>\r\n    <span class=\"kd\">public<\/span> <span class=\"kd\">static<\/span> <span class=\"kt\">void<\/span> <span class=\"nf\">main<\/span><span class=\"o\">(<\/span><span class=\"nc\">String<\/span><span class=\"o\">[]<\/span> <span class=\"n\">args<\/span><span class=\"o\">)<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"nc\">Vertx<\/span> <span class=\"n\">vertx<\/span> <span class=\"o\">=<\/span> <span class=\"nc\">Vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">vertx<\/span><span class=\"o\">();<\/span>\r\n        <span class=\"n\">vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">deployVerticle<\/span><span class=\"o\">(<\/span><span class=\"k\">new<\/span> <span class=\"nc\">LoggingVerticle<\/span><span class=\"o\">());<\/span>\r\n        <span class=\"nc\">EventBus<\/span> <span class=\"n\">eventBus<\/span> <span class=\"o\">=<\/span> <span class=\"n\">vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">eventBus<\/span><span class=\"o\">();<\/span>\r\n        <span class=\"n\">vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">createHttpServer<\/span><span class=\"o\">()<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">requestHandler<\/span><span class=\"o\">(<\/span><span class=\"n\">req<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"o\">{<\/span>\r\n                <span class=\"n\">eventBus<\/span><span class=\"o\">.<\/span><span class=\"na\">send<\/span><span class=\"o\">(<\/span><span class=\"s\">\"logging\"<\/span><span class=\"o\">,<\/span> <span class=\"s\">\"Got request: \"<\/span> <span class=\"o\">+<\/span> <span class=\"n\">req<\/span><span class=\"o\">.<\/span><span class=\"na\">method<\/span><span class=\"o\">()<\/span> <span class=\"o\">+<\/span> <span class=\"s\">\" \"<\/span> <span class=\"o\">+<\/span> <span class=\"n\">req<\/span><span class=\"o\">.<\/span><span class=\"na\">uri<\/span><span class=\"o\">());<\/span>\r\n                <span class=\"n\">req<\/span><span class=\"o\">.<\/span><span class=\"na\">response<\/span><span class=\"o\">().<\/span><span class=\"na\">end<\/span><span class=\"o\">(<\/span><span class=\"s\">\"Hello!\"<\/span><span class=\"o\">);<\/span>\r\n            <span class=\"o\">})<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">listen<\/span><span class=\"o\">(<\/span><span class=\"mi\">8888<\/span><span class=\"o\">);<\/span>\r\n\r\n        <span class=\"c1\">\/\/ ... \u30af\u30ed\u30fc\u30ba\u51e6\u7406<\/span>\r\n    <span class=\"o\">}<\/span>\r\n<span class=\"o\">}<\/span>\r\n\r\n<span class=\"kd\">class<\/span> <span class=\"nc\">LoggingVerticle<\/span> <span class=\"kd\">extends<\/span> <span class=\"nc\">AbstractVerticle<\/span> <span class=\"o\">{<\/span>\r\n    <span class=\"kd\">public<\/span> <span class=\"kt\">void<\/span> <span class=\"nf\">start<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"n\">vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">eventBus<\/span><span class=\"o\">().&lt;<\/span><span class=\"nc\">String<\/span><span class=\"o\">&gt;<\/span><span class=\"n\">consumer<\/span><span class=\"o\">(<\/span><span class=\"s\">\"logging\"<\/span><span class=\"o\">,<\/span>\r\n            <span class=\"n\">message<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"n\">log<\/span><span class=\"o\">.<\/span><span class=\"na\">info<\/span><span class=\"o\">(<\/span><span class=\"n\">message<\/span><span class=\"o\">.<\/span><span class=\"na\">body<\/span><span class=\"o\">()));<\/span>\r\n    <span class=\"o\">}<\/span>\r\n<span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<hr \/>\n<h2>\u9a86\u9a7c Vert.x<\/h2>\n<ul class=\"post-ul\">Camel\u304b\u3089Vert.x\u306e\u30a4\u30d9\u30f3\u30c8\u30d0\u30b9\u3001Vert.x\u30a4\u30d9\u30f3\u30c8\u30d0\u30b9\u304b\u3089Camel\u3078\u306e\u53cc\u65b9\u5411\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u30f3\u30b0\u304c\u53ef\u80fd<\/ul>\n<pre class=\"post-pre\"><code><span class=\"kd\">class<\/span> <span class=\"nc\">CamelHttpServer<\/span> <span class=\"o\">{<\/span>\r\n    <span class=\"kd\">public<\/span> <span class=\"kd\">static<\/span> <span class=\"kt\">void<\/span> <span class=\"nf\">main<\/span><span class=\"o\">(<\/span><span class=\"nc\">String<\/span><span class=\"o\">[]<\/span> <span class=\"n\">args<\/span><span class=\"o\">)<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"nc\">Vertx<\/span> <span class=\"n\">vertx<\/span> <span class=\"o\">=<\/span> <span class=\"nc\">Vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">vertx<\/span><span class=\"o\">();<\/span>\r\n        <span class=\"n\">vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">deployVerticle<\/span><span class=\"o\">(<\/span><span class=\"k\">new<\/span> <span class=\"nc\">LoggingVerticle<\/span><span class=\"o\">());<\/span>\r\n        <span class=\"nc\">EventBus<\/span> <span class=\"n\">eventBus<\/span> <span class=\"o\">=<\/span> <span class=\"n\">vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">eventBus<\/span><span class=\"o\">();<\/span>\r\n        <span class=\"n\">vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">createHttpServer<\/span><span class=\"o\">()<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">requestHandler<\/span><span class=\"o\">(<\/span><span class=\"n\">req<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"o\">{<\/span>\r\n                <span class=\"n\">eventBus<\/span><span class=\"o\">.<\/span><span class=\"na\">send<\/span><span class=\"o\">(<\/span><span class=\"s\">\"camel-logging\"<\/span><span class=\"o\">,<\/span> <span class=\"s\">\"Got request: \"<\/span> <span class=\"o\">+<\/span> <span class=\"n\">req<\/span><span class=\"o\">.<\/span><span class=\"na\">method<\/span><span class=\"o\">()<\/span> <span class=\"o\">+<\/span> <span class=\"s\">\" \"<\/span> <span class=\"o\">+<\/span> <span class=\"n\">req<\/span><span class=\"o\">.<\/span><span class=\"na\">uri<\/span><span class=\"o\">());<\/span>\r\n                <span class=\"n\">req<\/span><span class=\"o\">.<\/span><span class=\"na\">response<\/span><span class=\"o\">().<\/span><span class=\"na\">end<\/span><span class=\"o\">(<\/span><span class=\"s\">\"Hello!\"<\/span><span class=\"o\">);<\/span>\r\n            <span class=\"o\">})<\/span>\r\n            <span class=\"o\">.<\/span><span class=\"na\">listen<\/span><span class=\"o\">(<\/span><span class=\"mi\">8888<\/span><span class=\"o\">);<\/span>\r\n\r\n        <span class=\"nc\">CamelContext<\/span> <span class=\"n\">camel<\/span> <span class=\"o\">=<\/span> <span class=\"k\">new<\/span> <span class=\"nc\">DefaultCamelContext<\/span><span class=\"o\">();<\/span>\r\n        <span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">getComponent<\/span><span class=\"o\">(<\/span><span class=\"s\">\"vertx\"<\/span><span class=\"o\">,<\/span> <span class=\"nc\">VertxComponent<\/span><span class=\"o\">.<\/span><span class=\"na\">class<\/span><span class=\"o\">).<\/span><span class=\"na\">setVertx<\/span><span class=\"o\">(<\/span><span class=\"n\">vertx<\/span><span class=\"o\">);<\/span>\r\n        <span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">addRoutes<\/span><span class=\"o\">(<\/span><span class=\"k\">new<\/span> <span class=\"nc\">RouteBuilder<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n            <span class=\"kd\">public<\/span> <span class=\"kt\">void<\/span> <span class=\"nf\">configure<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n                <span class=\"c1\">\/\/ Vert.x \u2192 Camel<\/span>\r\n                <span class=\"n\">from<\/span><span class=\"o\">(<\/span><span class=\"s\">\"vertx:camel-logging\"<\/span><span class=\"o\">)<\/span>\r\n                    <span class=\"o\">.<\/span><span class=\"na\">log<\/span><span class=\"o\">(<\/span><span class=\"s\">\"body = ${body}\"<\/span><span class=\"o\">)<\/span>\r\n                    <span class=\"o\">.<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"direct:logging\"<\/span><span class=\"o\">);<\/span>\r\n                <span class=\"c1\">\/\/ Camel \u2192 Vert.x<\/span>\r\n                <span class=\"n\">from<\/span><span class=\"o\">(<\/span><span class=\"s\">\"direct:logging\"<\/span><span class=\"o\">)<\/span>\r\n                    <span class=\"o\">.<\/span><span class=\"na\">to<\/span><span class=\"o\">(<\/span><span class=\"s\">\"vertx:logging\"<\/span><span class=\"o\">);<\/span>\r\n            <span class=\"o\">}<\/span>\r\n        <span class=\"o\">});<\/span>\r\n        <span class=\"n\">camel<\/span><span class=\"o\">.<\/span><span class=\"na\">start<\/span><span class=\"o\">();<\/span>\r\n\r\n        <span class=\"c1\">\/\/ ... \u30af\u30ed\u30fc\u30ba\u51e6\u7406<\/span>\r\n    <span class=\"o\">}<\/span>\r\n<span class=\"o\">}<\/span>\r\n\r\n<span class=\"kd\">class<\/span> <span class=\"nc\">LoggingVerticle<\/span> <span class=\"kd\">extends<\/span> <span class=\"nc\">AbstractVerticle<\/span> <span class=\"o\">{<\/span>\r\n    <span class=\"kd\">public<\/span> <span class=\"kt\">void<\/span> <span class=\"nf\">start<\/span><span class=\"o\">()<\/span> <span class=\"o\">{<\/span>\r\n        <span class=\"n\">vertx<\/span><span class=\"o\">.<\/span><span class=\"na\">eventBus<\/span><span class=\"o\">().&lt;<\/span><span class=\"nc\">String<\/span><span class=\"o\">&gt;<\/span><span class=\"n\">consumer<\/span><span class=\"o\">(<\/span><span class=\"s\">\"logging\"<\/span><span class=\"o\">,<\/span>\r\n            <span class=\"n\">message<\/span> <span class=\"o\">-&gt;<\/span> <span class=\"n\">log<\/span><span class=\"o\">.<\/span><span class=\"na\">info<\/span><span class=\"o\">(<\/span><span class=\"n\">message<\/span><span class=\"o\">.<\/span><span class=\"na\">body<\/span><span class=\"o\">()));<\/span>\r\n    <span class=\"o\">}<\/span>\r\n<span class=\"o\">}<\/span>\r\n<\/code><\/pre>\n<hr \/>\n<h2>Vert.x\u76f8\u5173\u7ec4\u4ef6<\/h2>\n<div>\n<div class=\"post-table\">\u30b3\u30f3\u30dd\u30fc\u30cd\u30f3\u30c8\u8aac\u660e<a href=\"https:\/\/camel.apache.org\/components\/latest\/vertx-http-component.html\" target=\"_blank\" rel=\"nofollow noopener\">camel-vertx-http<\/a><a href=\"https:\/\/vertx.io\/docs\/vertx-web-client\/java\/\" target=\"_blank\" rel=\"nofollow noopener\">Vert.x Web Client<\/a>\u306b\u3088\u308bHTTP\u30a8\u30f3\u30c9\u30dd\u30a4\u30f3\u30c8\u5b9f\u88c5\uff08Producer\u306e\u307f\uff09<a href=\"https:\/\/camel.apache.org\/components\/latest\/vertx-kafka-component.html\" target=\"_blank\" rel=\"nofollow noopener\">camel-vertx-kafka<\/a><a href=\"https:\/\/vertx.io\/docs\/vertx-kafka-client\/java\/\" target=\"_blank\" rel=\"nofollow noopener\">Vert.x Kafka Client<\/a>\u306b\u3088\u308bKafka\u3068\u306e\u63a5\u7d9a<a href=\"https:\/\/camel.apache.org\/components\/latest\/vertx-websocket-component.html\" target=\"_blank\" rel=\"nofollow noopener\">camel-vertx-websocket<\/a>Vert.x WebSocket\u6a5f\u80fd\u306b\u3088\u308bWebSocket\u30a8\u30f3\u30c9\u30dd\u30a4\u30f3\u30c8\u306e\u5b9f\u88c5<a href=\"https:\/\/vertx.io\/docs\/vertx-camel-bridge\/java\/\" target=\"_blank\" rel=\"nofollow noopener\">Vert.x Camel Bridge<\/a>Camel\u3067\u306a\u304fVert.x\u5074\u304b\u3089\u306eCamel\u3078\u306e\u30d6\u30ea\u30c3\u30b8\uff08\u3061\u306a\u307f\u306b\u4f5c\u8005\u306fCamel\u306eClaus\uff09<\/div>\n<\/div>\n<hr \/>\n<h1>\u6587\u737b\u53c3\u8003<\/h1>\n<p>Camel in Action, 2nd Edition \u2014 Chapter 20: Reactive Camel<\/p>\n<hr \/>\n<h1>\u7ed3\u675f<\/h1>\n","protected":false},"excerpt":{"rendered":"<p>\u603b\u7ed3 \u30ea\u30a2\u30af\u30c6\u30a3\u30d6\u30d7\u30ed\u30b0\u30e9\u30df\u30f3\u30b0\u3068\u306f &nbsp; Camel + Reactive Streams &#038;nbs [&hellip;]<\/p>\n","protected":false},"author":6,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-36704","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"<!-- This site is optimized with the Yoast SEO Premium plugin v21.5 (Yoast SEO v21.5) - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>Apache Camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Apache Camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b\" \/>\n<meta property=\"og:description\" content=\"\u603b\u7ed3 \u30ea\u30a2\u30af\u30c6\u30a3\u30d6\u30d7\u30ed\u30b0\u30e9\u30df\u30f3\u30b0\u3068\u306f &nbsp; Camel + Reactive Streams &amp;nbs [&hellip;]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2024-02-14T22:43:25+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-28T16:28:46+00:00\" \/>\n<meta name=\"author\" content=\"\u6587, \u7fd4\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u6587, \u7fd4\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"3 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/\",\"name\":\"Apache Camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2024-02-14T22:43:25+00:00\",\"dateModified\":\"2024-04-28T16:28:46+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/64d5cc7727fffbff2f9a2a8da1de3e5c\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Apache Camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/64d5cc7727fffbff2f9a2a8da1de3e5c\",\"name\":\"\u6587, \u7fd4\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/920c3d673e0bccacc98e5e6b7149bb3c22edd8d39cb753e5d7d7e471498118a1?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/920c3d673e0bccacc98e5e6b7149bb3c22edd8d39cb753e5d7d7e471498118a1?s=96&d=mm&r=g\",\"caption\":\"\u6587, \u7fd4\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/wenxiang\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"Apache Camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b\/","og_locale":"zh_CN","og_type":"article","og_title":"Apache Camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b","og_description":"\u603b\u7ed3 \u30ea\u30a2\u30af\u30c6\u30a3\u30d6\u30d7\u30ed\u30b0\u30e9\u30df\u30f3\u30b0\u3068\u306f &nbsp; Camel + Reactive Streams &nbs [&hellip;]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2024-02-14T22:43:25+00:00","article_modified_time":"2024-04-28T16:28:46+00:00","author":"\u6587, \u7fd4","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u6587, \u7fd4","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"3 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/","name":"Apache Camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2024-02-14T22:43:25+00:00","dateModified":"2024-04-28T16:28:46+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/64d5cc7727fffbff2f9a2a8da1de3e5c"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"Apache Camel\u548c\u53cd\u5e94\u5f0f\u7f16\u7a0b"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/64d5cc7727fffbff2f9a2a8da1de3e5c","name":"\u6587, \u7fd4","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/920c3d673e0bccacc98e5e6b7149bb3c22edd8d39cb753e5d7d7e471498118a1?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/920c3d673e0bccacc98e5e6b7149bb3c22edd8d39cb753e5d7d7e471498118a1?s=96&d=mm&r=g","caption":"\u6587, \u7fd4"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/wenxiang\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/apache-camel%e5%92%8c%e5%8f%8d%e5%ba%94%e5%bc%8f%e7%bc%96%e7%a8%8b\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/36704","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/6"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=36704"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/36704\/revisions"}],"predecessor-version":[{"id":68348,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/36704\/revisions\/68348"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=36704"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=36704"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=36704"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}