下面是服务器和客户端基于TCP协议连接和接收消息的两段程序。由于每段程序都有主函数，不能放在一个java文档中，但是怎么同时运行两个含有包名的java文件呢？？？
package com.itheima;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class TestServer {
/*
* 10、使用TCP协议完成一个客户端一个服务器。
* 客户端从键盘输入读取一个字符串，发送到服务器。
服务器接收客户端发送的字符串，
反转之后发回客户端。客户端接收并打印。
*/
public static void main(String[] args) {
try {
//创建服务端socket，绑定指定端口
ServerSocket ss = new ServerSocket(10000);
System.out.println("服务端开启：");
//侦听并接受到此套接字的连接。阻塞式方法
Socket s = ss.accept();
//获取主机名
String name = s.getInetAddress().getHostName();
//输出主机名和端口号
System.out.println("name="+name+":"+"port="+s.getPort());
while(true){
//获取网络输入流，将InputStream（二进制流）包装为字符流，并调用reverse方法反转字符串
String str = reverse(new BufferedReader(new InputStreamReader(s.getInputStream())));
//获取网络输出流，将OutputStream（二进制流）包装为字符流
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
//反转后的字符串写给客户端
out.write(str);
//写入换行，读取的标记
out.newLine();
//刷新给客户端
out.flush();
//关闭后结束和客户端的通信
//s.close();
}
//ss.colse();
} catch (IOException e) {
e.printStackTrace();
}
}
//将BufferedReader流中的字符串反转后，返回
private static String reverse(BufferedReader in) throws IOException {
StringBuffer sb = new StringBuffer(in.readLine());
return sb.reverse().toString();
}
}
package com.itheima;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class TestClient {
public static void main(String[] args) {
try {
Socket s = new Socket("localhost", 10000);
System.out.println("客户端 开启：");
//获取标准输入流，将（二进制流）包装为字符流
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
//获取网络输出流，将（二进制流）包装为字符流
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
//获取网络输入流，将（二进制流）包装为字符流
BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));
while(true){
//从标准输入流中读取一行，并写给服务端
String str = br.readLine();
out.write(str);
//写入结束标记
out.newLine();
//刷新给服务端
out.flush();
//获得服务端主机名称，并输出
String name = s.getInetAddress().getHostName();
System.out.println(name+":");
//从网络输入流读取服务端写给客户端的反转后的字符串并输出
String string = in.readLine();
System.out.println(string);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
|
|
收藏
淘帖
踩
