首页 > 代码库 > Java -- Tcp Socket的使用
Java -- Tcp Socket的使用
客户端
/******************** Client **************************/ public void startSocket() { new Thread(new initSocket()).start(); } private Socket sendClient = null; private OutputStream sendOutStream = null; private boolean bSendisc = false; class initSocket implements Runnable { @Override public void run() { try { sendClient = new Socket(); InetSocketAddress isa = new InetSocketAddress("127.0.0.1".replace("/", ""), 8088); sendClient.connect(isa, 2000); sendClient.setSendBufferSize(500000); sendClient.setReceiveBufferSize(500000); sendClient.setPerformancePreferences(0, 0, 1); bSendisc = sendClient.isConnected(); sendClient.setTcpNoDelay(true); sendClient.setKeepAlive(true); sendOutStream = sendClient.getOutputStream(); } catch (IOException e) { e.printStackTrace(); } } } //建立连接后,采用OutputStream进行数据的发送 sendOutStream.write(data); //byte流数据
注意:Android中,socket的连接操作不能在主线程里面进行,必须开启新的线程;
/******************** Server **************************/ public void startListen() { new Thread(this).start(); } private final int PORT = 8088; private ServerSocket server; public void run() { //创建TCP Server 接收视频流 Socket client; DataInputStream is = null; try { server = new ServerSocket(PORT); client = server.accept(); client.setReceiveBufferSize(500000); client.setSendBufferSize(500000); client.setTcpNoDelay(true); client.setPerformancePreferences(0, 0, 1); is = new DataInputStream(client.getInputStream()); } catch (IOException e) { e.printStackTrace(); } //建立连接后开始进行读取 byte[] data = http://www.mamicode.com/new byte[1000];>Java -- Tcp Socket的使用
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。