久久久久久久999_99精品久久精品一区二区爱城_成人欧美一区二区三区在线播放_国产精品日本一区二区不卡视频_国产午夜视频_欧美精品在线观看免费

標(biāo)題: JAVA socket 實(shí)現(xiàn)同時讀寫 [打印本頁]

作者: leuku 時間: 2018-5-30 14:25
標(biāo)題: JAVA socket 實(shí)現(xiàn)同時讀寫
package cn.com.socket;

import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Reader;
import java.io.Writer;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 服務(wù)端同時讀和寫
* @author Administrator
*
*/
public class ServerDemo1 {

public static void main(String[] args) throws IOException {
//為了簡單起見，所有的異常信息都往外拋
   int port = 8899;
   //定義一個ServerSocket監(jiān)聽在端口8899上
   ServerSocket server = new ServerSocket(port);
   //server嘗試接收其他Socket的連接請求，server的accept方法是阻塞式的
   Socket socket = server.accept();
   //跟客戶端建立好連接之后，我們就可以獲取socket的InputStream，并從中讀取客戶端發(fā)過來的信息了。
   Reader reader = new InputStreamReader(socket.getInputStream());
   char chars[] = new char[64];
   int len;
   StringBuilder sb = new StringBuilder();
   String temp;
   int index;
   while ((len=reader.read(chars)) != -1) {
      temp = new String(chars, 0, len);
      if ((index = temp.indexOf("eof")) != -1) {//遇到eof時就結(jié)束接收
         sb.append(temp.substring(0, index));
         break;
      }
      sb.append(temp);
   }
   System.out.println("我是服務(wù)器,客戶端說: " + sb);
   //讀完后寫一句
   Writer writer = new OutputStreamWriter(socket.getOutputStream());
   writer.write("Hello Client.");
   writer.flush();
   writer.close();
   reader.close();
   socket.close();
   server.close();
  }

}

package cn.com.socket;

import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Reader;
import java.io.Writer;
import java.net.Socket;
import java.net.UnknownHostException;
/**
* 客戶端同時讀和寫
* @author Administrator
*
*/
public class ClientDemo1 {

public static void main(String[] args) throws UnknownHostException, IOException {
  //為了簡單起見，所有的異常都直接往外拋
String host = "localHost";  //要連接的服務(wù)端IP地址
int port = 8899; //要連接的服務(wù)端對應(yīng)的監(jiān)聽端口
//與服務(wù)端建立連接
Socket client = new Socket(host, port);
   //建立連接后就可以往服務(wù)端寫數(shù)據(jù)了
Writer writer = new OutputStreamWriter(client.getOutputStream());
   writer.write("Hello Server.");
   writer.write("eof");
   writer.flush();
   //寫完以后進(jìn)行讀操作
Reader reader = new InputStreamReader(client.getInputStream());
   char chars[] = new char[64];
   int len;
   StringBuffer sb = new StringBuffer();
   String temp;
   int index;
   while ((len=reader.read(chars)) != -1) {
      temp = new String(chars, 0, len);
      if ((index = temp.indexOf("eof")) != -1) {
         sb.append(temp.substring(0, index));
         break;
      }
      sb.append(new String(chars, 0, len));
   }
   System.out.println("我是客戶端,服務(wù)器說: " + sb);
   writer.close();
   reader.close();
   client.close();
  }

}

歡迎光臨 (http://www.zg4o1577.cn/bbs/)