文档章节

JAVA TCP 长连接通信

A
 ActionTime
发布于 2017/04/07 14:19
字数 326
阅读 162
收藏 0

由于TCP通信短连接在一次读写操作后关闭链接

而建立链接需要3次握手,而释放时需要4次握手

在一个客户端与服务器频繁通信时采用短连接是非常消耗资源和消耗时间的 

更多参考http://www.cnblogs.com/beifei/archive/2011/06/26/2090611.html

所以此时采用长连接比较合理,以下是亲自测试过的TCP长连接

 

Client代码:

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

public class TCPClientTest {

	private static final int SERVER_PORT=2010;
	
	public static void main(String[] args) throws Exception {
		   Socket socket = new Socket("127.0.0.1", SERVER_PORT);
		   System.out.println("Connected to server...sending command string");
		   OutputStream out = socket.getOutputStream();
		   int i = 0;
		   while (i < 10) {
		   out.write(("test" + i).getBytes());  // 发送
		   	out.flush();
		   	Thread.sleep(1000);
		   	i++;
		   }
		   out.close();
		   socket.close();
	}
}

Server代码:

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Hashtable;

public class TCPTransport {
	
    private static final int SERVER_PORT=2010;
 
    private static   Hashtable<String, Socket> ht = new Hashtable();
    
    public static void main(String[] args) throws IOException {
        // TODO Auto-generated method stub
        System.out.println("VNTCenter.main()===TCP SERVER==============");
        ServerSocket vntServer = null;
        try{
            vntServer= new ServerSocket(SERVER_PORT);

            System.out.println("Listening Port is "+vntServer.getLocalPort()+"...");
            while(true){
                Socket vntClient=vntServer.accept();
                System.out.println("have a client entering , the IP is "+vntClient.getInetAddress()+"...");
                System.out.println("have a client entering , the Port is "+vntClient.getPort()+"...");
                new GetGpsThreadFun(vntClient).start();
                ht.put(vntClient.getInetAddress().toString(),vntClient);
            }
        }catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
            vntServer.close();
        }
    }
}

class GetGpsThreadFun extends Thread{
    private Socket vntThreadClient;

    public GetGpsThreadFun(Socket vntThreadSocket){
        vntThreadClient=vntThreadSocket;
    }
    public void run(){
        try{
        	byte[] data = new byte[128];
            while(true){
            	int len = vntThreadClient.getInputStream().read(data);
            	if (len > 0){
            		System.out.println(vntThreadClient.getInetAddress()+":"+vntThreadClient.getPort()+":"+new String(data,0,len));
                  if("shutdown".equals(vntThreadClient)){
                      break;
                  }
            	}
            }
        }catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        }
    }

}

© 著作权归作者所有

共有 人打赏支持
A
粉丝 0
博文 5
码字总数 1333
作品 0
杭州

暂无文章

现场看路演了!

HiBlock
18分钟前
0
0
Rabbit MQ基本概念介绍

RabbitMQ介绍 • RabbitMQ是一个消息中间件,是一个很好用的消息队列框架。 • ConnectionFactory、Connection、Channel都是RabbitMQ对外提供的API中最基本的对象。Connection是RabbitMQ的s...

寰宇01
34分钟前
1
0
官方精简版Windows10:微软自己都看不过去了

微软宣布,该公司正在寻求解决方案,以减轻企业客户的Windows 10规模。该公司声称,企业客户下载整个Windows 10文件以更新设备既费钱又费时。 微软宣布,该公司正在寻求解决方案,以减轻企业...

linux-tao
39分钟前
0
0
TypeScript基础入门之JSX(二)

转发 TypeScript基础入门之JSX(二) 属性类型检查 键入检查属性的第一步是确定元素属性类型。 内在元素和基于价值的元素之间略有不同。 对于内部元素,它是JSX.IntrinsicElements上的属性类型...

durban
今天
1
0
AVA中CAS-ABA的问题解决方案AtomicStampedReference

了解CAS(Compare-And-Swap) CAS即对比交换,它在保证数据原子性的前提下尽可能的减少了锁的使用,很多编程语言或者系统实现上都大量的使用了CAS。 JAVA中CAS的实现 JAVA中的cas主要使用的是...

码代码的小司机
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部