关于建立一个TCP服务端出现阻塞问题

这里是tcp客户端的代码


import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class Socket_client {

public static void main(String[] args) throws UnknownHostException, IOException {
    //first,创建一个socket对象
    Socket s = new Socket("192.168.1.107",20000);

    //second,获取Socket中的输出流
    OutputStream out = s.getOutputStream();

    //third,发送信息
    out.write("嘿嘿嘿".getBytes());


    //添加读取服务器返回信息功能
    //使用socket流读取服务器返回数据
    InputStream in = s.getInputStream();
    byte[] b = new byte[1024];
    int len = in.read(b);
    String str = new String(b,0,len);
    System.out.println(str);

    //关闭资源
    s.close();

}

}


这里是tcp服务端的代码


import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server_Socket {
public static void main(String[] agrs) throws IOException{
//先建立一个服务Socket
ServerSocket ss = new ServerSocket(20000);

    //获取客户Socket对象
    Socket s = ss.accept();

    //使用客户的Socket对象将信息打印出来
    InputStream in = s.getInputStream();
    byte[] b = new byte[1024];
    int len;
    while((len = in.read(b))!=-1){    //问题就出在这里,用循环读取,读取-1时,出现阻塞,后面代码无法运行
        String str = new String(b,0,len);
        System.out.println(str);
    }

    //使用客户的Socket对象将成功接受信息的信息反馈给客户端
    OutputStream out = s.getOutputStream();
    out.write("成功接受到信息".getBytes());

    //关闭资源
    s.close();
    ss.close();
}

}
先执行了服务端,然后再执行客户端,服务端收到客户端发来的string后阻塞了,客户端也阻塞了,无法接受服务端回复的string
如果我把服务端循坏代码改成如下:

//使用客户的Socket对象将信息打印出来
InputStream in = s.getInputStream();
byte[] b = new byte[1024];
int len = in.read(b);
String str = new String(b,0,len);
System.out.println(str);
--------------------------------------------------
程序能正常运行,为何,求解?

3个回答

这个问题本人已经解决了,一直没时间,现在写一下。为什么 while((len=in.read(b))!=-1) 会阻塞呢?这是因为read()在读的时候没有读到结束符,
也就是说从socket的输入流中没有获取到结束标记,所以一直在等待着客户端继续发送字节,然而客户端已经发送完毕,进行到 “使用socket流读取服务器返回数据”
这一步,这时,客户端这边的read()开始等待服务端返回的字节,因此,两边就陷入互相等待的状况!!!
解决办法:在客户端
//third,发送信息
out.write("嘿嘿嘿".getBytes());
//在这一步后面,再加一句作用是加入socket流的结束标志,但并不是关闭流资源,告诉服务端,数据发送完毕,让服务器停止读取
s.shutdownOutput();

PS:其实shutdownOutput()这个方法相当于服务端的while((len=in.read())!=null){..........省略; 加入 if(in.read()=="end"){break}},当接受到结束标记“end”的时候就
跳出循环了,或者理解为传入了一个null,就跳出循环。

1,查看服务开启是否正常一般看到start8161就正常了
2. 看端口,监听地址是否正确对应,消息队列。
3,监听只能监听本机的,别人的你时间听不到的。你可以往客户的IP上发送消息,在客户的机器上得有监听地址和处理消息的程序
下面这个,你可以参考下
图片说明

我这也卡住了,API文档中是这样解释的
public void shutdownOutput()
throws IOException禁用此套接字的输出流。对于 TCP 套接字,任何以前写入的数据都将被发送,并且后跟 TCP 的正常连接终止序列。 如果在套接字上调用 shutdownOutput() 后写入套接字输出流,则该流将抛出 IOException。
我想不明白的是,如果客户端也采用whlie的方法读取信息,服务器端为什么不用 socket.shutdownOutput()方法,客户端也能正常读取服务器端发送的消息

YAN_HUAXIANGMO
YAN_HUAXIANGMO 你看看我服务器代码,后面直接s.close()关闭流了,肯定发出去了,如果在s.close()前面加个while(true)阻塞主,你看看。客户端肯定卡住
2 个月之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
python TCP服务端接受数据时recv函数非阻塞究竟如何实现?

这是TCP服务端代码: ``` import socket import threading s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.bind(('127.0.0.1', 9998)) s.listen(5) print('Waiting for connection') def tcplink(sock, addr): print('Accept new connection from %s:%s...' % addr) sock.send(b'Welcome!') buffer = [] while True: #接受数据时就卡在这里了 d = sock.recv(1024) if not d: break else: buffer.append(d) sock.send('get it!'.encode('utf-8')) print((b''.join(buffer)).decode('utf-8')) sock.close() print('Connection from %s:%s closed.' % addr) while True: sock, addr = s.accept() t = threading.Thread(target=tcplink, args=(sock, addr)) t.start() ``` 客户端代码: ``` import socket s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) s.send(b'nihao') buffer = [] while True: d = s.recv(1024) if not d: break else: buffer.append(d) data = b''.join(buffer) s.close() print(data.decode('utf-8')) ``` 上网查了很多方式比如settimeout,MSG_DONTWAIT,都失败了,如何修改代码才能正常接受数据呢?求详细一点的说明,谢谢!

