求救，急急急。 - 黑马程序员技术交流社区

import java.io.*;
import java.net.*;
/*
需求：使用TCP协议完成一个客户端一个服务器。客户端从键盘输入读取一个字符串，发送到服务器。
服务器接收客户端发送的字符串，反转之后发回客户端。客户端接收并打印。
*/
/*
客户端：
1. 需要先有socket端点。
2. 客户端的数据源：键盘。
3. 客户端的目的：socket。
4. 接收服务端的数据，源：socket。
5. 将数据显示再打印出来。目的：控制台。
6. 在这些流中操作的数据，都是文本数据。
*/
class MyClient {
public static void main(String[] args)throws Exception{
//创建客户端Socket服务
Socket s = new Socket("127.0.0.1",10010);
//获取键盘录入
BufferedReader bfr = new BufferedReader(new InputStreamReader(System.in));
//socket输出流
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
//socket输入流，读取服务端返回的反转数据
BufferedReader bfrIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
//把键盘获取的数据发送出去，输入over时结束客户端
String line = null;
while((line=bfr.readLine())!=null){
if("over".equals(line))
break;
out.println(line);
//读取服务器端返回的数据
String turn = bfrIn.readLine();
System.out.println(turn);
}
s.close();
}
}
/*
转换服务器
分析：
1. serversocket服务。
2. 获取socket对象。
3. 源：socket，读取客户端发过来需要转换的数据。
4. 目的：显示在控制台上。
5. 将数据转换顺序发给客户端。
*/
class TransServer {
public static void main(String[] args)throws Exception {
//创建ServerSocket
ServerSocket ss = new ServerSocket(10010);
//获取socket对象
Socket s = ss.accept();
//获取客户端的ip，有客户端连接进来时提示
String ip = s.getInetAddress().getHostAddress();
System.out.println(ip+"....is connected");
//获取socket读取流，并用BufferedReader装饰
BufferedReader bufr = new BufferedReader(new InputStreamReader(s.getInputStream()));
//获取socket的输出流，用PrintWriter装饰，方便刷新数据
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
String line = null;
while((line=bufr.readLine())!=null){
System.out.println(line);
//创建StringBuffer容器，使用它里面的reverse反转方法
StringBuffer sb = new StringBuffer(line);
out.println(sb.reverse());
}
s.close();
ss.close();
}
}

复制代码

new InputStreamReader(System.in));// 从键盘获取输入流到缓冲区；

BufferedWriter bufout=new BufferedWriter(newOutputStreamWriter(s.getOutputStream())

BufferedReader buf =new BufferedReader(newInputStreamReader(s.getInputStream()));

BufferedWriter bufout=newBufferedWriter(newOutputStreamWriter(s.getOutputStream())

/**
* 步骤：第一步：创建客户端--(得到键盘输入-发送数据-获得服务端反馈-输出结果)
* 第二步：创建服务端---通过服务端accept()方法，获得输入输出流，进行数据操作(获得-反转-输出)
* 因为只需要读取一个字符串，客户端只读一次就关闭流，只输出一次就关闭客户端输出流
* @author Administrator
*---测试类
*/
import java.net.*;
import java.io.*;
import java.util.*;
public class ReverseString{
//主线程
public static void main(String[] args) {
new Thread(new TcpServer()).start();//对于TCP协议，首先建立服务端线程
new Thread(new TcpClient()).start();//其次建立客户端线程
}
}
/**
* 客户端
* @author Administrator
*
*/
class TcpClient implements Runnable{
public void run(){//客户端线程run方法
Socket s=null;
BufferedReader isw=null;
try {
isw=new BufferedReader(new InputStreamReader(System.in));//键盘输入流
String str=isw.readLine();//获得键盘录入
s=new Socket(InetAddress.getLocalHost(),11112);//客户端
BufferedWriter bufw=//客户端输出流
new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
bufw.write(str);
bufw.flush();//输出并刷新流
s.shutdownOutput();//关闭输出流
BufferedReader bufr=//客户端输入流，读取服务端反馈的信息
new BufferedReader(new InputStreamReader(s.getInputStream()));
String backInfo=bufr.readLine();
System.out.println("客户端:反转后为:"+backInfo);//输出反馈信息
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
System.out.println("主机有误");
} catch (IOException e) {
// TODO Auto-generated catch block
System.out.println("流读写异常");
}finally{//关闭资源
if(s!=null&&isw!=null)
try {
s.close();
isw.close();
} catch (IOException e) {
// TODO Auto-generated catch block
System.out.println("客户端关闭失败");
}
}
}
}
/**
* TCP服务端
* @author Administrator
*
*/
class TcpServer implements Runnable{
public void run(){//服务端线程run方法
ServerSocket ss=null;
Socket s=null;
try {
ss=new ServerSocket(11112);//监听的应用程序--端口
s=ss.accept();//从服务端获得该服务端监听的客户端
BufferedReader bufr=//服务端输入流
new BufferedReader(new InputStreamReader(s.getInputStream()));
String getInfo=bufr.readLine();
if(getInfo!=null){//如果获得的客户端数据不为null，则反转该字符串
StringBuilder sb=new StringBuilder(getInfo);
getInfo=sb.reverse().toString();//反转
}
if(getInfo==null)//如果为空
getInfo="什么都没有呀";
PrintWriter pw=new PrintWriter(s.getOutputStream());//服务端输出流
pw.println(getInfo);//换行输出，客户端才能接收数据
pw.flush();//刷新
} catch (IOException e) {
// TODO Auto-generated catch block
System.out.println("服务端错误！");
}finally{//关闭资源
if(ss!=null&&s!=null){
try {
s.close();
ss.close();
} catch (IOException e) {
// TODO Auto-generated catch block
System.out.println("服务端关闭失败");
}
}
}
}
}

复制代码