Java使用Sockt进行通信（2）

使用TCP协议编写Sockt

TCP（Transmission Control Protocol 传输控制协议）是一种面向连接的、可靠的、基于字节流的传输层通信协议，由IETF的RFC 793定义。

TCP层是位于IP层之上，应用层之下的中间层。不同主机的应用层之间经常需要可靠的、像管道一样的连接，但是IP层不提供这样的流机制，而是提供不可靠的包交换。

Socket和ServerSocket类库位于java.net包中。ServerSocket用于服务器端，Socket是建立网络连接时使用的

具体代码：

服务端：
*端口号可以自定义

package cn.socket2;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class SeviceSocpt {
    /*
     *       服务端发送信息，接收信息
     */
    public static void main(String[] args) throws Exception {

                //1.创建对象
                ServerSocket sk=new ServerSocket(11111);
                //2.监听
                Socket s=sk.accept();
                //打包数据
                BufferedReader br=new BufferedReader(new 
                                  InputStreamReader(s.getInputStream()));    
                BufferedReader bw=new BufferedReader(new 
                                     InputStreamReader(System.in));
                OutputStream os=s.getOutputStream();
                String line=null;
                //使用循环可多次发送信息
                while((line=br.readLine())!=null){
                    System.out.println("Client 	"+line);        
                    
                    os.write(bw.readLine().getBytes());
                }            
                //释放资源
                s.close();

    }

}

客户端：

package cn.socket2;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;

public class ClientSocket {
/*
 *       客户端发送信息，接收信息
 */
    public static void main(String[] args) throws Exception {
        //创建Socket对象 并写入IP地址及端口号
        Socket sk=new Socket("192.168.60.218",11111);
        //使用IO流读取数据和写入数据
        BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
        BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(sk.getOutputStream()));
        String line=null;
        //使用循环使用循环可多次发送信息
        while((line=br.readLine())!=null){            
            bw.write(line);
            bw.newLine();
            bw.flush();
            
            InputStream is=sk.getInputStream();            
            byte [] by=new byte[1024];
            int num=is.read(by);
            String h=new String(by, 0, num);
            System.out.println("Service:	"+h);
        }    
        //释放资源
                   br.close();
                    bw.close();
           sk.close();

    }

}