tcp大文件传输,全部write成功,read接收到部分后阻塞

tcp大文件传输,全部write成功,read接收到部分后阻塞。 小文件传输没问题。 ``` //传输数据结构体 typedef struct ResponeBody{ int packindex;//4 byte char type;//2 byte char status;//2 byte int datalen;//4 byte int datatotal;//4 byte char s_arg[24];//24 byte char data[SIZE_DATA]; }ResponeBody; ``` ``` //发送数据 while((num = read(fd, resp.data, SIZE_DATA)) > 0) { resp.type = getData; resp.status = 1; resp.datalen = num; res = my_write(socket, &resp, SIZE_RESP); if(res < 0){ return -1; } memset(&resp, 0, SIZE_RESP); } close(fd); ``` ``` //读取数据 int ret = -1; while(1){ num = read(socket, &resp, SIZE_RESP); if(num <= 0 || len_recv >= datatotal){ printf("get success\n"); ret = 0; break; } if(0 == resp.status || resp.type != getData){ ret = -1; break; } write(fd, resp.data, resp.datalen); len_recv += num-SIZE_INFO; printf("get ----[%2.2f%%]----\n", len_recv/(double)datatotal * 100); memset(&resp, 0, SIZE_RESP); } ```

Netty服务端如何保持稳定的长连接

有一个项目用到了netty来搭建服务端,主要是接入大量的客户端(目前有500多个客户端的接入),与服务端进行来消息的传送。但是,项目运行到一定时间后(大概10来天左右),链路channel就处于一种inactive的状态,导致客户端与服务端无法正常接收发送消息。重启netty server 后,链路又正常连接,又过一端时间后,又出现了上诉的问题。有哪位有经验的大神,能说一下这是什么情况吗?

LWIP下,TCP接收数据过程中插拔网线,sock未非阻塞状态,但RECV堵塞

各位大神。。。帮帮我呗。。。我特别困惑 我在STM32F2系列下用select方式开发TCP服务端,每个服务端可以接收多个链接, 我每个链接都设置成了非阻塞模式,在TCP通讯过程中反复插拔网线,偶尔会出现SELECT任务被挂起的情况,我加了mark,在recv前的mark = recv后mark+1,然后任务被挂起。。。。请帮帮我

netty客户端向远程服务端发送数据包

