`
nbtlxx
  • 浏览: 253193 次
  • 性别: Icon_minigender_1
  • 来自: 宁波
社区版块
存档分类
最新评论

socket通信意外阻塞的可能原因及解决办法

阅读更多
今天上午写了个小程序,实现客户端和服务器端之间数据传输。
即:客户端产生随机数,发个服务器端,服务器读取数据后加1,回传给客户端并打印。但是程序总是在通信一次后处于阻塞状态。

查了半天,原来是dos.writeInt(data), 写成了dos.write(data); 导致客户端得不到数据,整个链路中断。
1. 教训之一,必须要足够仔细,两端发送的数据格式必须一致。
2. 解决了客户端关闭之后,服务器端报异常的问题,就是直接在catch{
   server.close()
   依次关闭isRunning = false, dis, dos, socket!
}
   同样道理,防止客户端报错,也是在相应的catch里面,关闭客户端连接及循环

Server
/**
 * 
 */
package study;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author sean
 * 
 * 建立serversocket
 * 接受clientsocket
 * 建立workthread(socket),startWork
 * work:
 * 	while(true)
 * 	   int read = dis.readInt();
 *     dos.write(read+1); 
 *
 */
public class Server {

	static int port = 9999;
	/**
	 * @param args
	 * @throws IOException 
	 */
	public static void main(String[] args) throws IOException {
		// TODO Auto-generated method stub
		
		ServerSocket server = new ServerSocket(port);
		System.out.println("服务器启动" + server.getLocalPort()+ " :" + server.getInetAddress());
		
		while(true){
			Socket socket = server.accept();
			System.out.println("接入...." + socket.getInetAddress() + socket.getPort());
			
			Work1 work1 = new Work1();
			work1.socket = socket;			
			new Thread(work1).start();
			
//			Work work = new Work();
//			work.socket = socket;
//			new Thread(work).start();			
		}		
	}
	
public static class Work1 implements Runnable {
		
		Socket socket = null;

		@Override
		public void run() {
			try {
				DataInputStream dis = new DataInputStream(socket.getInputStream());
				DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
				
				while(true) {
					int num = dis.readInt();					
					dos.writeInt(num + 1);
					System.out.println("server1 read data: " + num);
				}
				
				
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}			
		}
	}
}


Client
/**
 * 
 */
package study;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Random;

/**
 * @author sean
 * 1. socket 连接
 * 2. 循环
 *    获得dis, dos
 * 3. 发送随机数 random
 * 4. 接受随机数,并且判断temp+1=recv ?
 * 
 *
 */
public class Client implements Runnable {

	private static String addr = "127.0.0.1";
	private static int port = 9999;

	/**
	 * @param args
	 * @throws IOException 
	 * @throws UnknownHostException 
	 */
	public static void main(String[] args) throws UnknownHostException,
			IOException {
		// TODO Auto-generated method stub

		Client client = new Client(addr, port);
		new Thread(client).start();
	}

	public Client(String addr, int port) {
		this.addr = addr;
		this.port = port;

	}

	boolean isRunning;

	@Override
	public void run() {
		// TODO Auto-generated method stub
		longConnection();
	}

	DataOutputStream dos;
	DataInputStream dis;
	Socket socket;
	Random rand = new Random(10000);

	private void longConnection() {
		// TODO Auto-generated method stub
		isRunning = true;
		while (isRunning) {
			try {
				socket = new Socket(addr, port);
				System.out.println("socket connect ok");
				dis = new DataInputStream(socket.getInputStream());
				dos = new DataOutputStream(socket.getOutputStream());
			} catch (IOException e) {
				closeSocket();
			}

			int temp;
			int checkIn = 0;

			while (isRunning) {
				temp = rand.nextInt();
				try {
					dos.writeInt(temp);
					checkIn = dis.readInt();
					System.out.println("temp:" + temp);
					System.out.println("checkin:" + checkIn);
				} catch (IOException e) {
					// TODO Auto-generated catch block
					closeSocket();
//					e.printStackTrace();
				}

			}
		}
	}

	private void closeSocket() {
		// TODO Auto-generated method stub
		isRunning = false;

		if (dis != null) {
			try {
				dis.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			dis = null;
		}

		if (dos != null) {
			try {
				dos.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			dos = null;
		}

		if (socket != null) {
			try {
				socket.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			socket = null;
		}
	}
}




0
0
分享到:
评论

相关推荐

    c# WinForm 使用Socket实现简单实现服务端与客户端连接,实现消息发送,服务器客户端重连

    在C#编程环境中,WinForm应用常常用于构建用户界面,而Socket则被用来处理网络通信。本示例中,我们探讨的是如何利用C#的WinForm来创建一个基于Socket的服务端和客户端,实现两者之间的消息传递,以及在服务器断线后...

    java socket 长连接实例

    Java Socket 是一种基于TCP协议的低级网络通信接口,它允许两台计算机通过网络进行双向通信。在Java中,Socket提供了面向连接的、可靠的、基于字节流的通信服务。"Java Socket 长连接实例"是关于如何实现一个持久...

    Socket长连接+心跳包+发送读取

    Socket长连接是网络编程中的重要概念,主要用于保持客户端与服务器之间的持续通信状态,避免每次通信都需要重新建立连接的开销。在长连接中,一旦连接建立成功,就会保持该连接,直到某一方主动断开或者因为网络问题...

    socket 单服务器/多客户端

    如果客户端意外退出或关闭,服务器可能会因为尝试向已关闭的Socket发送数据而崩溃。为避免这种情况,服务器需要正确处理客户端的断开连接,比如通过异常捕获机制,检测到客户端断开连接时,立即关闭对应的Socket,...

    MFC多客户端SOCKET实例

    在本文中,我们将深入探讨如何使用Microsoft Foundation Class (MFC) 库来创建一个多客户端SOCKET应用程序。MFC是微软为Windows平台开发的C++类库,它为开发者提供了丰富的功能,包括对Win32 API的封装,使得网络...

    Socket的问题.doc

    - **原因**:频繁地关闭和打开Socket会导致资源管理不稳定,尤其是在异步通信模式下。这是因为每次关闭和打开Socket都会涉及复杂的网络连接过程。 - **建议**:尽量避免频繁地关闭和打开Socket。如果需要控制发送...

    SocketClient

    通常,Socket通信会发生在后台线程,避免阻塞UI线程。可以使用Android的AsyncTask或者自定义线程来执行网络操作。 7. **安全性**: 对于敏感信息,需要考虑使用加密技术(如SSL/TLS)进行数据传输,以防止数据被...

    基于Socket的公司员工管理系统

    在员工管理系统中,每个客户端的连接都由一个独立的线程来处理,避免了单线程模型中可能出现的阻塞问题,确保了系统响应的及时性。 数据库备份是数据安全的重要措施。系统内附带的Mysql数据库备份,意味着在发生...

    LINUX SOCKET错误分析

    这种情况可能是由于服务器配置或安全策略的原因。 #### ECONNRESET (错误码104) - **含义**:ECONNRESET错误码表示连接被远程主机重置。当远程主机突然关闭连接或执行硬性关闭时,客户端会收到此错误。 - **应用...

    Java TCP IP Socket编程(中文版).pdf

    在Java中,应当使用正确的关闭方法来确保资源得到释放,并且通信不会意外中断。 NIO(New I/O)是Java提供的一种新的I/O操作方式,它比传统的I/O模型更为高效,特别是在处理大量连接时。NIO通过Buffer和Channel来...

    Nodejs Post请求报socket hang up错误的解决办法

    然而在进行网络通信,特别是在发送HTTP Post请求时,可能会遇到一个常见的错误——“socket hang up”,中文意思是“套接字挂起”。 当Node.js进行Post请求时,如果遇到了“socket hang up”错误,通常意味着连接被...

    run-shell with unix socket

    3. 异步编程是解决上述问题的一个方法,它可以利用事件驱动或回调机制,以更高效的方式处理I/O操作。 总之,"run-shell with unix socket"涉及的主要知识点包括Unix域套接字的创建与使用、非阻塞I/O的设置、进程间...

    基于CS模式的socket编程

    本项目涉及的核心知识点是基于CS(Client/Server)模式的Socket编程,这是一种典型的网络通信模型,它包括一个服务器端程序和多个客户端程序。在该作业中,学生需要实现服务器和客户端的交互,以完成特定的任务。 ...

    nodejs socket服务端和客户端简单通信功能

    由于其非阻塞I/O模型和事件驱动的特性,Node.js非常适合开发网络应用和实时应用,其中就包括了网络通信应用。在Node.js中,可以利用net模块来实现基于TCP或IPC的Socket通信。 net模块是Node.js的核心模块之一,用于...

    CSharpAsynSocket.zip

    通过VS2015编译并运行这些示例,可以帮助开发者直观地感受异步Socket通信的工作流程,从而掌握在网络编程中实现高效、稳定的通信方法。 总之,C#的异步Socket通信是网络编程中重要的一部分,它允许开发者构建高性能...

    循环服务器(socket)

    `accept()`函数会阻塞直到有客户端连接,返回一个新的套接字`connectfd`,用于与特定的客户端通信。 ##### 客户端实现 客户端实现也涉及创建一个套接字: ```c if((fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) ...

    MyApplication2.zip

    2. 使用异步处理:在主线程之外处理Socket通信,避免阻塞UI。 3. 错误重试策略:在出现异常时,不要立即停止服务,而是尝试重新连接或恢复操作。 通过以上方式,我们可以确保即使在客户端断开连接的情况下,服务端...

    Linux下Socket编程.docx

    在发送数据时,Linux推荐在`send()`函数的最后一个参数中设置`MSG_NOSIGNAL`,以避免发送错误导致SIGPIPE信号,从而可能使程序意外终止。 在时间获取方面,Windows提供了`GetTickCount()`函数,而Linux下可以使用`...

    Linux进程间通信之管道

    不过,对于更复杂的通信需求,如双向通信或无亲缘关系的进程间通信,可能需要使用其他IPC机制,如消息队列、套接字(Socket)或信号量等。 标签"LINUX IPC PIPE"表明这是一个关于Linux进程间通信管道的知识点。文件...

Global site tag (gtag.js) - Google Analytics