java之 23天 TCP 网络编程 (二)

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

/**
* TCP传输
* Socket 和ServerSocket
* 建立客户端和服务器端
* 建立连接后,通过Socket中的IO流进行数据的传递
* 关闭Socket
* 同样,客户端与服务器端是两个独立的应用程序.
*
* 客户端:
*   通过查阅socke对象,发现在该对象建立的时候,就可以去连接指定的主机.
*   因为tcp是面向连接的,所以在建立socket的服务时,就要有服务端存在,并连接成功.形成通路后,在该通道进行数据的传输.
*
*   步骤
*   1.创建Socket服务,并指定要连接的主机和端口,必须要启动服务器端监听
*   2.然后创建 客户端,然后开始交流
*
* 需求:给服务端发送一个文本数据
*
*/

class TcpClient{
public static void main(String[] args) throws IOException{
Socket s=new Socket("192.168.1.121",10000);

OutputStream out=s.getOutputStream();
out.write("tcp 哥们来了".getBytes());

s.close();

}
}

/**
* 需求:定义端点接受数据并打印在控制台上
* 服务端:
*  1.建立服务器端的socket服务, ServerSocket()
*    并监听一个端口.
*  2. 获取连接过来的客户端对象.
*    通过ServerScoket的accept方法,所以这个方法是阻塞式的
*  3.客户端如果发来数据,那么服务端要使用对应的客户对象,并获取到该客户端对象的读取流读取发过来的数据
*    并打印在控制台.
*  4.关闭服务器  (可选)
*
*
*/
class TcpServer{

public static void main(String[] args) throws IOException{
//建立服务端socket服务,并监听一个端口
ServerSocket ss=new ServerSocket(10000);

Socket s=ss.accept();

String ip=s.getInetAddress().getHostAddress();
System.out.println(ip+"....connected");

//获取客户端发送过来的额数据,那么要使用客户端对象的读取流来读取数据
InputStream in=s.getInputStream();

byte[] buf=new byte[1024];
int len=in.read(buf);

System.out.println(new String(buf,0,len));//关闭客户端
s.close();
ss.close();
}

}

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

/**
* 演示 tcp的传输的客户端和服务端的互访
*
* 需求:客户端给服务端发送数据,服务端接手后,给客户端反馈系信息
*
*  客户端:
*  1.建立Socket服务,指定要连接主机和端口
*  2.获取socket流中的输出流,将数据写到该流中,通过网络发送给服务端
*  3.获取socket流中的输入流,将服务端反馈的数据获取到,并打印
*  4.关闭资源
*/

class TcpClient2{
public static void main(String[] args) throws IOException{
Socket s=new Socket("192.168.1.121",10000);

OutputStream out=s.getOutputStream();
out.write("服务端,你好吗?".getBytes());

InputStream in=s.getInputStream();

byte[] buf=new byte[1024];
int len=in.read(buf);
System.out.println(new String(buf,0,len));
s.close();
}
}

class TcpServer2{
public static void main(String[] args) throws IOException{
ServerSocket ss=new ServerSocket(10000);
Socket s=ss.accept();

String ip=s.getInetAddress().getHostAddress();
System.out.println(ip+".....connected");
InputStream in=s.getInputStream();

byte[] buf=new byte[1024];
int len=in.read(buf);
System.out.println(new String(buf,0,len));

OutputStream out=s.getOutputStream();
out.write("我很好,thankyou!".getBytes());

s.close();

ss.close();

}

}

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/**
*
* 需求:建立一个文本转换服务器
* 客户端给服务端发送一个,服务端会将文本转成大写再返回给客户端.
* 而且客户端可以不端的进行文本转换.当客户端输入over时,转换结束.
*
*
* 分析
* 客户端:
*   既然是操作设备上的数据,就可以使用io技术,并按照io的操作规律来思考
*   源:键盘录入
*   目的:网络设备,网络输出流.
*   可以操作的是文本数据,可以选择字符流
*
* 步骤:
* 1.建立服务
* 2.获取键盘录入
* 3.将数据发送给服务端
* 4.获取服务端的的反馈数据
* 5.结束,关资源
* 都是文本数据,可以使用字符流进行操作,同时提高效率,加入缓冲.
*
*
* 该例子出现的问题:
* 现象:客户端和服务端都在莫名的等待.
* 为什么呢?
* 因为客户端和服务端都有阻塞式方式,这些方法么有读取到结束标记,
* 那么就一直等.而导致两端都在等待.
*
*/

class TransClient{

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

Socket s=new Socket("192.168.1.121",10000);
BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));

//BufferedWriter bufw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
//优化
PrintWriter out=new PrintWriter(s.getOutputStream(),true);

BufferedReader bufrs=new BufferedReader(new InputStreamReader(s.getInputStream()));

String line=null;
while((line=bufr.readLine())!=null){
if("over".equals(line))
break;
out.println(line);
/*
bufw.write(line);
bufw.newLine(); //缓冲区的 读取结束标记
bufw.flush();*/

String str=bufrs.readLine();
System.out.println("Server:"+str);
}
bufr.close();
s.close();
}
}

class TransServer{
public static void main(String[] args) throws IOException{
ServerSocket ss=new ServerSocket(10000);

Socket s=ss.accept();
String ip=s.getInetAddress().getHostAddress();
System.out.println(ip+"....connected");
//读取socket流中的数据
BufferedReader bufr=new BufferedReader(new InputStreamReader(s.getInputStream()));

//目的Socket输入流,将大写的写入到socket输出流,并发给客户端
//BufferedWriter bufw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));

//优化
PrintWriter out=new PrintWriter(s.getOutputStream(),true);

String line=null;
while((line=bufr.readLine())!=null){
System.out.println(line);

out.println(line.toUpperCase());
/*
bufw.write(line.toUpperCase());
bufw.newLine(); //缓冲区的 读取结束标记
bufw.flush();*/
}
s.close();
ss.close();
}

}