promise chain中的重试功能
基础概念
Promise 链是一种处理异步操作的方式，它允许你将多个异步操作串联起来，每个操作在前一个操作完成后执行。Promise 链中的重试功能是指在某个异步操作失败后，自动重新尝试执行该操作，直到成功或达到最大重试次数。
相关优势
- 提高可靠性：通过重试机制，可以减少因临时性错误导致的失败。
- 简化代码：相比于手动编写重试逻辑，使用现成的重试功能可以使代码更简洁。
- 灵活性：可以配置重试次数、重试间隔等参数，以适应不同的应用场景。
类型
- 固定间隔重试：每次重试之间的时间间隔是固定的。
- 指数退避重试：每次重试之间的时间间隔按指数增长，适用于处理可能产生累积效应的错误。
- 随机间隔重试：每次重试之间的时间间隔是随机的，可以减少多个请求同时重试导致的冲突。
应用场景
- 网络请求：在发送 HTTP 请求时，如果因为网络问题导致请求失败，可以自动重试。
- 数据库操作：在执行数据库操作时，如果因为数据库暂时不可用导致操作失败，可以自动重试。
- 第三方服务调用：在调用第三方服务时，如果因为服务暂时不可用导致调用失败，可以自动重试。
示例代码
以下是一个使用 JavaScript 实现的 Promise 链中的重试功能的示例：
function retry(fn, retries = 3, delay = 1000) {
return new Promise((resolve, reject) => {
fn()
.then(resolve)
.catch((error) => {
if (retries === 0) {
reject(error);
} else {
setTimeout(() => {
retry(fn, retries - 1, delay).then(resolve).catch(reject);
}, delay);
}
});
});
}
// 示例异步操作
function asyncOperation() {
return new Promise((resolve, reject) => {
setTimeout(() => {
if (Math.random() > 0.5) {
resolve('成功');
} else {
reject('失败');
}
}, 1000);
});
}
// 使用重试功能
retry(asyncOperation)
.then((result) => {
console.log(result);
})
.catch((error) => {
console.error(error);
});参考链接
常见问题及解决方法
- 无限重试：如果重试次数没有限制，可能会导致无限重试。解决方法是设置最大重试次数。
- 重试间隔过短：如果重试间隔过短，可能会导致服务器压力过大。解决方法是使用指数退避或增加重试间隔。
- 重试逻辑复杂：手动编写重试逻辑可能会使代码变得复杂。解决方法是使用现成的重试库或封装重试功能。
通过以上方法，可以有效地在 Promise 链中实现重试功能，提高系统的可靠性和稳定性。
相关·内容
3回答
如何链接异步方法
、、
我编写的API有几个异步方法，它们不返回值，但仍然应该按照调用的顺序执行。我想从最终用户抽象出等待解决方案，以便他们可以链接方法调用，并期望在解析前一个承诺之后执行每个承诺，如下所示：
api = new Api();
api.doAsync().doAnotherAsync().doAThirdAsync();
从这些方法中获得值并不重要，只是它们是按顺序执行的。我试过使用链接结构，但它一直不可靠。
class Api {
resolvingMethodChain = false;
constructor() {
this._methodChain = {
浏览 0提问于2018-04-11得票数 4
回答已采纳
1回答
数组中有可变的数据计数。我想做点什么，做这件事
function tryThis(num: number): Promise<any> {
return new Promise ((resolve, reject) => {
if(num == 3){
resolve()
}else{
reject();
}
}
}
let arrayOfSomething : Array<number> = [1,2,3,4];
let chain;
// create the chain
arrayOfSomethi
浏览 1提问于2017-10-06得票数 0
回答已采纳
下面是带有重试的Spring配置：
<int:chain input-channel="sdCreationChannel" output-channel="debugLogger">
<int:poller fixed-delay="500" />
<int:filter ref="sdIntegrationExistingRequestSentFilter" method="filter"/>
<int:service-activator ref
浏览 1提问于2016-01-11得票数 2
回答已采纳
3回答
我无法弄清楚如何将嵌套的承诺链分解为主承诺链。这是我的代码：
//Main Promise chain
let promiseMain = Promise.resolve(1)
.then(result => functionA())
.then(result => nestedChain()).catch((error) => {
console.log(error);
})
.then(result => functionC())
//chain error handler
浏览 0提问于2018-12-10得票数 0
回答已采纳
2回答
其思想是按顺序迭代数组，但并行处理子数组中的每个项。
一旦记录#1被并行处理，然后它移动到记录#2，并并行处理它的项，等等。基本上，这是顺序性和并行性的结合。
所有的连接结果都是一个一维数组和显示。(待决)
如果输入包含数组数组。
var items = [
["item1", "item2"],
["item3", "item4"],
["item5", "item6"],
["item7", "item8"],
浏览 0提问于2018-04-09得票数 1
回答已采纳
4回答
我有一个返回promise的func1函数。在func2中，我已经启动了promise chain。我想在这里做的是，我想在旧的promise链中使用func1 resolve message，并且我希望这段代码不那么复杂。在func2中加入func1 promise to promise链的最佳方式是什么
var func1 = function(){
return new promise(function(resolve, reject){
//some operations here
});
};
var func2 = function(){
promise.re
浏览 3提问于2016-05-01得票数 1
我遇到过多个应用程序，其中使用catch比使用rejectHandler更好。更喜欢
new Promise.then(resolveHandler).catch()
而不是
new Promise().then(resolveHandler, rejectHandler).catch()
有什么特别的原因吗？？
我发现
new Promise().then(resolveHandler, rejectHandler).catch()
变得更有用是因为
我可以使用rejectHandler来解决设计的/预期的错误场景，其中调用了Promise.reject。
我可以使用catch块来解
浏览 1提问于2018-10-04得票数 5
回答已采纳
我的问题与非常相似，但我无法让它起作用：
问题：
我有一个Javascript程序，需要运行在IE11和Chrome。
它有一个函数列表，我需要按顺序执行这些函数。
每个函数都返回一个承诺。的工作范围是我可以“等待”直到所有函数完成后才继续工作。但这并不能保证每个函数都按顺序运行。这是必不可少的。
我尝试过使用，但是我还没有找到正确使用它的方法。
因为我需要在IE11中运行，所以不能使用像“箭头函数”这样的ES6特性。
这是我的代码：
<script>
var fn = function(arg) {
return new Promise (func
浏览 0提问于2018-05-09得票数 2
回答已采纳
在promise库Q中，您可以执行以下操作来按顺序链接promise：
var items = ['one', 'two', 'three'];
var chain = Q();
items.forEach(function (el) {
chain = chain.then(foo(el));
});
return chain;
但是，以下内容不适用于$q
var items = ['one', 'two', 'three'];
var chain = $q();
items.forEach(
浏览 81提问于2014-09-07得票数 15
回答已采纳
1回答
在承诺中的ajax调用中添加重试
、、、、
在拒绝下列代码的错误之前，需要实现n次重试：
const self = {
fetchPreAuthnConfig: (data) => {
return new Promise((resolve, reject) => {
$.ajax({
url: preAuthnEndpoint,
type: 'POST',
contentType: 'application/json',
dataType: 'json',
data: J
浏览 11提问于2022-06-03得票数 0
3回答
你好啊，
我目前正在进行我的一个项目，使用带有mongo数据存储的节点服务器。我目前正在编写一些函数来填充数据库。
数据库中的对象包括用户、班级、学年、学生评分等。
创建这些对象的所有函数都是这样实现的：
function popUser(users){
chain = [];
users.forEach((v,i,a)=>{
let p = new Promise(function(res,rej){
let newU = new User(v);
newU.
浏览 0提问于2018-10-11得票数 0
回答已采纳
是否有办法保证Promise.all在内部承诺的then链之后得到解决？
示例：
const promiseOne = new Promise((resolve, reject) => {
setTimeout(function(){
console.log('promiseOne after 1 second')
resolve()
}, 1000)
}).then(()=> {
setTimeout(function(){
console.log('promiseOne then chain, after 2 seco
浏览 6提问于2017-11-03得票数 2
回答已采纳
我有一系列的承诺是这样的：
var chain = Promise.resolve(); // execution starts immediately
for (var i = 0; i < 100; i++) {
var promise = new Promise(...) // build another one
chain = chain.then(promise);
}
我想在它完全建立之后(而不是像调用Promise.resolve()那样立即开始)手动开始它的执行，有什么技术可以这样做呢？
浏览 4提问于2016-01-03得票数 1
回答已采纳
1回答
假设我想在TypeScript中实现一个类型化函数链，但是在本例中，调用函数会从返回类型中删除该函数。例如：
type Omit<T, K> = Pick<T, Exclude<keyof T, K>>;
interface Chainable {
execute: () => Promise<void>;
}
interface Chain1 extends Chainable {
chain1?: () => Omit<this, 'chain1'>;
}
interface Chain2
浏览 1提问于2018-12-12得票数 4
回答已采纳
1回答
有没有其他推荐的接口来检测浏览器是否支持视频的AutoPlay？
我正在尝试做一种方式，如果AutoPlay功能是允许的，维斯蒂亚播放器代码与自动播放将被加载。在AutoPlay不被允许的情况下，我正在尝试启动带有静音功能的视频自动播放的Wistia播放器代码，这种方式在所有浏览器上都能很好地工作。
我使用了modernizr，它工作得很好，但它需要更多的时间来显示视频。
我尝试使用的另一种方式是Javascript Promise，但还没有在Wistia代码中获得成功。除了这两种方法之外，还有什么建议吗？
浏览 5提问于2018-01-24得票数 0
2回答
改进了处理承诺内部回调的方法
、、、、
我有以下在promises中使用callbacks的代码
const clue = 'someValue';
const myFunction = (someParam, callback) => {
someAsyncOperation(someParam) // this function returns an array
.then((array) => {
if (array.includes(clue)){
callback(null, array); // Callback with 'S
浏览 30提问于2018-09-03得票数 1
回答已采纳
2回答
我试图在a+模式下打开2个文件，然后尝试读取它们的内容并将其发送回用户。我使用嵌套回调实现了它，但我想尝试使用承诺来实现它，因此我编写了以下代码：
var chain1 = [];
var c1Promise1 = new Promise(func(res,rej){
fs.open('path','a+',func(err,fd){
if(err)
{rej(err)}
else
{res(fd)}
})
chain1.push(c1Promise1)
//Sa
浏览 4提问于2017-05-26得票数 0
回答已采纳
1回答
我有一个上传模块，可以连续上传一组文件。只有在上一次上传完成后，才能开始上传。
构建一个promise链来实现这一点：
let chain = Promise.resolve();
files.forEach(file => {
chain = chain.then(() => upload(file)); // upload returns a promise
});
chain.then(() => console.log('Files uploaded'));
我想确保这个链背靠背地执行upload()。我如何测试它？
浏览 2提问于2016-03-23得票数 0
我正在学习JavaScript中的承诺，并遇到了一些奇怪的事情
const successFunc = msg => {
console.log(`Success ${msg}`);
};
const failFunc = msg => {
console.log(`Fail ${msg}`);
};
// create a promise object
// inside the promise object, there is a logic gate inside.
const promise = new Promise((resolve, rejec
浏览 4提问于2019-12-31得票数 0
回答已采纳
我需要在webdriverJS测试脚本中执行一些节点请求命令，因为这些命令不会进入webdriverJS命令队列，我将它们包装在.then()函数中(以处理异步)。
例如：
var webdriver = require('selenium-webdriver');
// create webdriver instance so promise chain can be setup
var promise_builder = new webdriver.Builder().withCapabilities(webdriver.Capabilities.chrome()).
浏览 1提问于2015-10-05得票数 0
2回答
这是我的代码：
let promise = new Promise(( resolve ) => {
let dataArray = d3.csvParse(csvData);
return resolve(dataArray);
});
promise.then(( dataArray: Array<Object> ) => {
return _(dataArray).transform(( result, item, name ) => {
result[ item.di
浏览 3提问于2017-01-15得票数 0
回答已采纳
2回答
在为我的云功能启用了之后，我想知道它将重试的所有情况是什么。
在我看来是自相矛盾的。因此，我认为我不明白这一点。
我认为，以下内容意味着启用了“在失败时重试”的函数也将对致命错误进行重试：
云函数不理解不应该重试的致命错误。
但是，在这种情况下捕获错误并使用Promise.reject有什么意义呢？
我试图使用Promise.reject来取消对云函数的重试，但是没有发生这种情况。
return Promise.reject(..) // will retry
throw Error() // will retry
如果该功能没有重新部署，两人都将重试一周。
在我看来，这似乎是致命的错
浏览 2提问于2019-06-18得票数 3
回答已采纳
1回答
如果我处理一个任意值必须映射到promises的数组，并且在执行下一个调用之前等待前一个调用完成是至关重要的，我通常遵循以下模式： const later = ms =>
new Promise(resolve =>
setTimeout(_ => resolve(console.log(ms)), ms));
console.log('chain start')
let chain = Promise.resolve();
[1, 2, 3, ...].forEach(val =>
chain = chain.then(la
浏览 23提问于2019-09-10得票数 0
1回答
我正在尝试创建一个通用的"retry“函数，它接受一个promise对象，并在最终解析或拒绝之前将promise回放一定次数。
我已经编写了一段代码，它接受一组promises并按顺序执行它们，直到一个成功，或者它们都失败。
var first = function(promiseArr){
return promiseArr.reduce(function (prev, next) {
return prev.catch(()=>next)
});
};
first([Promise.reject("1"), Promise
浏览 11提问于2016-08-20得票数 3
1回答
伙计们：
最近我遇到了一个问题，让我们先看看我的代码：
var foo = function () {
var promise = new Promise(function (resolve, reject) {
request.post(
someAddress,
{ form: someData },
function (error, res, body) {
responseHandler(error, res, body, resolve, reject
浏览 3提问于2016-08-16得票数 1
我希望下面的代码在控制台上打印一个数字，然后等待一秒钟，然后打印另一个数字。相反，它会立即打印所有10个数字，然后等待10秒。创建一个按照描述的行为的promise链的正确方法是什么？
function getProm(v) {
return new Promise(resolve => {
console.log(v);
resolve();
})
}
function Wait() {
return new Promise(r => setTimeout(r, 1000))
}
function createChain
浏览 3提问于2017-07-07得票数 30
回答已采纳
2回答
我有一些困难，得到一个重试功能的工作，并希望得到一些帮助。我想要调用一个$resource，直到出现成功条件或超过最大重试为止。
我似乎遇到的问题是，在我的重试功能中，我调用了另一个承诺，这就是条件将被检查的地方。我可以通过删除添加的承诺并在几次重试后创建默认的成功条件来使代码按预期的方式运行，但我不知道如何将新的承诺调用正确地添加到函数中。
resource是角$resource的替补，它返回$promise。
我的代码如下：
resource.$promise.then(function (response) {
return keepTrying(state, 5);
}).the
浏览 2提问于2015-01-10得票数 6
回答已采纳
2回答
我对承诺相当陌生，在Q.when()链中我也遇到了问题。
我想按顺序履行我的诺言。
到目前为止，这就是我所掌握的。它是连续运行的，但它没有解析我的URL。parseUrls(urls)应该返回一个包含所有parseUrl(url)分辨率的数组。
function parseUrl(url) {
return function () {
var deferred = Q.defer();
// setTimeout as async placeholder
setTimeout(function() {
浏览 2提问于2015-11-18得票数 1
回答已采纳
我在Swift中使用PromiseKit，到目前为止，它非常方便。它们提供的函数之一是when()，它允许您拥有任意数量的promises数组，并且只有在所有promises都完成后才能执行某些操作。
但是，数组中的promises是并行执行的。我还没有找到任何允许我按顺序执行它们的函数。我试着写一个我自己的递归函数，但它似乎没有按照它们在数组中的顺序执行Promise，并且我偶尔会得到"Promise deallocated“错误。请帮帮我！
static func executeSequentially(promises: [Promise<Void>]) ->
浏览 0提问于2018-01-20得票数 6
1回答
我的project.And中有一个复杂的ajax调用树，我想使用Promise，这是es6的新特性，可以从地狱回调中逃脱。
很难描述整个调用树，所以我做了一个简单的例子来模拟它：
在这个示例中，很容易看出我使用Promise遇到了then地狱，您可以想象如果树一直在增长，就不可能理解和修改它。
在这里，我尝试解决这个问题，但失败了：
另外，我读过一些关于Promise的文章，但我认为promise chain不会解决这个problem.Am我误解了promise chain的用法？
请帮帮我，谢谢！
浏览 3提问于2016-03-14得票数 0
2回答
我试图通过让一个函数处理一系列函数来尽可能地简化承诺链。他们需要井然有序，但我给他们正确语法的方法不起作用，我相信有更好的方法可以做到这一点。链中的每个函数都调用数据库，并需要在返回时触发下一个函数。
// Run each in order.
var Chain = function(chain, cb){
chain.forEach(function(i){ i = function(r){return new Promise(i)}; });
chain.reduce(function(cur, next) { {cur.then(next)} }, Promise
浏览 8提问于2016-06-17得票数 0
回答已采纳
1回答
我目前正在尝试创建一个工具来链接动态数量的承诺。这是我的代码：
// NB: This is made using angular's $q, but this applies to anything else
promiseChain = function(array, passedPromise) {
let chain = $q((resolve, reject) => resolve());
for (let elem of array)
chain = chain.then(_ => passedPromise(elem));
浏览 2提问于2016-05-04得票数 1
回答已采纳
在我的项目中 npm install @angular/compiler-cli@">=9.0.0 <10" --dry-run
npm WARN registry Unexpected warning for https://registry.npmjs.org/: Miscellaneous Warning SELF_SIGNED_CERT_IN_CHAIN: request to https://registry.npmjs.org/@angular%2fcompiler-cli failed, reason: self signed certificate
浏览 26提问于2020-09-17得票数 0
我是函数式编程的新手，我发现下面的fluture函数式编程示例似乎为处理数据库查询和后续数据操作提供了一个非常好的示例。然而，需要注意的是，在阅读函数式编程概念时，Just/Nothing monad似乎是处理null检查的建议方法。1)这将如何适应这个示例；2)如果findOne拒绝，它是否会停止后续链的运行并立即转到分叉？
import Future from 'fluture';
const processAll = Future.fork(_sendError, _sendResponse);
const _fetchFromDB =
encaseP(use
浏览 15提问于2021-03-06得票数 1
回答已采纳
1回答
这应该是一个简单的问题，但是我找不到关于如何做到这一点的文档。
像这样链接一个承诺：
// Making a promise, no problem
let promise = new Promise((resolve, reject) => {
let data = {}; // do something
reject(data);
});
// First chain, no problem
promise.then(data => {
console.log('Success callback', data); // This wil
浏览 3提问于2017-01-11得票数 2
回答已采纳
1回答
重试、中止等
、、
我一直在试图找到一个包装器，它可以用重试、超时、中止等方式进行抓取。不久前我遇到了，在修复了几个类型(缺少options.和=>)之后，它就能工作了，除了.好吧，也许有用，但我不知道怎么用。如何使用此特定包装器中止获取？我有小提琴，。有了这段代码，我怎么才能点击一个按钮，让它中止这个提取循环呢？对于我的用例，我使用boopstrap，并且我有一个模式，当显示时，尝试加载动态内容。如果用户在加载时单击Cancel，我希望获取进程停止。据我所知，我应该可以用下面的代码.但我不知道该怎么做。也许这是不可能的，按照结构，有一个承诺.但是，我对这样或那样的承诺知之甚少。
const fetchWi
浏览 7提问于2022-01-17得票数 -3
在Python中：
list(itertools.chain.from_iterable(['aaa','bbb']))
给予：
['a','a','a','b','b','b']
如预期的那样。在Jython2.7.0中，相同的代码给出了TypeError: 'str' object is not callable。
请注意，这似乎是试图将其强制转换为导致错误的列表，如
for c in itertools.chain.from_iterable([
浏览 0提问于2016-12-23得票数 0
回答已采纳
我有一个应用程序，在这个应用程序中，我必须在后台继续运行一些异步代码。我为我的应用程序创建了一个最小的模拟。
let promise_chain = Promise.resolve();
let rejected_promise_count = 0;
const interval_id = setInterval(
// Do some important polling. I will just always reject to demonstrate the problem.
() => {
promise_chain = promise_chain
浏览 0提问于2018-04-06得票数 3
回答已采纳
1回答
在我的应用中，我正在接收来自usb设备的包。在我发送命令后，我应该在每隔N ms调用接收函数来获取所有的数据包。
我用promises创建了链：
var packagesCount = 10;
var chain = $q.when();
for (var i=0; i<packagesCount; i++) {
chain = chain.then(hidRead((packagesCount-i)*1000));
}
chain.then(function () {
console.log("all finished")
}, function (r
浏览 6提问于2017-01-27得票数 1
回答已采纳
我正在尝试使用OkHttpClient进行HTTP调用。我试图在客户机上实现重试，以防我看到SocketTimeoutExceptions。我现在拥有的是：
builder.addInterceptor(new Interceptor() {
@Override
public Response intercept(Chain chain) throws IOException {
Request request = chain.request();
// try the request
浏览 1提问于2021-09-22得票数 1
回答已采纳
1回答
通过数组异步循环
、、、
我有以下代码：
var obj = {
"slot1": ["1", "2"],
"slot2": ["7", "5"],
"slot3": ["12", "213"],
};
for (var key of Object.keys(obj )) {
obj[key].reduce((chain, user_id) => {
return chain
.then(() => async_things
浏览 1提问于2021-04-01得票数 0
回答已采纳
我是春季整合的新手。我的要求是，如果有连接问题到jms q，那么它应该尝试连接3次，然后记录它并退出进程。我做不到。它抛出一个错误，说明它需要service:activator的ref属性。但我不知道在这里提供哪一类的参考资料。还有别的办法吗？
<int-jms:message-driven-channel-adapter id="msgIn" channel="toRoute" container="messageListenerContainer" />
<int:service-activator id="s
浏览 4提问于2015-10-09得票数 0
回答已采纳
我试图将队列类型系统引入到JS类中，以允许异步方法链接，理想情况下，我希望使用这些异步方法对类实例执行操作并返回"this“实例。
export class Queue {
constructor() {
this.queue = Promise.resolve()
this.firstRequestStarted = false
this.firstRequestStatusCode = 0
this.secondRequestStarted = false
this.secondRequest
浏览 4提问于2022-10-08得票数 1
回答已采纳
1回答
我正在尝试使用Node.js连接并执行语句到Amazon QLDB。为了实现这一点，我需要完成最后一步，即计算提交摘要。我不知道该怎么做。 我在这里彻底研究了QLDB Sessions javascript API：https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/QLDBSession.html，但没有任何关于计算提交摘要的内容。我碰巧在这里发现了另一个关于堆栈溢出的问题：How to get/compute CommitDigest when committing a transaction in AWS QLDB?。我试着理
浏览 17提问于2019-10-05得票数 2
1回答
Chefspec模拟问题
、、、、
我有两个没有类的方法，它们都有相同的代码，但返回的对象不同。
def get_load_balancer(network_client, resource_group_name, load_balancer_name)
promise = network_client.load_balancers.get(resource_group_name, load_balancer_name)
load_balancer = promise.value!
return load_balancer.body
end
def get_public_ip(network_client, res
浏览 4提问于2016-12-07得票数 0
我有下面这段代码：
#define BOOST_THREAD_PROVIDES_FUTURE
#define BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
#include <iostream>
#include <thread>
#include <boost/thread/future.hpp>
using namespace boost;
int foo(boost::future<int> x) {
std::cout << "first stage(" <
浏览 0提问于2016-07-17得票数 1
回答已采纳
我在这件事上失去了理智。
我所要做的就是链接一个函数数组(同步和异步)，并在它们都完成后进行回调。
像这样简单的链接函数
function promise_chain(fns, start) {
return fns.reduce(function(previous, next) {
return previous.then(next);
}, start);
}
对事物进行排序是可行的，但我无法为我的生命在结束时得到一次回调。它返回一系列承诺中的最后一个，应该像其他的一样接受then回调。但是这样的回调会在链中的第一项之后触发。
这是小提琴。
它还包括该链接
浏览 0提问于2014-02-27得票数 4
回答已采纳
1回答
我有一个承诺链 如果我在getServiceCost中收到错误，我想再次重复该链(重试)2次，当我使用Promise chain时如何实现这一点，这意味着再次执行getUser，getServiceCost getUser(100)
.then(getServices)
.then(getServiceCost)
.then(console.log);
function getUser(userId) {
return new Promise((resolve, reject) => {
console.log('Get th
浏览 26提问于2021-11-22得票数 0
回答已采纳
我试图建立请求链，用数据填充结果并进行解析。如果承诺，这是正常的，但角2使用RxJ与他们的订户等。
所以我试着做这个
private getPatientPrefPharmacies(patientId: string): Observable {
return this._http.get(this._config.getPatientFeauturesJsonUrl(patientId, this.preferredPharmaciesPropName))
.map(res => {
return Observable.of(this.
浏览 1提问于2016-06-07得票数 3
回答已采纳
我已经设置了一个简单的文件集成--从目录读取文件并通过sftp传输到远程系统。它工作很好，但是我需要在成功的传输之后处理归档，然后重试直到*n如果传输失败。有什么建议可以使用spring集成组件来完成吗？
<bean id="sftpSessionFactory" class="org.springframework.integration.sftp.session.DefaultSftpSessionFactory">
<property name="host" value="sftp.host
浏览 1提问于2014-06-03得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
