1、创建一个简单的socket连接。
当客户端与服务端进行通信时,服务端首先监听端口,程序中监听本地8000端口,通过while(true)轮询,不断地去accept方法(阻塞的)连接,这时客户端如果创建连接,服务端都能拿到这个连接,对应扔给处理器去处理客户端连接,这个连接创建完成之后,客户端就将数据写入服务端,那么对于服务端就是接收数据过程,服务端接收到数据要进行一系列的处理。
2、启动服务端。
package com.waylau.Netty;
/**
* socketDemo
*/
public class SocketDemo {
private static final int PORT = 8000;
public static void main(String[] args) {
//创建服务端,传入监听的PORT端口号
Server server = new Server(PORT);
server.start();
}
}
3、服务端。
package com.waylau.Netty;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
private ServerSocket serverSocket;
public Server(int port) {
try {
this.serverSocket = new ServerSocket(port);
System.out.println("服务端启动成功,端口:" + port);
} catch (IOException exception) {
System.out.println("服务端启动失败");
}
}
public void start() {
new Thread(new Runnable() {
@Override
public void run() {
doStart();
}
}).start();
}
private void doStart() {
while (true) {
try {
//accpet阻塞的
Socket client = serverSocket.accept();
new ClientHandler(client).start();
} catch (IOException e) {
System.out.println("服务端异常");
}
}
}
}
4、客户端。
package com.waylau.Netty;
import java.io.IOException;
import java.net.Socket;
public class Client {
private static final String HOST = "127.0.0.1";
private static final int PORT = 8000;
private static final int SLEEP_TIME = 5000;
public static void main(String[] args) throws IOException {
final Socket socket = new Socket(HOST, PORT);
new Thread(new Runnable() {
@Override
public void run() {
System.out.println("客户端启动成功!");
while (true) {
try {
String message = "hello world";
System.out.println("客户端发送数据: " + message);
socket.getOutputStream().write(message.getBytes());
} catch (Exception e) {
System.out.println("写数据出错!");
}
sleep();
}
}
}).start();
}
private static void sleep() {
try {
Thread.sleep(SLEEP_TIME);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
5、服务端处理客户端数据的对象。
package com.waylau.Netty;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
public class ClientHandler {
public static final int MAX_DATA_LEN = 1024;
private final Socket socket;
public ClientHandler(Socket socket) {
this.socket = socket;
}
public void start() {
System.out.println("新客户端接入");
new Thread(new Runnable() {
@Override
public void run() {
doStart();
}
}).start();
}
private void doStart() {
try {
//通过InputStream获得客户端传来的数据
InputStream inputStream = socket.getInputStream();
while (true) {
byte[] data = new byte[MAX_DATA_LEN];
int len;
while ((len = inputStream.read(data)) != -1) {
String message = new String(data, 0, len);
System.out.println("客户端传来消息: " + message);
socket.getOutputStream().write(data);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
5、结果。