php – 如何超时ibase_connect？（php 超时时间）

25-04-05 5

以上就是给各位分享php–如何超时ibase_connect？，其中也会对php超时时间进行解释，同时本文还将给你拓展.conn.ManagedClientConnectionImpl@604ed9f

以上就是给各位分享php – 如何超时ibase_connect？，其中也会对php 超时时间进行解释，同时本文还将给你拓展.conn.ManagedClientConnectionImpl@604ed9f0 java.net.ConnectException: Connection refused: connect、c – 连接lambda时如何将Qt :: ConnectionType传递给QObject :: connect？、find IBASE structure - CRM_IBASE_COMP_FIND_MULTI - IBSP, IBIB、flink ConnectException: Connection refused: connect？？等相关知识，如果能碰巧解决你现在面临的问题，别忘了关注本站，现在开始吧！

本文目录一览：

php – 如何超时ibase_connect？（php 超时时间）
.conn.ManagedClientConnectionImpl@604ed9f0 java.net.ConnectException: Connection refused: connect
c – 连接lambda时如何将Qt :: ConnectionType传递给QObject :: connect？
find IBASE structure - CRM_IBASE_COMP_FIND_MULTI - IBSP, IBIB
flink ConnectException: Connection refused: connect？？

php – 如何超时ibase_connect？（php 超时时间）

我正在尝试在连接到firebird 2.5 db时实现超时.

这适用于连接150台服务器的脚本.我的目标是太失败了服务器并移动到下一个服务器,以维持脚本执行时间.

正常的脚本执行时间是30秒,但是如果一个服务器发生故障,它会提升到300秒.
我在PHP 7上使用ibase扩展.

有什么建议吗？

提前致谢.

解决方法

服务器端存在连接超时选项,在客户端,您可以尝试在firebird.conf中设置它
如何在连接前测试端口是否打开？

<?PHP

function con_test($i,$p) {
    $f = @fsockopen($i,$p,$errno,$errstr,0.1);
        if (!$f) {
            return false;
        } 
        else {
            fclose($f);
            return true;
        }
}   


$host[] = ['ip'=>'192.168.52.97','port' => '3050','alias' => 'test'];
$host[] = ['ip'=>'192.168.52.96','alias' => 'test'];

$username='sysdba';
$password = 'masterkey';

foreach ($host as $k=>$v)
 {
 if (con_test($v['ip'],$v['port'])) { 

    $host = $v['ip'].'/'.$v['port'].':'.$v['alias'];
    $dbh = ibase_connect($host,$username,$password);
    $stmt = 'SELECT \'test\' as test FROM rdb$database';
    $sth = ibase_query($dbh,$stmt);

    while ($row = ibase_fetch_object($sth)) {
    echo $row->TEST,PHP_EOL;
    }
    ibase_free_result($sth);
    ibase_close($dbh);
} 
else  {
    echo 'Cannot connect to '.$v['ip'].':'.$v['port'].PHP_EOL;
}

}

.conn.ManagedClientConnectionImpl@604ed9f0 java.net.ConnectException: Connection refused: connect

DEBUG 2016-11-07 14:32:47,518 Get connection for route {}->http://127.0.0.1:8087->http://rdsearch.zhaopin.com:80
DEBUG 2016-11-07 14:32:47,519 Connecting to 127.0.0.1:8087
DEBUG 2016-11-07 14:32:48,530 Connection org.apache.http.impl.conn.DefaultClientConnection@91161c7 closed
DEBUG 2016-11-07 14:32:48,531 Connection org.apache.http.impl.conn.DefaultClientConnection@91161c7 shut down
DEBUG 2016-11-07 14:32:48,532 Releasing connection org.apache.http.impl.conn.ManagedClientConnectionImpl@604ed9f0
java.net.ConnectException: Connection refused: connect
at java.net.DualStackPlainSocketImpl.connect0(Native Method)
at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)
at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
at java.net.PlainSocketImpl.connect(Unknown Source)
at java.net.SocksSocketImpl.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at org.apache.http.conn.scheme.PlainSocketFactory.connectSocket(PlainSocketFactory.java:117)
at org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:177)
at org.apache.http.impl.conn.ManagedClientConnectionImpl.open(ManagedClientConnectionImpl.java:304)
at org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:611)
at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:446)
at org.apache.http.impl.client.AbstractHttpClient.doExecute(AbstractHttpClient.java:882)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:82)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:107)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:55)

c – 连接lambda时如何将Qt :: ConnectionType传递给QObject :: connect？

我将lambdas连接到QObject的信号：

QObject::connect(handle,&BatchHandle::progressMax,[this](const ProcessHandle* const self,const int value) {        this->maxProgress(value);    });

上面的代码编译没有问题.

但是Qt :: QueuedConnection是绝对必要的,因为句柄对象最终将移动到另一个线程.

我把它添加到我的代码中：

QObject::connect(handle,&BatchHandle::finished,[this](const ProcessHandle* const self) {        this->processIsRunning(false);    },(Qt::ConnectionType)Qt::QueuedConnection);

请注意我是如何添加显式强制转换以确保它正确标识值类型的.结果：