首先,感谢每一位来关注的IT前辈,真诚希望您提出宝贵的意见。 我需要的效果: 1.客户端与服务端长连接TCP通信; 2.客户端通过自定义解码器,解析服务端返回的数据包; 3.客户端在服务端返回连接结果后,发送登录请求数据包,需要对数据自定义编码器解析; 4.因为是长连接,服务不能断,还需要发送登陆请求,以及其他验证消息。很重要。 **数据包结构:** 1.固定包头2字节; 2.消息体,全部为文本(ASCII码),汉字是GB2312编码。 3.固定包尾2字节; 我目前代码: public class TCPClient { public void connect(int port,String host)throws Exception{ //网络事件处理线程组 EventLoopGroup group=new NioEventLoopGroup(); //配置客户端启动类 Bootstrap b=new Bootstrap(); b.group(group).channel(NioSocketChannel.class) .option(ChannelOption.TCP_NODELAY, true)//设置封包 使用一次 大数据的写操作,而不是多次小数据的写操作 .handler(new ChannelInitializer<SocketChannel>() { @Override protected void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast("decoder",new DealMsg()); //设置自定义解码器 ch.pipeline().addLast("encoder",new MsgEncode()); //设置自定义编码器 ch.pipeline().addLast(new TCPClientHandler()); //设置客户端网络IO处理器 } }); //连接服务器 同步等待成功 ChannelFuture f = b.connect(new InetSocketAddress(host,port)); //同步等待客户端通道关闭 // f.channel().closeFuture().sync(); //不关闭会发生阻塞 Channel channel = f.sync().channel(); Scanner scanner = new Scanner(System.in); while(true){ System.out.println("请输入"); CarData carData = new CarData(); String line = scanner.nextLine(); carData.setBody(line); //发送请求 channel.writeAndFlush(carData); } //释放线程组资源 // group.shutdownGracefully(); } } public class TCPClientHandler extends ChannelHandlerAdapter { @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { System.out.println("通信异常!!"); cause.printStackTrace(); } @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { System.out.println("链接服务端成功!"); } @Override public void channelInactive(ChannelHandlerContext ctx) throws Exception { System.out.println("退出链接!!"); } @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { System.out.println("接受服务器数据:【 "+msg); } @Override public void channelReadComplete(ChannelHandlerContext ctx) throws Exception { ctx.channel().writeAndFlush("数据读取完成!"); } }

关于tcp的accept函数的问题

当服务端用accept函数接受客户端请求,假设服务端bind的端口号为2347, accept的第二个参数会把客户端的ip 端口号保存下来, 但是当通过accept第二个参数打印客户端端口号和ip时, 与netstat -anp|grep 2347显示连接的客户端的ip 端口号完全不一样

C# 单客户端 多服务器同时收发数据

需要用C#编写TCP协议的客户端接收两个服务器传过来的文件。使用了两个Socket连接两个服务器,每一个socket都有一个单独的接收线程recmsg,多线程+阻塞模式。 现在的问题是两个服务器有可能会在同一时刻向客户端发送文件,客户端同一IP地址下从不同端口同时接收到了文件。这种情况下是否会出现冲突的情况,客户端无法判断优先从哪个端口接收数据? 如果会有冲突,那么应该采用何种方式解决这种客户端同时接收到文件的情况? 部分代码如下 private void Form1_Load(object sender, EventArgs e) { socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); IPEndPoint ipe = new IPEndPoint(IPAddress.Parse("192.168.2.100"), 7890); socketClient.Connect(ipe); threadClient = new Thread(RecMsg); threadClient.IsBackground = true; threadClient.Start(); Message.AppendText("已经与服务端100建立连接,可以开始通信...\r\n"); socketClient2 = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); IPEndPoint ipe2 = new IPEndPoint(IPAddress.Parse("192.168.2.110"), 7890); socketClient2.Connect(ipe2); threadClient2 = new Thread(RecMs); threadClient2.IsBackground = true; threadClient2.Start(); Message.AppendText("已经与服务端110建立连接,可以开始通信...\r\n"); }

qt tcp通讯,server端无法进入incomingConnection函数

自己写了一个类继承QTcpServer,重写里面的incomingConnection函数,但是当有新的客户端连接的时候无法进入这个函数。 头文件 ```class TcpServerManager : public QTcpServer { Q_OBJECT public: TcpServerManager(QObject *parent); ~TcpServerManager(); QList<TcpSocketManager*> mSocketList; void ReadUserInfo(); public slots: void ServerNewConnection(); void ServerReadData(); void slotclientdisconnect(qintptr descriptor); void sliotupdateserver(QString, int); private: QTcpSocket *mp_TCPSocket; QTcpServer* mp_TCPServer; std::map<string, string> mMapUserInfo; protected: virtual void incomingConnection(qintptr socketDescriptor); }; ``` cpp ``` TcpServerManager::TcpServerManager(QObject *parent) : QTcpServer(parent) { ReadUserInfo(); mp_TCPServer = new QTcpServer(); mp_TCPSocket = new QTcpSocket(); if (!mp_TCPServer->listen(QHostAddress::Any, 9988)) { QMessageBox::warning(NULL, QString::fromLocal8Bit("提示"), QString::fromLocal8Bit("服务器端监听失败!"), QMessageBox::Yes); return; } //connect(mp_TCPServer, SIGNAL(newConnection()), this, SLOT(ServerNewConnection())); } TcpServerManager::~TcpServerManager() { } void TcpServerManager::incomingConnection(qintptr socketDescriptor) { TcpSocketManager *tcpclientsocket = new TcpSocketManager(this); tcpclientsocket->setSocketDescriptor(socketDescriptor); mSocketList.append(tcpclientsocket); connect(tcpclientsocket, &TcpSocketManager::clientdisconnected, this, &TcpServerManager::slotclientdisconnect); connect(tcpclientsocket, &TcpSocketManager::updateserver, this, &TcpServerManager::sliotupdateserver); } ```

关于TCP连接的问题,第一次接收数据成功之后,第二次就断开了

有木有大神指导TCP连接自动断开时怎么回事,我用一个定时器循环执行接收发送消息的动作 但是一直不成功 第一次数据接收成功之后 第二次就失败了 后面发现是第二次的时候连接断开了 有木有大神指点一下啊![图片说明](https://img-ask.csdn.net/upload/201608/12/1470969702_204794.png)

Golang TCP Client无法从服务器接收数据,在conn.Read()上挂起/阻止

<div class="post-text" itemprop="text"> <p>I'm taking a dive into the networking side of Go, and I'd thought I'd start with a TCP Client and Server.</p> <p>I am able to get the client to connect to the server and send a simple message ("Hello") successfully. However, I can not get the server to send back a response (or the get the client to read the response).</p> <p>Here is the code.</p> <p><strong>Server</strong></p> <pre><code>Address := "localhost:9999" Addr, err := net.ResolveTCPAddr("tcp", Address) if err != nil { log.Fatal(err) } listener, err := net.ListenTCP("tcp", Addr) if err != nil { log.Fatal(err) } defer listener.Close() //server loop for { conn, err := listener.Accept() if err != nil { continue } go handle(conn) } func handle(c net.Conn) { totalBytes, message := connRead(c) fmt.Println(c.RemoteAddr()) fmt.Println(string(message[:totalBytes])) c.Write([]byte("Hi")) fmt.Println("Replied") c.Close() } func connRead(c net.Conn) (int, []byte) { buffer := make([]byte, 4096) totalBytes := 0 for { n, err := c.Read(buffer) totalBytes += n if err != nil { if err != io.EOF { log.Printf("Read error: %s", err) } break } } return totalBytes, buffer } </code></pre> <p><strong>Client</strong></p> <pre><code> tcpAddr, err := net.ResolveTCPAddr("tcp", "localhost:9999") if err != nil { log.Fatal(err) } conn, err := net.DialTCP("tcp", nil, tcpAddr) if err != nil { log.Fatal(err) } defer conn.Close() _, err = conn.Write([]byte("Hello")) if err != nil { log.Fatal(err) } tBytes, resp := connRead(conn) fmt.Println(tBytes) fmt.Println(string(resp[:tBytes])) func connRead(c net.Conn) (int, []byte) { buffer := make([]byte, 4096) totalBytes := 0 for { fmt.Println("Stuck?") n, err := c.Read(buffer) fmt.Println("Stuck.") totalBytes += n fmt.Println(totalBytes) if err != nil { if err != io.EOF { log.Printf("Read error: %s", err) } break } } return totalBytes, buffer } </code></pre> <p>From what I can tell it's not a problem with the server. When I run the client, everything stops right after <code>fmt.Println("Stuck?")</code>. This leads me to belive that it's messing up in the <code>n, err := c.Read(buffer)</code> statement somehow. The server doesn't even print out the messeage length (5) and message ("Hello") untill after I Ctrl-C the client. If I comment out the read and printings in the client, then things run smoothly.</p> <p>I've tried googling for answers, but nothing has come up. </p> <p>What am I doing wrong? Am I using conn.Read() wrong in the client?</p> <p><strong>EDIT:</strong></p> <p>I actually do have access to Linux, so here are the SIGQUIT dumps for the pertinent functions.</p> <p><em>Server</em></p> <p><a href="http://pastebin.com/itevngCq" rel="nofollow">http://pastebin.com/itevngCq</a></p> <p><em>Client</em></p> <p><a href="http://pastebin.com/XLiKqkvs" rel="nofollow">http://pastebin.com/XLiKqkvs</a></p> </div>

java socket客户端一直监听服务端返回数据

连接服务端之后,一直要监听服务端的加载信息,当检测到特定格式的数据,干什么事。目前是用readLine!=null循环读取数据的,关闭是用ajax发一条命令给服务端,当检测到这条命令时,退出循环读取,但是这个方法是阻塞的,及不方便,如发送心跳包,有什么更好的方法实现吗

求助:netty 4.x服务器端出现CLOSE_WAIT的问题

**1.主题:**我最近用netty4.x 做了一个app服务端,在部署到服务器上之后出现了很多close_wait 状态的TCP连接 ,导致服务端卡住,不能再接收新的连接,但是换回本地测试又不会出现这样的问题。 **2.详细描述:** 1)当服务端出现卡住的情况时,使用netstat -ano 命令可以看到服务器的连接状态还是established,抓包也能看到客户端仍然在正常发送数据包,但是服务器只是回应了一个ACK(此时服务端已经卡住,控制台没有任何动作,也没有日志记录)。 ![图片说明](https://img-ask.csdn.net/upload/201807/12/1531381902_865010.jpg) 下面那一个是心跳包。 只要客户端不关闭连接,一直是established,直到客户端断开连接后,就变成了close_wait。只有一次服务端从这种“卡死”状态恢复,并且打印了日志(比如"用户的断开连接")。 一开始我以为是某一步阻塞,而导致了这个情况,于是又用jstack 命令查看了阻塞状态,转下节, 2) 显示结果: ![图片说明](https://img-ask.csdn.net/upload/201807/12/1531382616_657392.png) 3)在查看官方的使用手册和《netty 实战》中,有提到入站出站消息需要使用ReferenceCountUtil.release()进行,手动释放,但我的编解码器用的分别是ByteToMessageDecoder和MessageToByteEncoder,源码上这两个都进行了Bytebuf的释放处理, 所以问题应该不是出在这里吧..... 以下是编解码器的部分代码: encoder ``` @Override protected void encode(ChannelHandlerContext ctx, YingHeMessage msg, ByteBuf out) throws Exception { checkMsg(msg);// not null int type = msg.getProtoId(); int contentLength = msg.getContentLength(); String body = msg.getBody(); out.writeInt(type); out.writeInt(contentLength); out.writeBytes(body.getBytes(Charset.forName("UTF-8"))); } ``` decoder ``` //int+int private static final int HEADER_SIZE = 8; private static final int LEAST_SIZE = 4; private static final Logger LOG = LoggerFactory.getLogger(YingHeMessageDecoder.class); @Override protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception { in.markReaderIndex();//第一次mark int readable = in.readableBytes(); LOG.info("check:{}", in.readableBytes() < HEADER_SIZE); LOG.info("readable:{}", readable); if (in.readableBytes() < HEADER_SIZE) {//消息过小回滚指针,不作处理 LOG.warn(">>>可读字节数小于头部长度!"); LOG.info("before reset:{}", in.readerIndex()); in.resetReaderIndex(); LOG.info("after reset:{}", in.readerIndex()); return; } //读取消息类型 int type = in.readInt(); int contentLength = in.readInt(); LOG.info("type:{},contentLength:{}", type, contentLength); in.markReaderIndex();//第二次mark int readable2 = in.readableBytes(); if (readable2 < contentLength) { LOG.error("内容长度错误!length=" + contentLength); in.resetReaderIndex();//重设readerIndex LOG.info("重设,当前readerIndex:" + in.readerIndex()); return; } //读取内容 ByteBuf buf = in.readBytes(contentLength); byte[] content = new byte[buf.readableBytes()]; buf.readBytes(content); String body = new String(content, "UTF-8"); YingHeMessage message = new YingHeMessage(type, contentLength, body); out.add(message); } ``` 下面是服务器启动类的配置: ``` public void run() throws Exception { EventLoopGroup boss = new NioEventLoopGroup(); EventLoopGroup worker = new NioEventLoopGroup(5); try { ServerBootstrap b = new ServerBootstrap(); b.group(boss, worker) .channel(NioServerSocketChannel.class) .option(ChannelOption.SO_BACKLOG, 1024) .option(ChannelOption.SO_REUSEADDR, true) .childOption(ChannelOption.TCP_NODELAY, true) .childOption(ChannelOption.SO_KEEPALIVE, true) .handler(new LoggingHandler(LogLevel.DEBUG)) .childHandler(new ChannelInitializer<SocketChannel>() { @Override protected void initChannel(SocketChannel ch) throws Exception { ch.pipeline() .addLast(new LengthFieldBasedFrameDecoder(MAX_LENGTH, LENGTH_FIELD_OFFSET, LENGTH_FIELD_LENGTH, LENGTH_ADJUSTMENT, INITIAL_BYTES_TO_STRIP)) .addLast(new ReadTimeoutHandler(60)) .addLast(new YingHeMessageDecoder()) .addLast(new YingHeMessageEncoder()) .addLast(new ServerHandlerInitializer()) .addLast(new Zenith()); } }); Properties properties = new Properties(); InputStream in = YingHeServer.class.getClassLoader().getResourceAsStream("net.properties"); properties.load(in); Integer port = Integer.valueOf(properties.getProperty("port")); ChannelFuture f = b.bind(port).sync(); LOG.info("服务器启动,绑定端口:" + port); DiscardProcessorUtil.init(); System.out.println(">>>flush all:" + RedisConnector.getConnector().flushAll()); LOG.info(">>>redis connect test:ping---received:{}", RedisConnector.getConnector().ping()); f.channel().closeFuture().sync(); } catch (IOException e) { e.printStackTrace(); } finally { //清除 LOG.info("优雅退出..."); boss.shutdownGracefully(); worker.shutdownGracefully(); ChannelGroups.clear(); } } ``` 4)其他补充说明: 服务器为windows server 2012r; 客户端使用的C sharp编写; 服务端使用了Netty 4.1.26.Final,Mybatis,Spring,fastjson,redis(缓存),c3p0(连接池); 本地测试不会出现这种情况! 40c币奉上,还请各位大牛不吝赐教,救小弟于水火啊!

socket连接运行一段时间后无法正常通信.

小弟目前在负责一个socket相关的小项目,具体流程很简单,服务端向客户端发送数据,客户端接收到数据后进入睡眠,然后由第三方工具唤醒客户端,唤醒后服务端继续想客户端发送数据,客户端继续进入睡眠,如此一直循环. 目前小弟碰到的问题是:当循环运行到一定圈数后(有时几百圈,有时一千多圈),服务端send()方法运行过后,客户端却接收不到数据,一直阻塞在receive()方法这. 此时我用netstat -nao查看tcp连接,状态是established 还有就是服务端代码是有python写的,客户端代码是c#,我在客户端设置了socket.ReceiveTimeout(120000),当receive两分钟未收到数据,就会报异常,在catch语句里面关闭连接并重新连接;方法如下 ``` socket.shutdown(SocketShutdown.Both); socket.close(); socket = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp); IPEndPoint endPoint = new IPEndPoint(ip,8002); socket.Connect(endPoint); ``` 但是重新连接后依然无法接收数据,只能一直等待两分钟报错后重连,然后继续报错.但是如果我在运行正常的情况下断开WiFi然后重连,程序是可以继续运行的.. 这个问题已经困扰小弟一两个月了,希望有大佬能够帮小弟分析一下原因,万分感谢!!! 宁外,今天小弟发现服务端python代码在创建socket的时候用的是 ``` s = socket.socket() ``` 而不是 ``` s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) ``` 即未指定ipv4协议和流,不知道是不是因为这个的原因(还未验证)

基于TCP实现多人聊天,遇到线程不够用的现象

如果要用TCP协议建立一个一百人的聊天室,使用线程池处理客户端的消息,有一个客户端连接就把这个客户端加入任务队列中,再使用线程池中的线程处理客户端与服务端的消息发送与显示,那么在一百个人同时在线发送消息的时候是不是要在线程池中开启100个线程? 或者有其他办法吗? 谢谢各位大神指导一下!

socket连接问题,关闭原来的,建另一个IP的socket

我现在有一个socket连接,现在我想停掉他,然后用另一个IP开启socket,求方法 那个,程序运行,只允许有一个socket,然后我这个做的是修改IP之后路,我应该怎么做呢?

Netty4.1运行一段时间后监听端口收不到请求

项目用的Netty4.1编写, 情况是运行一段时间后,监听端口就接收不到前端请求,大概过1分钟自动又恢复,貌似运行越久这种状况出现的越是频繁。上线时并发测试还挺不错的。就是这个问题折腾到现在反复重现,求救大神。 关键代码如下: ``` EventLoopGroup bossGroup = new NioEventLoopGroup(); //定义一个线程组,这个线程组的作用是用来接收客户端的连接 EventLoopGroup workerGroup = new NioEventLoopGroup(); //定义一个线程组,这个线程组用来处理业务逻辑 final EventExecutorGroup e2=new DefaultEventExecutorGroup(32); try { ServerBootstrap b = new ServerBootstrap(); //定义一个ServerBootstarp类,这个类用来初始化netty服务器 //将两个线程组绑定到ServerBootstarp中,channel使用的模式为非阻塞模式 b.group(bossGroup, workerGroup); b.channel(NioServerSocketChannel.class); b.childHandler(new ChannelInitializer<SocketChannel>() { int i = 0; @Override //当有连接接入的时候会调用这个方法 public void initChannel(SocketChannel ch) throws Exception { //server端发送的是httpResponse,所以要使用HttpResponseEncoder进行编码,将HttpResponse转化为ByteBuffer ch.pipeline().addLast(new HttpResponseEncoder()); //server端接收到的是httpRequest,所以要使用HttpRequestDecoder进行解码,将HttpRequset解码为ByteBuffer ch.pipeline().addLast(new HttpRequestDecoder()); //处理接收HTTP报文不全的特殊设置 ch.pipeline().addLast("aggregator", new HttpObjectAggregator(3200)); //收到客户端的连接之后就调用HttpServerInboundHandler来处理 //ch.pipeline().addLast(new HttpServerInboundHandler()); ch.pipeline().addLast(e2,new HttpServerInboundHandler()); } }); b.option(ChannelOption.SO_BACKLOG, 1024); b.childOption(ChannelOption.CONNECT_TIMEOUT_MILLIS,30); b.childOption(ChannelOption.SO_KEEPALIVE, false); ChannelFuture f = b.bind(port).sync(); //和套接字的绑定类似,监听班底的port端口 f.channel().closeFuture().sync(); //等待结束 ```

C++ Win10 socket send后接收服务器返回应答recv阻塞

result = send(socketTCP, (const char*)(char*)(sByte+offset), size, 0); if (result < 0){ DWORD a = GetLastError(); ResumeThread(recvThread); return result; } Sleep(100); //等待服务器响应 int loop = 0; char bufRecv[MAX_PACKET]; char tempBuf[4096]; int flag = recv(socketTCP, bufRecv, MAX_PACKET, 0); int temp12 = strlen(bufRecv); for (int i = 0; i<MAX_PACKET; i++){ tempBuf[i] = bufRecv[i]; } while (temp12>MAX_PACKET){ loop++; flag = recv(socketTCP, bufRecv, MAX_PACKET, 0); //temp12 = strlen(bufRecv) - MAX_PACKET*loop; temp12 = strlen(bufRecv); for (int i = 0; i < flag; i++){ tempBuf[i + MAX_PACKET*loop] = bufRecv[i]; } } if (flag <= 0){ int temp1 = WSAGetLastError(); printf("receive data error"); return -1; } //backData = (unsigned char*)tempBuf; string backStr = "recv data from server "; backStr += tempBuf; //backData = new unsigned char[3036]; int i = 0; for (i = 0; i < backStr.length(); i++){ backData[i] = backStr[i]; } backData[i] = '\0'; index = findIndexNum(backData); //backData = (unsigned char*)backStr.c_str(); //printf("recv data from server:%s", bufRecv); printf("recv data from server:%s", backData);

UDP通信问题,时通时不通

服务器用的UDP通信,多个客户端,现在问题是服务器跟一部分客户端通信没有问题,而只能收到另一部分客户端的数据,服务器回复了应答,但是客户端接收不到应答,这一部分客户端有时又可以正常通行,这样的问题怎么处理,怎么定位?

java socket长连接循环读取数据

用ip端口密码里连接上服务端控制台,然后一直从服务端控制台读取数据,当读取到某一特定字符的时候干什么业务,有一个问题就是,只要连接上他就一直读取,阻塞在循环内,如果后续需要发送心跳包只有另外一个类里面隔多久发送一条命令,当读取类读取到这个命令的时候发送一条信息给服务端保持连接,不然过20分钟左右就断了,请问有什么更好的方法实现,一直监听数据,读到特定字符数据时实现特定业务,而不是一直阻塞式读取

在中国程序员是青春饭吗?

今年,我也32了 ,为了不给大家误导,咨询了猎头、圈内好友,以及年过35岁的几位老程序员……舍了老脸去揭人家伤疤……希望能给大家以帮助,记得帮我点赞哦。 目录: 你以为的人生 一次又一次的伤害 猎头界的真相 如何应对互联网行业的「中年危机」 一、你以为的人生 刚入行时,拿着傲人的工资,想着好好干,以为我们的人生是这样的: 等真到了那一天,你会发现,你的人生很可能是这样的: ...

删库了,我们一定要跑路吗?

在工作中,我们误删数据或者数据库,我们一定需要跑路吗?我看未必,程序员一定要学会自救,神不知鬼不觉的将数据找回。 在 mysql 数据库中,我们知道 binlog 日志记录了我们对数据库的所有操作,所以 binlog 日志就是我们自救的利器。 接下来就来开启程序员自救之路。 想要自救成功,binlog 这把利器一定要好,在自己之前,我们一定要确定我们有 binlog 这把利器,以下就是确保有 bi...

再不跳槽,应届毕业生拿的都比我多了!

跳槽几乎是每个人职业生涯的一部分,很多HR说“三年两跳”已经是一个跳槽频繁与否的阈值了,可为什么市面上有很多程序员不到一年就跳槽呢?他们不担心影响履历吗? PayScale之前发布的**《员工最短任期公司排行榜》中,两家码农大厂Amazon和Google**,以1年和1.1年的员工任期中位数分列第二、第四名。 PayScale:员工最短任期公司排行榜 意外的是,任期中位数极小的这两家公司,薪资...

我以为我学懂了数据结构,直到看了这个导图才发现,我错了

数据结构与算法思维导图

技术大佬:我去,你写的 switch 语句也太老土了吧

昨天早上通过远程的方式 review 了两名新来同事的代码,大部分代码都写得很漂亮,严谨的同时注释也很到位,这令我非常满意。但当我看到他们当中有一个人写的 switch 语句时,还是忍不住破口大骂:“我擦,小王,你丫写的 switch 语句也太老土了吧!” 来看看小王写的代码吧,看完不要骂我装逼啊。 private static String createPlayer(PlayerTypes p...

华为初面+综合面试(Java技术面)附上面试题

华为面试整体流程大致分为笔试,性格测试,面试,综合面试,回学校等结果。笔试来说,华为的难度较中等,选择题难度和网易腾讯差不多。最后的代码题,相比下来就简单很多,一共3道题目,前2题很容易就AC,题目已经记不太清楚,不过难度确实不大。最后一题最后提交的代码过了75%的样例,一直没有发现剩下的25%可能存在什么坑。 笔试部分太久远,我就不怎么回忆了。直接将面试。 面试 如果说腾讯的面试是挥金如土...

和黑客斗争的 6 天!

互联网公司工作,很难避免不和黑客们打交道,我呆过的两家互联网公司,几乎每月每天每分钟都有黑客在公司网站上扫描。有的是寻找 Sql 注入的缺口,有的是寻找线上服务器可能存在的漏洞,大部分都...

讲一个程序员如何副业月赚三万的真实故事

loonggg读完需要3分钟速读仅需 1 分钟大家好,我是你们的校长。我之前讲过,这年头,只要肯动脑,肯行动,程序员凭借自己的技术,赚钱的方式还是有很多种的。仅仅靠在公司出卖自己的劳动时...

上班一个月,后悔当初着急入职的选择了

最近有个老铁,告诉我说,上班一个月,后悔当初着急入职现在公司了。他之前在美图做手机研发,今年美图那边今年也有一波组织优化调整,他是其中一个,在协商离职后,当时捉急找工作上班,因为有房贷供着,不能没有收入来源。所以匆忙选了一家公司,实际上是一个大型外包公司,主要派遣给其他手机厂商做外包项目。**当时承诺待遇还不错,所以就立马入职去上班了。但是后面入职后,发现薪酬待遇这块并不是HR所说那样,那个HR自...

女程序员,为什么比男程序员少???

昨天看到一档综艺节目,讨论了两个话题:(1)中国学生的数学成绩,平均下来看,会比国外好?为什么?(2)男生的数学成绩,平均下来看,会比女生好?为什么?同时,我又联想到了一个技术圈经常讨...

副业收入是我做程序媛的3倍,工作外的B面人生是怎样的?

提到“程序员”,多数人脑海里首先想到的大约是:为人木讷、薪水超高、工作枯燥…… 然而,当离开工作岗位,撕去层层标签,脱下“程序员”这身外套,有的人生动又有趣,马上展现出了完全不同的A/B面人生! 不论是简单的爱好,还是正经的副业,他们都干得同样出色。偶尔,还能和程序员的特质结合,产生奇妙的“化学反应”。 @Charlotte:平日素颜示人,周末美妆博主 大家都以为程序媛也个个不修边幅,但我们也许...

MySQL数据库面试题(2020最新版)

文章目录数据库基础知识为什么要使用数据库什么是SQL?什么是MySQL?数据库三大范式是什么mysql有关权限的表都有哪几个MySQL的binlog有有几种录入格式?分别有什么区别?数据类型mysql有哪些数据类型引擎MySQL存储引擎MyISAM与InnoDB区别MyISAM索引与InnoDB索引的区别?InnoDB引擎的4大特性存储引擎选择索引什么是索引?索引有哪些优缺点?索引使用场景(重点)...

如果你是老板,你会不会踢了这样的员工?

有个好朋友ZS,是技术总监,昨天问我:“有一个老下属,跟了我很多年,做事勤勤恳恳,主动性也很好。但随着公司的发展,他的进步速度,跟不上团队的步伐了,有点...

我入职阿里后,才知道原来简历这么写

私下里,有不少读者问我:“二哥,如何才能写出一份专业的技术简历呢?我总感觉自己写的简历太烂了,所以投了无数份,都石沉大海了。”说实话,我自己好多年没有写过简历了,但我认识的一个同行,他在阿里,给我说了一些他当年写简历的方法论,我感觉太牛逼了,实在是忍不住,就分享了出来,希望能够帮助到你。 01、简历的本质 作为简历的撰写者,你必须要搞清楚一点,简历的本质是什么,它就是为了来销售你的价值主张的。往深...

外包程序员的幸福生活

今天给你们讲述一个外包程序员的幸福生活。男主是Z哥,不是在外包公司上班的那种,是一名自由职业者,接外包项目自己干。接下来讲的都是真人真事。 先给大家介绍一下男主,Z哥,老程序员,是我十多年前的老同事,技术大牛,当过CTO,也创过业。因为我俩都爱好喝酒、踢球,再加上住的距离不算远,所以一直也断断续续的联系着,我对Z哥的状况也有大概了解。 Z哥几年前创业失败,后来他开始干起了外包,利用自己的技术能...

现代的 “Hello, World”,可不仅仅是几行代码而已

作者 |Charles R. Martin译者 | 弯月,责编 | 夕颜头图 |付费下载自视觉中国出品 | CSDN(ID:CSDNnews)新手...

!大部分程序员只会写3年代码

如果世界上都是这种不思进取的软件公司,那别说大部分程序员只会写 3 年代码,恐怕就没有程序员这种职业。

离职半年了,老东家又发 offer,回不回?

有小伙伴问松哥这个问题,他在上海某公司,在离职了几个月后,前公司的领导联系到他,希望他能够返聘回去,他很纠结要不要回去? 俗话说好马不吃回头草,但是这个小伙伴既然感到纠结了,我觉得至少说明了两个问题:1.曾经的公司还不错;2.现在的日子也不是很如意。否则应该就不会纠结了。 老实说,松哥之前也有过类似的经历,今天就来和小伙伴们聊聊回头草到底吃不吃。 首先一个基本观点,就是离职了也没必要和老东家弄的苦...

HTTP与HTTPS的区别

面试官问HTTP与HTTPS的区别,我这样回答让他竖起大拇指!

程序员毕业去大公司好还是小公司好?

虽然大公司并不是人人都能进,但我仍建议还未毕业的同学,尽力地通过校招向大公司挤,但凡挤进去,你这一生会容易很多。 大公司哪里好?没能进大公司怎么办?答案都在这里了,记得帮我点赞哦。 目录: 技术氛围 内部晋升与跳槽 啥也没学会,公司倒闭了? 不同的人脉圈,注定会有不同的结果 没能去大厂怎么办? 一、技术氛围 纵观整个程序员技术领域,哪个在行业有所名气的大牛,不是在大厂? 而且众所...

男生更看重女生的身材脸蛋,还是思想?

往往,我们看不进去大段大段的逻辑。深刻的哲理,往往短而精悍,一阵见血。问:产品经理挺漂亮的,有点心动,但不知道合不合得来。男生更看重女生的身材脸蛋,还是...

程序员为什么千万不要瞎努力?

本文作者用对比非常鲜明的两个开发团队的故事,讲解了敏捷开发之道 —— 如果你的团队缺乏统一标准的环境,那么即使勤劳努力,不仅会极其耗时而且成果甚微,使用...

为什么程序员做外包会被瞧不起?

二哥,有个事想询问下您的意见,您觉得应届生值得去外包吗?公司虽然挺大的,中xx,但待遇感觉挺低,马上要报到,挺纠结的。

当HR压你价,说你只值7K,你该怎么回答?

当HR压你价,说你只值7K时,你可以流畅地回答,记住,是流畅,不能犹豫。 礼貌地说:“7K是吗?了解了。嗯~其实我对贵司的面试官印象很好。只不过,现在我的手头上已经有一份11K的offer。来面试,主要也是自己对贵司挺有兴趣的,所以过来看看……”(未完) 这段话主要是陪HR互诈的同时,从公司兴趣,公司职员印象上,都给予对方正面的肯定,既能提升HR的好感度,又能让谈判气氛融洽,为后面的发挥留足空间。...

面试阿里p7,被按在地上摩擦,鬼知道我经历了什么?

面试阿里p7被问到的问题(当时我只知道第一个):@Conditional是做什么的?@Conditional多个条件是什么逻辑关系?条件判断在什么时候执...

终于懂了TCP和UDP协议区别

终于懂了TCP和UDP协议区别

无代码时代来临,程序员如何保住饭碗?

编程语言层出不穷,从最初的机器语言到如今2500种以上的高级语言,程序员们大呼“学到头秃”。程序员一边面临编程语言不断推陈出新,一边面临由于许多代码已存在,程序员编写新应用程序时存在重复“搬砖”的现象。 无代码/低代码编程应运而生。无代码/低代码是一种创建应用的方法,它可以让开发者使用最少的编码知识来快速开发应用程序。开发者通过图形界面中,可视化建模来组装和配置应用程序。这样一来,开发者直...

面试了一个 31 岁程序员,让我有所触动,30岁以上的程序员该何去何从?

最近面试了一个31岁8年经验的程序猿,让我有点感慨,大龄程序猿该何去何从。

大三实习生,字节跳动面经分享,已拿Offer

说实话,自己的算法,我一个不会,太难了吧

程序员垃圾简历长什么样?

已经连续五年参加大厂校招、社招的技术面试工作,简历看的不下于万份 这篇文章会用实例告诉你,什么是差的程序员简历! 疫情快要结束了,各个公司也都开始春招了,作为即将红遍大江南北的新晋UP主,那当然要为小伙伴们做点事(手动狗头)。 就在公众号里公开征简历,义务帮大家看,并一一点评。《启舰:春招在即,义务帮大家看看简历吧》 一石激起千层浪,三天收到两百多封简历。 花光了两个星期的所有空闲时...

立即提问
相关内容推荐