package com.socket;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.Reader;
import java.net.Socket;
import java.nio.CharBuffer;
/**
* Socket 长连接 客户端
*/
public class Client03 {
private String host = "127.0.0.1";
private int port = 5055;
/**
* 数据发送线程
*/
class SendThread implements Runnable {
private Socket socket;
public SendThread(Socket socket) {
this.socket = socket;
}
public void run() {
while (true) {
try {
PrintWriter pw = new PrintWriter(new OutputStreamWriter(
socket.getOutputStream()));
pw.write("this is client");
pw.flush();
Thread.sleep(2000);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
/**
* 数据接收线程
- 1
- 2
- 3
- 4
- 5
- 6
前往页