1>src\TechAdminServices\database\techCore\processes\import\ImportManagerDialog.cpp(191): error C2664: 'QMetaObject::Connection QObject::connect<void(__cdecl taservices::ProcessHandle::* )(const taservices::ProcessHandle *),Qt::ConnectionType>(const taservices::ProcessHandle *,Func1,const QObject *,Func2,Qt::ConnectionType)' : cannot convert parameter 3 from 'taservices::`anonymous-namespace'::<lambda58>' to 'const QObject *'1>          with1>          [1>              Func1=void (__cdecl taservices::ProcessHandle::* )(const taservices::ProcessHandle *),1>              Func2=Qt::ConnectionType1>          ]1>          No user-defined-conversion operator available that can perform this conversion,or the operator cannot be called

连接lambda时如何获得排队连接？

解决方法

我认为你需要使用 QObject::connect overload,它允许你指定应该调用lambda的上下文…

QObject::connect(  handle,target_context,/* Target context parameter. */  [this](const ProcessHandle* const self,const int value)  {    this->maxProgress(value);  },Qt::QueuedConnection);

find IBASE structure - CRM_IBASE_COMP_FIND_MULTI - IBSP, IBIB

[外链图片转存失败(img-zFuWLUzH-1566273661028)(https://upload-images.jianshu.io/upload_images/2085791-c4f58b9813a954cb.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)]要获取更多Jerry的原创文章，请关注公众号"汪子熙":

本文同步分享在博客“汪子熙”（CSDN）。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。

flink ConnectException: Connection refused: connect？？

报错记录是： Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:146) at org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:647) at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:123) at org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.scala:654) at com.atguigu.orderpay_detect.OrderTimeout$.main(OrderTimeout.scala:63) at com.atguigu.orderpay_detect.OrderTimeout.main(OrderTimeout.scala) Caused by: java.net.ConnectException: Connection refused: connect at java.net.DualStackPlainSocketImpl.connect0(Native Method) at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:79) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.net.Socket.connect(Socket.java:589) at org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction.run(SocketTextStreamFunction.java:96) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:94) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:58) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:99) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:704) at java.lang.Thread.run(Thread.java:748) 代码例子： package com.atguigu.orderpay_detect import java.util import org.apache.flink.cep.{PatternSelectFunction, PatternTimeoutFunction} import org.apache.flink.cep.scala.CEP import org.apache.flink.cep.scala.pattern.Pattern import org.apache.flink.streaming.api.TimeCharacteristic import org.apache.flink.streaming.api.scala._ import org.apache.flink.streaming.api.windowing.time.Time /** * Copyright (c) 2018-2028 尚硅谷 All Rights Reserved * * Project: UserBehaviorAnalysis * Package: com.atguigu.orderpay_detect * Version: 1.0 * * Created by wushengran on 2019/9/25 9:17 */ // 定义输入订单事件的样例类 case class OrderEvent(orderId: Long, eventType: String, txId: String, eventTime: Long) // 定义输出结果样例类 case class OrderResult(orderId: Long, resultMsg: String) object OrderTimeout { def main(args: Array[String]): Unit = { val env = StreamExecutionEnvironment.getExecutionEnvironment env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime) env.setParallelism(1) // 1. 读取订单数据 val resource = getClass.getResource("/OrderLog.csv") // val orderEventStream = env.readTextFile(resource.getPath) val orderEventStream = env.socketTextStream("localhost", 7777) .map(data => { val dataArray = data.split(",") OrderEvent(dataArray(0).trim.toLong, dataArray(1).trim, dataArray(2).trim, dataArray(3).trim.toLong) }) .assignAscendingTimestamps(_.eventTime * 1000L) .keyBy(_.orderId) // 2. 定义一个匹配模式 val orderPayPattern = Pattern.begin[OrderEvent]("begin").where(_.eventType == "create") .followedBy("follow").where(_.eventType == "pay") .within(Time.minutes(15)) // 3. 把模式应用到stream上，得到一个pattern stream val patternStream = CEP.pattern(orderEventStream, orderPayPattern) // 4. 调用select方法，提取事件序列，超时的事件要做报警提示 val orderTimeoutOutputTag = new OutputTag[OrderResult]("orderTimeout") val resultStream = patternStream.select(orderTimeoutOutputTag, new OrderTimeoutSelect(), new OrderPaySelect()) resultStream.print("payed") resultStream.getSideOutput(orderTimeoutOutputTag).print("timeout") env.execute("22order timeout job") } } // 自定义超时事件序列处理函数 class OrderTimeoutSelect() extends PatternTimeoutFunction[OrderEvent, OrderResult] { override def timeout(map: util.Map[String, util.List[OrderEvent]], l: Long): OrderResult = { val timeoutOrderId = map.get("begin").iterator().next().orderId OrderResult(timeoutOrderId, "timeout") } } // 自定义正常支付事件序列处理函数 class OrderPaySelect() extends PatternSelectFunction[OrderEvent, OrderResult] { override def select(map: util.Map[String, util.List[OrderEvent]]): OrderResult = { val payedOrderId = map.get("follow").iterator().next().orderId OrderResult(payedOrderId, "payed successfully") } }

关于php – 如何超时ibase_connect？和php 超时时间的介绍现已完结，谢谢您的耐心阅读，如果想了解更多关于.conn.ManagedClientConnectionImpl@604ed9f0 java.net.ConnectException: Connection refused: connect、c – 连接lambda时如何将Qt :: ConnectionType传递给QObject :: connect？、find IBASE structure - CRM_IBASE_COMP_FIND_MULTI - IBSP, IBIB、flink ConnectException: Connection refused: connect？？的相关知识，请在本站寻找。

本文标签：