【小程序】使用TCP协议实现客户端和服务端直接交互

====================客户端=========================

/*

* 客户端与服务端互动

* 说明：

* 1.使用的BufferedReader的readLine()方法要加上\r\n才能把数据输入;

* 2. 使用字符流一定要使用flush()才能把数据写出;

*/

package com.lin.michael;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.InetAddress;

import java.net.Socket;

import java.net.UnknownHostException;

public class Client {

public static void main(String[] args) throws UnknownHostException, IOException{

//1.建立客户端TCP服务，指定与此通信的服务器的IP和port

Socket socket = new Socket(InetAddress.getLocalHost(), 9090);

//2.获取Socket对象的输出流,并且使用转换流转化成字符输出流

OutputStreamWriter socketOut = new OutputStreamWriter(socket.getOutputStream());

//3. 从键盘的输入流读取数据

BufferedReader  keyReader = new BufferedReader(new InputStreamReader(System.in));

//从服务端读取回送数据,获取Socket的输入流对象

BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

//4.写出数据

String line = null;

while((line=keyReader.readLine())!=null){

socketOut.write(line+"\r\n");

socketOut.flush();

System.out.println("服务端回送的数据是:" + socketReader.readLine());

}

//5.关闭资源

socket.close();

}

}

=====================服务端===============================

package com.lin.michael;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.ServerSocket;

import java.net.Socket;

public class Server {

public static void main(String[] args) throws IOException{

//1.创建服务端tcp服务,坚挺端口

ServerSocket serverSocket = new ServerSocket(9090);

//2.接受服务端的连接并产生一个socket

Socket socket = serverSocket.accept();

//3.获取socket的输入流对象,并转换成字符输入流

BufferedReader socketReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

//获取socket的输出流对象

OutputStreamWriter socketOut = new OutputStreamWriter(socket.getOutputStream());

//读取从键盘输入

BufferedReader keyReader = new BufferedReader(new InputStreamReader(System.in));

//4.读取客户端的数据

String line = null;

while((line=socketReader.readLine())!=null){

System.out.println("服务端接收到的资源:" + line);

System.out.println("输入个客户端的数据:");

socketOut.write(keyReader.readLine()+"\r\n");

socketOut.flush();

}

serverSocket.close();

}

}