&互联先锋，中国最优秀的海外主机海外域名服务商。
7*24小时服务热线 400-688-5856
&&&全国服务热线
客服帮助类别
最新客服帮助
客服帮助点击排行
建立数据 socket 失败的解决方法
发布时间：
文章来源：客服帮助
点击次数：2216 次
使用过FTP的都可能遇到以下错误（以CuteFtp为例）
状态:&&正在重获目录列表...
命令:&&PASV
&227 Entering Passive Mode (127.0.0.1,7,221)
命令:&&LIST
状态:&&正在连接数据 socket...
错误:&&建立数据 socket 失败
如果出现这个错误，请在FTP软件设置当中将你的数据连接类型由 & PASV & 改为 & PORT & 应该就可以了。
FTP协议有两种工作方式：PORT方式和PASV方式，中文意思为主动式和被动式。
PORT（主动）方式的连接过程是：客户端向服务器的FTP端口（默认是21）发送连接请求，服务器接受连接，建立一条命令链路。当需要传送数据时，客户端在命令链路上用PORT命令告诉服务器：&我打开了XXXX端口，你过来连接我&。于是服务器从20端口向客户端的XXXX端口发送连接请求，建立一条数据链路来传送数据。
PASV（被动）方式的连接过程是：客户端向服务器的FTP端口（默认是21）发送连接请求，服务器接受连接，建立一条命令链路。当需要传送数据时，服务器在命令链路上用PASV命令告诉客户端：&我打开了XXXX端口，你过来连接我&。于是客户端向服务器的XXXX端口发送连接请求，建立一条数据链路来传送数据。
自选配置 实时开通 在线管理
520标准服务
服务单提交问题5分钟内响应
30天退款保障
主机产品不满意退款保障
友情链接：
&工信部备案号：
拓展先锋 版权所有 7x24小时服务热线：400-688-5856 电话总机：6 传真：5
客服中心：深圳市福田区深南中路华联大厦13楼&&&&技术中心：香港九龍旺角道33號凱途發展大廈7樓
拓展先锋& 版权所有hbase配置、运行错误总结
Categories:
Published on: 2012 年 06 月 05 日
一、执行$ hbase hbck 命令时，出现以下提示：
Invalid maximum heap size: -Xmx4096m
The specified size exceeds the maximum representable size.
Error: Could not create the Java Virtual Machine.
Error: A fatal exception has occurred. Program will exit.
原因：jvm设置的内存过大，减小配置文件hbase-env.sh内的设置即可。例如：
export HBASE_HEAPSIZE=1024
二、无法启动hbase，regionserver log里会有这样的错误，zookeeper也有初始化问题的错误
FATAL org.apache.hadoop.hbase.regionserver.HRegionServer: ABORTING region server 10.210.70.57,8145399: Initialization of RS failed. Hence aborting RS.
因为之前安装配置的时候是好好的，中间经历过强行kill daemon的过程，又是报错初始化问题，所以估计是有缓存影响了，所以清理了tmp里的数据，然后发现HRegionServer依然无法启动，不过还好的是zookeeper启动了，一怒之下把hdfs里的hbase数据也都清理了，同时再清理tmp，检查各个节点是否有残留hbase进程，kill掉，重启hbase，然后这个世界都正常了。不知道具体哪里影响了，不推荐这种暴力解决办法，如果有谁知道原因请告之。
三、无法启动reginserver daemon，报错如下：
Exception in thread "main" java.lang.RuntimeException: Failed construction of Regionserver: class org.apache.hadoop.hbase.regionserver.HRegionServer
Caused by: java.net.BindException: Problem binding to /10.210.70.57:60020 : Cannot assign requested address
根据错误提示，检查ip对应的机器是否正确，如果出错机器的ip正确，检查60020端口是否被占用。
四、执行hbase程序orshell命令出现如下提示：
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/usr/hbase-0.92.1/lib/slf4j-log4j12-1.5.8.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/usr/hadoop-1.0.3/lib/slf4j-log4j12-1.4.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
是因为hbase和hadoop里都有这个jar包，选择其一移除即可。
五、执行hbase的mapreduce作业，有些节点无任何报错正常执行，有些节点总报类似Status : FAILED
java.lang.NullPointerException的错误，查看tasktracker的log日志有如下错误：
WARN org.apache.zookeeper.ClientCnxn: Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
caused by java.net.ConnectException: Connection refused
对这个错误给了说明，
Errors like this... are either due to ZooKeeper being down, or unreachable due to network issues.
当初配置zookeeper时只说尽量配置奇数节点防止down掉一个节点无法选出leader，现在看这个问题貌似所以想执行任务的节点都必须配置zookeeper啊。
六、报告找不到方法异常，但是报告的函数并非自己定义的，也并没有调用这样的函数，类似信息如下：
java.lang.RuntimeException: java.lang.NoSuchMethodException: com.google.hadoop.examples.Simple$MyMapper.()
at org.apache.hadoop.util.ReflectionUtils.newInstance(ReflectionUtils.java:45)
at org.apache.hadoop.mapred.MapRunner.configure(MapRunner.java:32)
at org.apache.hadoop.util.ReflectionUtils.newInstance(ReflectionUtils.java:53)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:209)
at org.apache.hadoop.mapred.TaskTracker$Child.main(TaskTracker.java:1210)
Caused by: java.lang.NoSuchMethodException: com.google.hadoop.examples.Simple$MyMapper.()
at java.lang.Class.getConstructor0(Class.java:2705)
at java.lang.Class.getDeclaredConstructor(Class.java:1984)
at org.apache.hadoop.util.ReflectionUtils.newInstance(ReflectionUtils.java:41)
... 4 more
网上找到解决方法如下：
This is actually the() function. The display on the web page doesn't translate into html, but dumps plain text, sois treated as a (nonexistant) tag by your browser. This function is created as a default initializer for non-static classes. This is most likely caused by having a non-static Mapper or Reducer class. Try adding the static keyword to your class declaration, ie:
意思是缺少static关键字～添加上即可。如下：
public static class MyMapper extends MapReduceBase implements Mapper {...}
七、使用mapreduce程序写HFile操作hbase时，可能会有这样的错误：
java.lang.IllegalArgumentException: Can't read partitions file
Caused by: java.io.IOException: wrong key class: org.apache.hadoop.io.*** is not class org.apache.hadoop.hbase.io.ImmutableBytesWritable
这里需要注意的是无论是map还是reduce作为最终的输出结果，输出的key和value的类型应该是：& ImmutableBytesWritable, KeyValue& 或者& ImmutableBytesWritable, Put&。改成这样的类型就行了。
八、如果启动hbase集群出现regionserver无法启动，日志报告如下类似错误时，说明是集群的时间不同步，只需要同步即可解决。
FATAL org.apache.hadoop.hbase.regionserver.HRegionServer: ABORTING region server 10.210.78.22,9095415: Unhandled exceptio
n: org.apache.hadoop.hbase.ClockOutOfSyncException: Server 10.210.78.22,9095415 Reported time is too far out of sync with mast
er. Time difference of 90358ms & max allowed of 30000ms
org.apache.hadoop.hbase.ClockOutOfSyncException: org.apache.hadoop.hbase.ClockOutOfSyncException: Server 10.210.78.22,9095415
Reported time is too far out of sync with master. Time difference of 90358ms & max allowed of 30000ms
Caused by: org.apache.hadoop.ipc.RemoteException: org.apache.hadoop.hbase.ClockOutOfSyncException: Server 10.210.78.22,9095415
Reported time is too far out of sync with master. Time difference of 90358ms & max allowed of 30000ms
只需要执行一下这条命令即可同步国际时间：
/usr/sbin/ntpdate tick.ucla.edu
ntp.nasa.gov timekeeper.isi.edu usno.pa-;/sbin/hwclock --systohc & /dev/null
我猜你可能也喜欢：
Share this
三江小渡 All rights reserved
Fastfood theme by
- Powered by
[put here your code]
quickbar tool -->
Recent Posts
by 三江小渡基本原理： ① 客户端第一次访问应用程序时，会到数据库（RDBMS）中取出数据，返回给客户端；同时也将取出的数[...]
by 三江小渡不错的一篇转过来记录一下。 1，服务器端软件：安装nfs-utils和portmap（rpcbind） nfs[...]
by 三江小渡安装了rsync程序后，运行以下shell程序即可完成rsync服务的启动，自行修改相关的module和认证用[...]
by 三江小渡mac下没有找到好用的类似secureCRT，就自己写了个自动登录的脚本，分享一下,如果是新浪的，就基本不用修[...]
by 三江小渡协同过滤算法是推荐系统中最古老，也是最简单高效的推荐算法。简单说协同过滤就是根据以往的用户产生的数据分析，对用[...]
by 三江小渡无意中看到哲学家不解释的博客，被她的文章吸引甚深。又看了她的两篇文章：人人主站 和 哲学十二钗问答 。然后特别[...]
by 三江小渡The big difference between MySQL Table Type MyISAM and [...]
by 三江小渡在看Redis底层实现的时候，看到一个数据结构“跳跃表”，随手学习了一下。大致结构如下图： 一个头指针数据控制[...]
by 三江小渡A comprehensive collection of hash functions, a hash vi[...]
by 三江小渡一、创建和销毁对象 1、用静态工厂方法替代构造器 优点：跟构造器比有名称；不必每次调用都创建新的实例；可以返回[...]
Categories
( 102)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 ( 62)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 ( 44)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 ( 22)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 ( 22)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 ( 21)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 ( 20)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 ( 19)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 ( 9)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 ( 7)Recent Posts by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡 by 三江小渡
Recent Comments
alan about 楼主。考虑如下矩阵 [10 9 10;6 8 9;7 9 9]，按你的算法，6- 7- 9,长度为3，但是结果应该是10-9-8-6，长度为4。似乎还是深搜+递归才能解决。 ml about canopy clustering解决了kmeans选取K值的问题，却又留下了选取t1和t2的问题。这个问题你怎么看？ 贺荣伟 about 真的吗？ 贺荣伟 about 候志远学长，这段话说得很文学，同时又很有道理。赞！ 三江小渡 about 是完整记录~ 王锦阳 about thanks！ 王锦阳 about 大虾，我现在遇到版本问题需要升级了，我的Hadoop版本是0.20.2，想问一下你版本是不是都没有多大的关系？可不可以升级到1.0.4？还有你写的步骤是否完整？感激不尽！ ZJP about 这么小清新啊！ ys about 3、最后就是从hbase中的表作为数据源读取
不用设置reducer的类型？ jared about 你好,我有个问题请教，如果我想给每个task制定个性化的配置属性，比如，io.sort.mb， io.sort.factor，如何实现最好？ 因为一般的情况是每个job都一次性在配置文件里设置好，然后就固定了。当每个task生成时都去读取这个统一的配置文件，我想实现让每个task都读取不一样的配置。如果有任何建议都欢迎指教，谢谢！我的邮箱：。：-）
Not logged in
Welcome , today is 星期二, 2014 年 12 月 23 日
Leave a comment
feed for comments on this post
Trackback URL
Next Post: hbase参数配置优化
Previous Post: hbase安装配置和入门使用
Top of page
Bottom of page我有1万个客户端，向服务器发起soap请求，在服务器上老是收到这种错误，请指点这种问题该如何解决，谢谢大家。
21:28:56,089 INFO& [STDOUT] No Inform received on this session.
21:29:16,043 ERROR [STDERR] java.net.SocketTimeoutException: Read timed out
21:29:16,044 ERROR [STDERR]&&&& at java.net.SocketInputStream.socketRead0(Native Method)
21:29:16,044 ERROR [STDERR]&&&& at java.net.SocketInputStream.read(SocketInputStream.java:129)
21:29:16,044 ERROR [STDERR]&&&& at org.apache.coyote.http11.InternalInputBuffer.fill(InternalInputBuffer.java:716)
21:29:16,044 ERROR [STDERR]&&&& at org.apache.coyote.http11.InternalInputBuffer$InputStreamInputBuffer.doRead(InternalInputBuffer.ja
va:746)
21:29:16,044 ERROR [STDERR]&&&& at org.apache.coyote.http11.filters.IdentityInputFilter.doRead(IdentityInputFilter.java:116)
21:29:16,044 ERROR [STDERR]&&&& at org.apache.coyote.http11.InternalInputBuffer.doRead(InternalInputBuffer.java:675)
21:29:16,044 ERROR [STDERR]&&&& at org.apache.coyote.Request.doRead(Request.java:428)
21:29:16,045 ERROR [STDERR]&&&& at org.apache.catalina.connector.InputBuffer.realReadBytes(InputBuffer.java:297)
21:29:16,045 ERROR [STDERR]&&&& at org.apache.tomcat.util.buf.ByteChunk.substract(ByteChunk.java:372)
21:29:16,045 ERROR [STDERR]&&&& at org.apache.catalina.connector.InputBuffer.readByte(InputBuffer.java:306)
21:29:16,045 ERROR [STDERR]&&&& at org.apache.catalina.connector.CoyoteInputStream.read(CoyoteInputStream.java:105)
21:29:16,043 ERROR [STDERR] java.net.SocketTimeoutException: Read timed out
这个应该是客户端抛出的异常吧？
（1）客户端是否设置了读取超时时间？
（2）看看与服务端的处理能力是否匹配？
假设服务端处理一个soap请求需要的时间为T秒，开启tomcat的线程池
&Connector executor="tomcatThreadPool"
port="8080" protocol="HTTP/1.1"
connectionTimeout="20000"
redirectPort="8443" /&
&Executor name="tomcatThreadPool" namePrefix="catalina-exec-"
maxThreads="[b]150[/b]" minSpareThreads="4"/&
那理想情况下服务端每秒的处理能力应该是：maxThreads/T
超出部分的请求就可能会出现读超时和连接超时
tomcat 是否启用了NIO 吗？有没配线程池？
已解决问题
未解决问题11816人阅读
本文作者：sodme本文出处：声明：本文可以不经作者同意任意转载、复制、传播，但任何对本文的引用均须保留本文的作者、出处及本行声明信息！谢谢！前言:
错误处理和socket释放, 是IOCP编程中的一大难点. 本文试图就IOCP设计中经常遇到的这个难题展开论述并寻找其解决方案, 事实上, 文中所述的解决方式不仅仅适用于IOCP, 它同样适用于EPOLL等多种服务器编程的网络模型中, 前提是: 领会这种处理方式的实质.正文:在使用IOCP开发时, 大家经常遇到的一个难题是与socket相关的缓冲区释放不当带来的错误, 这种错误通常是由于多次对同一个指针执行了delete操作引起的. 比如, 当在执行wsasend或wsarecv返回了非pending的错误信息时, 我们就要对此错误进行处理, 通常情况下, 我们会想到执行这两步操作: a. 释放此次操作使用的缓冲区数据(如果不释放可能造成内存泄漏); b. 关闭当前操作所使用的socket. 而另一方面, 我们可能也会在get函数(GetQueuedCompletionStatus)的处理中, 当get函数返回值为FALSE时也作这两步相同的操作.
此时, 就会造成对同一缓冲区的重复释放, 问题由此产生.解决的方法, 可以有这几种: 1. 对数据缓冲区使用引用计数机制; 2. 在clientsock的对象设计机制上使释放操作线性化. 关于这两种方法, 任何一种如果要详细说清, 可能篇幅都会比较长, 笔者并无耐心和精力将每一个细节都一一道来, 在此仅选第2种方案的关键步骤和核心思想来与大家分享.由前面对问题的描述可以看出, 造成多次释放的原因可能是在执行收发操作和GET函数返回值为FALSE时, 我们重复执行了释放操作. 很自然地, 我们会想到,
能不能把这两次释放合并成一次释放,
这样不就没问题了吗?
这个思路是没问题的.
但要想让这个思路能变成现实,
需要在设计机制上对这个思路进行一定的支持.首先,
我们假设, 是在get函数返回时统一进行相应的释放和关闭操作.如果在执行wsasend操作时, 发生了非pending错误(io操作正在进行中), 而此时我们如果不释放资源, 那至少得让IOCP在GET返回时得知这个错误和发生错误时的缓冲区指针. 通知IOCP的方式, 是使用post函数(PostQueuedCompletionStatus)向IOCP抛一个特殊标志的消息, 这个特殊标志可以通过get函数的第二个参数, 即: 传送字节数来表示, 可以选择任何一个不可能出现的值, 比如任何一个跟它的初始值不相等的负数.
当然, 如果你通过单句柄数据或单IO数据来传递也是可以的. 而发生错误的这个缓冲区指针, 我们是必须要通过单句柄数据或单IO数据来传递的. 但是, 从整个缓冲区的管理机制上来说, 我不推荐这样的离散缓冲区机制, 我的建议是: 把收发缓冲区或数据队列与相应的clientsocket对象相绑定, 释放操作写在该对象的析构函数里, 这样当释放clientsocket对象时就释放了这些缓冲区.ok, 这样一来, 在get函数里, 有三种情况需要执行释放逻辑:1. get的返回值为FALSE;2. 传送字节数为0;3. 接收到刚才我们post的那个错误类型消息.把释放操作全放在get函数里以后, 对释放操作的处理, 就比较统一了. 当然, 为了实现真正的线性化和元子化, 在释放操作的最终执行逻辑上, 还需要对释放代码加锁以实现线程互斥(当然, 这是在你开了多个工作者线程的情况下).
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：651775次
积分：7768
积分：7768
排名：第810名
原创：141篇
转载：22篇
评论：299条
(1)(1)(1)(2)(4)(18)(4)(1)(3)(1)(1)(1)(2)(3)(4)(3)(3)(6)(3)(11)(9)(8)(10)(8)(8)(23)(12)(2)(1)(2)(1)(3)(3)当前位置： >
> 执行这个socket客户端。出错：error:[Errno10053]1。Pythoncode#应
执行这个socket客户端。出错：error:[Errno10053]1。Pythoncode#应
leexiaoping27 & at
执行这个socket客户端。出错：error: [Errno 10053]1。　　Python code　　#应用实例的服务器端 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM); #生成Socket对像 sock.bind(('localhost', 8001)); #绑定主机IP与端口号 sock.listen(5);
#开始监听 while True:
connection, address = sock.accept(); #
connection.settimeout(5); #在5秒后调用这个函数
buf = connection.recv(1024);
if buf == '1':
connection.send('lkafds');
connection.send('false');
except socket.timeout:
print 'time out';
connection.close(); sock.close();
2。　　Python code　　#socket 小实例 客户端代码 import socket import time sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM); # sock.connect(('localhost', 8001)); # time.sleep(2); sock.send('1'); print sock.recv(1024); sock.close();
下面是出错代码：　　Python code　　Traceback (most recent call last):
File &F:/python/pyweb/1.1.7.py&, line 8, in &module&
print sock.recv(1024); error: [Errno 10053]
是先运行server端的文件没有错再运动client就出上面的错。查了好几遍好像没有错？
好生看看你每一行代码最后多了什么？？
LeeYan & &
& & （0）（0）
尽管可以用分号，但是python程序，很少用;的，那不是被认可的习惯。习惯是每条语句一行，行末无分号。（如果要多条语句一行，每条语句末尾加分号，尽管这不认为是好习惯）leeyetion & &
& & （0）（0）
本问题标题：
本问题地址：
温馨提示：本问题已经关闭，不能解答。
暂无合适的专家
&&&&&&&&&&&&&&&
希赛网 版权所有 & &&&&湘教QS2-164&&增值电信业务经营许可证湘B2-