socket客户服务器_socket通信服务器

文章目录：

• 1、TCP/IP 使用Socket 实现客户端与服务器端通信
• 2、socket 客户端和服务器一体。
• 3、如何使用socket进行客户端和服务器端的通信
• 4、如何判断socket客户端和服务器端
• 5、socket客户端如何连接服务器端

TCP/IP 使用Socket 实现客户端与服务器端通信

之所以称为TCP服务器，是因为服务器端执行TCP的listen（监听连入请求）逻辑；而TCP客户端执行的是connect（请求连接）逻辑。

所以，不能可能让服务器去主动连接客户端端的。

socket 客户端和服务器一体。

服务器的部分用一个ServerSocket来listen一个port。客户端的部分是用一个Socket来打开对另一个地方的connection，两个不干扰的。只是ServerSocket.accept()应该会block你的execution，所以你可能需要让你的server的部分和client的部分在不同的thread里面运行。

如何使用socket进行客户端和服务器端的通信

下载完成后，软件是一个单独的运行程序，可以直接打开软件。

3

软件的界面很简单，在左侧有tcp和udp的客户端或服务端的快捷按钮，上方有【创建】【删除】【退出】等选项按钮。

4

我们先来建立TCP的测试服务端。点击【TCP Server】再点击【创建】。

选择一个监听端口，这里我们使用6001作为服务端的监听端口。

建立完成后，服务端会自动启动，软件会显示【启动监听】的状态。

我们可以检测一下本机的6001端口是否已经打开。在DOS窗口中输入命令【netstat -a】，可以在列表中看到本机的6001端口的状态为listening的状态，表示本机的6001端口正处于监听的状态。

在DOS窗口中输入命令【telnet 192.168.0.140 6001】来登录本地的6001端口。

点击回车键，就可以成功登录6001端口。在测试软件中就可以看到状态是已连接的状态，同时也可以看到对方的ip就是本地ip。

再来测试通信情况，在DOS窗口中输入a、b、c，在软件的接收窗口就可以看到收到的数据了。

在软件的发送窗口中输入1234567890，点击发送后，在DOS窗口中就可以看到软件发送过来的数据了。

测试完成后，在软件中点击【停止监听】，同时在DOS窗口中可以看到【失去了跟主机的连接】，表示测试连接已经断开。

再来创建TCP的客户端，点击【TCP Client】再点击【创建】。会弹出【创建socket客户端】窗口，输入对方的ip和对方的端口，点击确认。

tcp的客户端已经建立好，如果对方的端口监听正常的话，点击【连接】就可以连接到对方的端口和对方进行测试通信了。

如何判断socket客户端和服务器端

法一：

当recv()返回值小于等于0时，socket连接断开。但是还需要判断 errno是否等于 EINTR，如果errno == EINTR 则说明recv函数是由于程序接收到信号后返回的，socket连接还是正常的，不应close掉socket连接。

法二：

struct tcp_info info;

int len=sizeof(info);

getsockopt(sock, IPPROTO_TCP, TCP_INFO, info, (socklen_t *)len);

if((info.tcpi_state==TCP_ESTABLISHED)) 则说明未断开 else 断开

法三：

若使用了select等系统函数，若远端断开，则select返回1，recv返回0则断开。其他注意事项同法一。

法四：

int keepAlive = 1; // 开启keepalive属性

int keepIdle = 60; // 如该连接在60秒内没有任何数据往来,则进行探测

int keepInterval = 5; // 探测时发包的时间间隔为5 秒

int keepCount = 3; // 探测尝试的次数.如果第1次探测包就收到响应了,则后2次的不再发.

setsockopt(rs, SOL_SOCKET, SO_KEEPALIVE, (void *)keepAlive, sizeof(keepAlive));

setsockopt(rs, SOL_TCP, TCP_KEEPIDLE, (void*)keepIdle, sizeof(keepIdle));

setsockopt(rs, SOL_TCP, TCP_KEEPINTVL, (void *)keepInterval, sizeof(keepInterval));

setsockopt(rs, SOL_TCP, TCP_KEEPCNT, (void *)keepCount, sizeof(keepCount));

设置后，若断开，则在使用该socket读写时立即失败，并返回ETIMEDOUT错误

socket客户端如何连接服务器端

import java.net.*;

import java.lang.*;

import java.io.*;

public class MySocketServer

{

public static void main(String args[]) //throws IOException

{

try{

ServerSocket myServer = new ServerSocket(8018);

System.out.println("正在监听端口："+myServer.getLocalPort());

Socket myClient = null;

boolean flag = true;

String InputMessage = null;

int c;

while(flag)

{

myClient = myServer.accept();

//接收客户端的信息，如果不是Stop就继续监听，加个if判断

DataInputStream dataIn = new DataInputStream(myClient.getInputStream());

//DataInputStream dataIn = new DataInputStream(new BufferedInputStream(myClient.getInputStream()));

OutputStream dataOut = myClient.getOutputStream();

while( (InputMessage = dataIn.readLine()) != null )

{

if( InputMessage.equals("stop"))

{

flag = false;

break;

}

else

{

System.out.println("从客户端接收到的信息是："+InputMessage);

//输入：读取至 末尾-1结束，遇到回车'\n'结束：

while((c=System.in.read())!= -1)

{

dataOut.write((byte)c);

if( c== '\n')

{

dataOut.flush();

break;

}

}

}

}

dataIn.close();

dataOut.close();

myClient.close();

}

myServer.close();

}

catch(Exception e)

{

System.out.println(e.getMessage());

}

}

}

客户端：

import java.io.*;

import java.lang.*;

import java.net.*;

public class MySocketClient

{

public static void main(String args[])

{

try{

Socket myClient = new Socket("192.168.1.25",8018);

DataInputStream dataIn = new DataInputStream(myClient.getInputStream());

OutputStream dataOut = myClient.getOutputStream();

boolean flag = true;

int c;

String serverResponse = null ;

while(flag)

{

while( (c=System.in.read())!= -1 )

{

dataOut.write((byte)c);

if(c=='\n')

{

dataOut.flush();

serverResponse = dataIn.readLine();

System.out.println("服务器的返回信息是："+serverResponse);

}

}

}

dataIn.close();

dataOut.close();

myClient.close();

}

catch(Exception e)

{

System.out.println("Exception :"+e.getMessage());

}

}

}