今天上午写了个小程序,实现客户端和服务器端之间数据传输。
即:客户端产生随机数,发个服务器端,服务器读取数据后加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;
}
}
}
分享到:
相关推荐
在C#编程环境中,WinForm应用常常用于构建用户界面,而Socket则被用来处理网络通信。本示例中,我们探讨的是如何利用C#的WinForm来创建一个基于Socket的服务端和客户端,实现两者之间的消息传递,以及在服务器断线后...
Java Socket 是一种基于TCP协议的低级网络通信接口,它允许两台计算机通过网络进行双向通信。在Java中,Socket提供了面向连接的、可靠的、基于字节流的通信服务。"Java Socket 长连接实例"是关于如何实现一个持久...
Socket长连接是网络编程中的重要概念,主要用于保持客户端与服务器之间的持续通信状态,避免每次通信都需要重新建立连接的开销。在长连接中,一旦连接建立成功,就会保持该连接,直到某一方主动断开或者因为网络问题...
如果客户端意外退出或关闭,服务器可能会因为尝试向已关闭的Socket发送数据而崩溃。为避免这种情况,服务器需要正确处理客户端的断开连接,比如通过异常捕获机制,检测到客户端断开连接时,立即关闭对应的Socket,...
在本文中,我们将深入探讨如何使用Microsoft Foundation Class (MFC) 库来创建一个多客户端SOCKET应用程序。MFC是微软为Windows平台开发的C++类库,它为开发者提供了丰富的功能,包括对Win32 API的封装,使得网络...
- **原因**:频繁地关闭和打开Socket会导致资源管理不稳定,尤其是在异步通信模式下。这是因为每次关闭和打开Socket都会涉及复杂的网络连接过程。 - **建议**:尽量避免频繁地关闭和打开Socket。如果需要控制发送...
通常,Socket通信会发生在后台线程,避免阻塞UI线程。可以使用Android的AsyncTask或者自定义线程来执行网络操作。 7. **安全性**: 对于敏感信息,需要考虑使用加密技术(如SSL/TLS)进行数据传输,以防止数据被...
在员工管理系统中,每个客户端的连接都由一个独立的线程来处理,避免了单线程模型中可能出现的阻塞问题,确保了系统响应的及时性。 数据库备份是数据安全的重要措施。系统内附带的Mysql数据库备份,意味着在发生...
这种情况可能是由于服务器配置或安全策略的原因。 #### ECONNRESET (错误码104) - **含义**:ECONNRESET错误码表示连接被远程主机重置。当远程主机突然关闭连接或执行硬性关闭时,客户端会收到此错误。 - **应用...
在Java中,应当使用正确的关闭方法来确保资源得到释放,并且通信不会意外中断。 NIO(New I/O)是Java提供的一种新的I/O操作方式,它比传统的I/O模型更为高效,特别是在处理大量连接时。NIO通过Buffer和Channel来...
然而在进行网络通信,特别是在发送HTTP Post请求时,可能会遇到一个常见的错误——“socket hang up”,中文意思是“套接字挂起”。 当Node.js进行Post请求时,如果遇到了“socket hang up”错误,通常意味着连接被...
3. 异步编程是解决上述问题的一个方法,它可以利用事件驱动或回调机制,以更高效的方式处理I/O操作。 总之,"run-shell with unix socket"涉及的主要知识点包括Unix域套接字的创建与使用、非阻塞I/O的设置、进程间...
本项目涉及的核心知识点是基于CS(Client/Server)模式的Socket编程,这是一种典型的网络通信模型,它包括一个服务器端程序和多个客户端程序。在该作业中,学生需要实现服务器和客户端的交互,以完成特定的任务。 ...
由于其非阻塞I/O模型和事件驱动的特性,Node.js非常适合开发网络应用和实时应用,其中就包括了网络通信应用。在Node.js中,可以利用net模块来实现基于TCP或IPC的Socket通信。 net模块是Node.js的核心模块之一,用于...
通过VS2015编译并运行这些示例,可以帮助开发者直观地感受异步Socket通信的工作流程,从而掌握在网络编程中实现高效、稳定的通信方法。 总之,C#的异步Socket通信是网络编程中重要的一部分,它允许开发者构建高性能...
`accept()`函数会阻塞直到有客户端连接,返回一个新的套接字`connectfd`,用于与特定的客户端通信。 ##### 客户端实现 客户端实现也涉及创建一个套接字: ```c if((fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) ...
2. 使用异步处理:在主线程之外处理Socket通信,避免阻塞UI。 3. 错误重试策略:在出现异常时,不要立即停止服务,而是尝试重新连接或恢复操作。 通过以上方式,我们可以确保即使在客户端断开连接的情况下,服务端...
在发送数据时,Linux推荐在`send()`函数的最后一个参数中设置`MSG_NOSIGNAL`,以避免发送错误导致SIGPIPE信号,从而可能使程序意外终止。 在时间获取方面,Windows提供了`GetTickCount()`函数,而Linux下可以使用`...
不过,对于更复杂的通信需求,如双向通信或无亲缘关系的进程间通信,可能需要使用其他IPC机制,如消息队列、套接字(Socket)或信号量等。 标签"LINUX IPC PIPE"表明这是一个关于Linux进程间通信管道的知识点。文件...