最近在 学习了socket 发现socket果然是个好东西. 仔细的去了解发现用途真的太多.通过scoket编写的东西能很好的做到各种兼容性.比如大家孰知的HTTP 协议了.sokcet通过一些同行协议就能就完成了HTTP . 想想就感觉好厉害呀.

        HTTP 这样强大的协议也不是在任何情况都是很有效的.如HTTP 需要实现长链接就显得有些力不从心了.HTTP 适合BS下的应用需要什么数据就从服务器请求什么数据.如果想要服务器主动找客户端的话就不是那样容易了.HTTP 基于请求的特点就无法完成服务端一主动找客户端(浏览器)

HTTP 协议是BS 的应用需要的.为了满足服务端的需要求.请求头是比较长的. 于是实际的业务逻辑中是需要自己去实现一些协议.

        编写一个简单的服务端的客户端的代码

        server 端代码

package com.fzb.socket;

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

public class MyServer {

 public static void main(String[] args) {
  ServerSocket server=null;
  try {
   server=new ServerSocket(8888);
   System.out.println("server is run");
   while(true){
    // accept 这个方式会对server进行堵塞 当有链接上来后会不再堵塞
    Socket socket=server.accept();
    System.out.println(socket.getInetAddress() +" get connect");
    socket.getOutputStream().write(("Hello I'm server,you want to tell some sth "+MyClient.ENDCHAR).getBytes());
    InputStream in=socket.getInputStream();
    byte sth[]=MyClient.getByteArrayByInputStream(in);
    System.out.println("client say: "+new String(sth));
    socket.getOutputStream().write(("now I know, you say "+new String(sth)+MyClient.ENDCHAR).getBytes() );
    in.close();
    socket.close();
   }
  } catch (IOException e) {
   e.printStackTrace();
  }
  finally{
   if(server!=null){
    try {
     server.close();
    } catch (IOException e) {
     e.printStackTrace();
    }
   }
  }
 }
}

        client 端代码

package com.fzb.socket;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

public class MyClient {

 public static String ENDCHAR="*";
 public static void main(String[] args) {
  try {
   Socket socket=new Socket("127.0.0.1", 8888);
   InputStream in=socket.getInputStream();
   String message=new String(getByteArrayByInputStream(in));
   System.out.println("server say: "+message);
   Scanner sc=new Scanner(System.in);
   String sendMessage=sc.nextLine()+ENDCHAR;
   OutputStream out=socket.getOutputStream();
   out.write(sendMessage.getBytes());
   // 读取服务端的消息
   message=new String(getByteArrayByInputStream(in));
   System.out.println("server say: "+message);
  } catch (UnknownHostException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  }
 }
 
 public static byte[] getByteArrayByInputStream(InputStream in){
  byte temp[]=new byte[5];
  ByteArrayOutputStream out=new ByteArrayOutputStream();
  try {
   // in.read(temp) 这里也会发生堵塞.有到来是不再发生堵塞
   in.read(temp);
   while(!new String(temp).trim().endsWith(ENDCHAR)){
    out.write(temp);
    temp =new byte[5];
    in.read(temp);
   }
   out.write(new String(temp).replace(ENDCHAR, "").getBytes());
  } catch (IOException e) {
   e.printStackTrace();
  }
  return out.toByteArray();
 }
}

client console

server console