我有一个MyThread课程.我有一个方法样本.我试图从具有相同的对象上下文运行它.请看一下代码:
class myThread (threading.Thread):
def __init__(self, threadID, name, counter, redisOpsObj):
threading.Thread.__init__(self)
self.threadID = threadID
self.name = name
self.counter = counter
self.redisOpsObj = redisOpsObj
def stop(self):
self.kill_received = True
def sample(self):
print "Hello"
def run(self):
time.sleep(0.1)
print "\n Starting " + self.name
self.sample()
看起来很简单不是吗.但是当我运行它时,我得到了这个错误
AttributeError: 'myThread' object has no attribute 'sample'现在我有那种方法,就在那里.那有什么不对？请帮忙
编辑:这是堆栈跟踪
Starting Thread-0
Starting Thread-1
Exception in thread Thread-0:
Traceback (most recent call last):
File "/usr/lib/python2.6/threading.py", line 525, in __bootstrap_inner
self.run()
File "./redisQueueProcessor.py", line 51, in run
self.sample()
AttributeError: …如何选择第n < td >一个的< tr >使用jquery.说,我想选择第3名 < td >.我有每个tr的id.我们怎样才能做到这一点？
我一直在学习apache kafka一个月了.然而,我现在陷入了困境.我的用例是,我有两个或更多的消费者进程在不同的机器上运行.我运行了一些测试,其中我在kafka服务器上发布了10,000条消息.然后在处理这些消息时,我杀死了一个消费者进程并重新启动它.消费者在文件中编写处理过的消息.消费完成后,文件显示超过10k条消息.所以有些消息是重复的.
在消费者流程中,我已禁用自动提交.消费者手动批量提交偏移量.因此,例如,如果将100条消息写入文件,则消费者提交偏移量.当单个消费者进程正在运行并且以这种方式避免崩溃并恢复重复时.但是当多个消费者正在运行并且其中一个消失并且恢复时,它会将重复的消息写入文件.
是否有任何有效的策略来避免这些重复的消息？
在这段代码中.
public class Test {
public static void testFun(String str) {
if (str == null | str.length() == 0) {
System.out.println("String is empty");
} else {
System.out.println("String is not empty");
}
}
public static void main(String [] args) {
testFun(null);
}
}
我们将null值传递给函数null.编译很好,但testFun在运行时给出.
假设传递给的实际参数的值NullPointerException是从某个进程生成的.假设该进程错误地返回null值并将其提供给testFun.如果是这种情况,如何验证传递给函数的值是否为null？
一个(奇怪的)解决方案可能是将形式参数分配给函数内的某个变量,然后对其进行测试.但是如果有许多变量传递给函数,那可能会变得乏味且不可行.那么,如何在这种情况下检查空值？
编辑:错误地写了|| 而不是| 在if条件下.现在生成运行时异常
我想在IE7和IE8中实现框阴影.我没有成功就尝试了一切.这是我用来将彩色阴影应用于div的css:
.bright{
position: absolute;
z-index: 1;
-moz-box-shadow: 0px -3px 55px 20px #147197;
box-shadow: 0px -3px 55px 20px #147197;
-webkit-box-shadow: 0px -3px 55px 20px #147197;
behavior: url(ie-css3.htc);
}
这个ie-css3.htc文件是IE阴影问题的解决方案.但它只提供黑色阴影,而不是色彩阴影.我试过了:
filter: progid:DXImageTransform.Microsoft.Shadow(color='#969696', Direction=100, Strength=13);
但它会产生一个方向性的阴影,我想要一个全方位的阴影.还试过模糊滤镜,但它需要有额外的div,这在我目前的情况下是不可取的.有关这个问题的专家意见吗？
css internet-explorer css3 internet-explorer-8 internet-explorer-7
我想知道,如何递归地找出元素的所有父节点.假设我有以下代码段
<a href="#"><font>Hello</font></a>
在这里我想知道font标签的父节点是否是锚标签.现在可以通过简单地检查.parentNode属性来实现.但是,如果有以下情况,如果,
<a href="#"><font><b>Hello<b></font></a>
要么
<a href="#"><font><b><u>Hello</u><b></font></a>
所以,基本上,如何知道我们是否已达到最顶级的父节点？
好吧,这可能是java中的小孩问题.我们不能在一个文件中定义两个公共类.但是,在SCJP学习指南一书中的一个例子中,提到了这个例子:
public abstract class A{
public abstract void show(String data);
}
public class B extends A{
public void show(String data){
System.out.println("The string data is "+data);
}
public static void main(String [] args){
B b = new B();
b.show("Some sample string data");
}
}
当我把它粘贴到netbeans中时立即抛出编译错误,那个公共类A应该在单独的文件中提到.那个来自SCJP styudy指南的例子真的错了吗？在一些模拟测试中,我发现许多问题都有这样的模式,但没有一个选项是提到编译器错误.在这里担心
我有以下要求:
问题是,客户端可能落后于服务器多少分钟.在服务器端,我将cookie设置为
setcookie($cooName,$cooVal,time()+500,"/");
但是现在如果客户端计算机比服务器落后500秒,则上面的代码将生成一个cookie,该cookie将在1000秒内到期,而不是500秒.
我当时想把客户的时间戳发送到服务器并在那个时候设置cookie.这样的事情:
setcookie($cooName,$cooVal,$_GET['clientTS']+500,"/");
但是如果客户端落后500秒,如果我设置了这样一个已经过时的cookie,它就不会被设置.如果cookie过期,如何在客户端和服务器之间实现时间同步？
我们随机NetworkExceptions而且TimeoutExceptions在我们的生产环境中:
Brokers: 3
Zookeepers: 3
Servers: 3
Kafka: 0.10.0.1
Zookeeeper: 3.4.3
我们偶尔会在生产者日志中获得此异常:
超过TOPIC的10条记录:XXXXXX:自创建批次以及延迟时间后已经过了5608 ms.
此类错误消息中的毫秒数不断变化.有时它的〜5秒其他时间长达~13秒!
我们很少得到:
NetworkException: Server disconnected before response received.
集群由3名 经纪人和3名 动物园管理员组成.生产者服务器和Kafka集群在同一网络中.
我正在进行同步通话.有一个Web服务,多个用户请求调用它来发送数据.Kafka Web服务有一个Producer对象,它执行所有发送.生产者的请求超时最初为1000毫秒,已更改为15000毫秒(15秒).即使在增加超时期限后TimeoutExceptions仍会出现错误日志.
可能是什么原因？
我将在每天超过十亿次请求的高流量环境中使用kafka.每个请求都将与kafka集群建立连接以发送消息.因此,每秒都会有如此多的连接.这可能会导致套接字超时等问题.生产者正在进行所有非持久性连接.因此在这种情况下可能存在套接字超时或端口耗尽问题.
大多数生态系统都在php中,所以我必须使用php库来实现kafka.现在如何有效地使用kafka生产者来缓解这种连接争用？
我想到了一个可以传递消息的守护进程,然后它会批量发送这些消息到kafka集群.另外一方面是连接数量有限.缺点是这种服务的响应延迟会妨碍应用程序.此外,我必须使用一些中间存储来保存消息.
现在我知道有很多极高容量的应用程序/站点使用kafka来直接传输消息.你们中的任何一个人都可以指导我如何解决这些问题吗？在这种情况下持久连接可以帮助吗？在如此高容量的环境中使用kafka-producer的php库本身是个坏主意吗？