基于Socket长连接多线程传输数据的简单示例

import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

	/**
	 * @param args
	 */
	public static void main(String[] args) throws Exception {
		ServerSocket socketServer = new ServerSocket(9090);
		while (true) {
			Socket socket = socketServer.accept();
			InputStream in = socket.getInputStream();
			byte[] b = new byte[7];
			int len;
			try {
				while ((len = in.read(b)) != -1) {
					String value = new String(b, 0, len);
					double d=Double.parseDouble(value);
					//process data
					System.out.println(d);
				}
			} catch (Exception ex) {
				//handle exception
				ex.printStackTrace();
			}
		}
	}

}

import java.io.OutputStream;
import java.net.Socket;

public class Client {
	static class SendThread extends Thread {
		Socket server;
		byte[] value;

		public SendThread(Socket server, String value) {
			super();
			this.server = server;
			this.value = value.getBytes();
		}

		public void run() {
			while (true) {
				try {
					OutputStream out = server.getOutputStream();
					out.write(value);
					out.flush();
					Thread.sleep(1000);
				} catch (Exception ex) {
					return;
				}
			}
		}
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) throws Exception {
		Socket server = new Socket("localhost", 9090);
		SendThread t1 = new SendThread(server, "1111.11");
		SendThread t2 = new SendThread(server, "2222.22");
		SendThread t3 = new SendThread(server, "3333.33");
		t1.start();
		t2.start();
		t3.start();
	}

}

评论

4 楼 xhpscdx 2016-08-28  

兄弟，你这个算长连接应用吗？不关闭stream，不关闭socket，就算长连接吗？

3 楼 贝爷粉丝团 2015-04-01  

davidchouwolf 写道

也碰到一个类似的应用，需要长连接，客户端大约是两三千个，那么服务端开的线程岂不是也要两三千个？这样到后面线程跑多了，效率就越来越低了，有什么好的解决方式吗？

是不是要用线程池？

2 楼 davidchouwolf 2012-11-08  

也碰到一个类似的应用，需要长连接，客户端大约是两三千个，那么服务端开的线程岂不是也要两三千个？这样到后面线程跑多了，效率就越来越低了，有什么好的解决方式吗？

1 楼 季铵盐 2012-08-06