PROSAGA码农传奇-rabbitmq-在nodejs中等待与Rabbit的正确连接

在nodejs中等待与Rabbit的正确连接

作者: 诸葛神侯
发布时间: 2024-12-26 04:40:01 (2月前)
转自：

<div class =“post-text”itemprop =“text”>
  <H1>
    包裹你的
    <a href="https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Promise" rel="nofollow noreferrer">
       <code>
        Promise
      </code>
    </A>
     在里面
    <a href="https://github.com/ReactiveX/rxjs" rel="nofollow noreferrer">
       <code>
        Observable
      </code>
    </A>
  </H1>
  <P>
     <code>
      Promise
    </code>
     不是为了处理
    <EM>
      “重试”
    </EM>
     逻辑。如果你想这样做，你应该调查一下
    的<strong>
      观测
    </强>
     使用
    <a href="https://github.com/ReactiveX/rxjs" rel="nofollow noreferrer">
       <code>
        rxjs
      </code>
       图书馆
    </A>
    。这将允许您在捕获错误时使用任意时间间隔重试。
  </p>
  <P>
  </p>
  <div class =“snippet”data-lang =“js”data-hide =“false”data-console =“true”data-babel =“false”>
    <div class =“snippet-code”>
       <pre class="snippet-code-js lang-js prettyprint-override">
        <code>
          const { from, interval, of } = rxjs;
const { catchError, mergeMap, tap, skipWhile, take } = rxjs.operators;

const THRESHOLD = 3;
const RETRY_INTERVAL = 1000;

// Equivalent to 'amqp.connect'
const functionThatThrows = number =>
  number < THRESHOLD
    ? Promise.reject(new Error("ERROR"))
    : Promise.resolve("OK");

// Equivalent to `getConnect`
const getConnect = () =>
  interval(RETRY_INTERVAL)
    .pipe(
      mergeMap(x => from(functionThatThrows(x)).pipe(catchError(e => of(e)))),
      skipWhile(x => {
        const isError = x instanceof Error;
        if (isError) console.log('Found error. Retrying...');
        return isError;
      }),
      take(1)
    ).toPromise();

// Resolve only if the inner Promise is resolved
getConnect().then(console.log);
        </code>
      </pre>
       <pre class="snippet-code-html lang-html prettyprint-override">
        <code>
          <script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.4.0/rxjs.umd.min.js"></script>
        </code>
      </pre>
    </DIV>
  </DIV>
  <P>
  </p>
  <H1>
    说明
  </H1>
  <OL>
    <LI>
      用。创建一个源
       <code>
        interval
      </code>
       的
       <code>
        1000
      </code>
      。这意味着它将每秒重试一次
    </LI>
    <LI>
      打电话给你
       <code>
        amqp.connect
      </code>
       这相当于
       <code>
        functionThatThrows
      </code>
       在我的例子中
    </LI>
    <LI>
      使用获取错误
       <code>
        catchError
      </code>
       操作员并将其归还
    </LI>
    <LI>
      在返回的对象出错时跳过。这将允许你
      的<strong>
        解决只有你的
         <code>
          Promise
        </code>
         已经解决，但没有被拒绝
      </强>
    </LI>
    <LI>
      使用第一个解析结果
       <code>
        take(1)
      </code>
    </LI>
    <LI>
      转换你的
      <EM>
        可观察
      </EM>
       使用的承诺
       <code>
        toPromise
      </code>
       实用功能
    </LI>
    <LI>
      打电话给你的功能并附上
       <code>
        then
      </code>
       就像你用标准做的那样
       <code>
        Promise
      </code>
    </LI>
  </醇>
</DIV>