Java基础——网络编程(三)
2024-10-14 06:06:10
TCP 网络编程
-- tcp 分为客户端和服务端
-- 客户端对应的对象是 Socket
-- 服务端对应的对象是 ServerSocket
-- 如果客户端先启动,则出现 connection refused 异常 //refused 拒绝
客户端创建Socket 对象时,就可以连接服务器,连接成功后,即形成通路,进行数据交换
import java.net.*;
import java.io.*; //TCP客户端
class TClient{
public static void main(String [] args) throws Exception
{
Socket socket=new Socket("127.0.0.1",9000); //取得 Socket 中的输出流
OutputStream out =socket.getOutputStream();
out.write("这是客户端向主机输出的数据".getBytes()); //取得服务端发回的数据
InputStream in=socket.getInputStream();
byte [] buff=new byte[1024];
int len =in.read(buff);
String str=new String(buff,0,len);
System.out.println("服务端返回的数是:"+str); out.close();
in.close();
socket.close();
}
}
//TCP服务端
/*
1 创建ServerSocket ,指定要监听的端口
2 通过 ServerSocket 的 accept 方法 (它是阻塞模式的) 取得连接上来的客户端对象
3 与客户端连通后,就可以得到客户端对象,并使用客户端对象读取流来取得数据
4 如果有必要,释放资源
*/
import java.io.*;
import java.net.*;
class TServer
{
public static void main(String [] args) throws Exception
{
ServerSocket serverSocket=new ServerSocket(9000); //指定监听的端口
Socket clientSocket=serverSocket.accept(); //通过客户端的Socket对象可以取得信息
String clientIp=clientSocket.getInetAddress().getHostAddress();
int clientPort=clientSocket.getPort(); System.out.println(clientIp+":"+clientPort +"连接成功"); InputStream in= clientSocket.getInputStream();
byte[] buff=new byte[1024];
int len=in.read(buff); //len 表示读了多少个字节 注意,这个read 是阻塞的 String msg=new String(buff,0,len); System.out.println(msg); //往回发送数据
OutputStream out=clientSocket.getOutputStream();
out.write("小样的客户端,你竞敢骂人?,我也能".getBytes()); */ out.close();
in.close();
serverSocket.close();
clientSocket.close(); }
}
例子 从客户端向服务端发字母,变成大写后反回
/*
客户端:
1 建立服务
2 获取键盘录入
3 将数入的数据发给服务端
4 接收服务端返回的大写字母
5 关闭资源
备注: 使用带缓冲的字符流进行操作
*/ import java.io.*;
import java.net.*;
class TransClient
{
public static void main(String [] args) throws Exception
{
Socket socket=new Socket("127.0.0.1",8000); //定义输入流,读取键盘数据
BufferedReader br=new BufferedReader(new InputStreamReader(System.in)); //定义输出流对象(用于将键盘数据写入到输出流中)
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); //定义一个socket 读取流,读取服务器返回的大写字母
BufferedReader brResult=new BufferedReader(new InputStreamReader(socket.getInputStream())); String str=null;
while((str=br.readLine())!=null){ //从键盘开始读取
bw.write(str); //向服务端输出
bw.newLine();
bw.flush(); //千万别忘了 System.out.println("服务端返回的数据是"+brResult.readLine()); //取出变大写后的字符串
} socket.close();
br.close();
bw.close();
brResult.close();
}
}
//服务端
import java.net.*;
import java.io.*;
class TransServer
{
public static void main(String [] args) throws Exception
{
ServerSocket serverSocket=new ServerSocket(8000);
Socket clientSocket=serverSocket.accept(); //读取socket流中的数据(从客户端发过来的小写字母)
BufferedReader br=new BufferedReader(new InputStreamReader( clientSocket.getInputStream())); //创建输出流对象,往clientSocket 的流中写入转换后的大写字母
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter( clientSocket.getOutputStream())); String str=null;
while((str=br.readLine())!=null) //注意 readLine 的特性,它是要一直读取回车换行才返回
{
bw.write(str.toUpperCase());
bw.newLine();
bw.flush(); //千万别忘了
} br.close();
bw.close();
clientSocket.close();
serverSocket.close();
} }
例子 上传文件
//客户端
import java.io.*;
import java.net.*;
class UPClient
{
public static void main(String [] args) throws Exception
{
Socket socket=new Socket("127.0.0.1",7000);
BufferedReader br=new BufferedReader(new FileReader("C:\\作业\\名单.txt")); //用来读文件的输入流
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); //用来把文件往服务端传 //往scoket中一行一行的写入数据
String content=null;
while((content=br.readLine())!=null){
bw.write(content);
bw.newLine();
bw.flush();
} socket.shutdownOutput(); //关闭客端的输出流同,当相于加入一个结束标记(-1),要不然服务端会不停的等 //取出服务端返回的信息
BufferedReader brResult=new BufferedReader(new InputStreamReader(socket.getInputStream())) ;
System.out.println( brResult.readLine()); bw.close();
br.close();
socket.close();
}
}
//服务端
import java.io.*;
import java.net.*;
class UPServer
{
public static void main(String [] args) throws Exception
{
ServerSocket serverSocket=new ServerSocket(7000);
Socket clientSocket=serverSocket.accept(); System.out.println(clientSocket.getInetAddress().getHostAddress()+"已经连接..."); //打印一下客户端连上的的信息 //读取客户端发过的来的数据
BufferedReader br=new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
BufferedWriter bw=new BufferedWriter(new FileWriter("e:/xxx.exe")); String str=null;
while((str=br.readLine())!=null){ //如果客户端不发结束标记,它就不会返回
bw.write(str);
bw.newLine();
bw.flush();
} //再向发送端返回一条提示息 BufferedWriter bwResult=new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
bwResult.write("文件上传成功");
bwResult.flush(); serverSocket.close();
clientSocket.close();
bwResult.close();
bw.close();
br.close(); }
例子 上传图片
客户端
import java.net.*;
import java.io.*;
class ImgClient
{
public static void main(String [] ars) throws Exception
{
Socket socket=new Socket("127.0.0.1",7000);
FileInputStream fis=new FileInputStream("C:\\image\\0.jpg"); //文件输入流
OutputStream out=socket.getOutputStream(); byte [] buff =new byte[1024];
int len=0;
while((len=fis.read(buff))!=-1){ //一边读数据,一边传数据
out.write(buff,0,len); //字节流,不用flush, 和 newLine()
} socket.shutdownOutput(); //加一个结束标记,表示输入流结束 //取出服务端发过来的信息
BufferedReader brResult=new BufferedReader(new InputStreamReader(socket.getInputStream()));
System.out.println(brResult.readLine()); socket.close();
fis.close();
}
}
服务端
import java.net.*;
import java.io.*;
class ImgServer
{
public static void main(String [] args) throws Exception
{
ServerSocket serverSocket=new ServerSocket(7000); Socket clientSocket=serverSocket.accept(); System.out.println(clientSocket.getInetAddress().getHostAddress()+" 已连接"); InputStream in=clientSocket.getInputStream(); //取数据用的流
FileOutputStream fos=new FileOutputStream("e:\\xxx.jpg"); byte [] buff=new byte[1024];
int len=0;
while((len=in.read(buff))!=-1){
fos.write(buff,0,len); //不用flush 因为是字节流
} BufferedWriter br=new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
br.write("图片上传成功");
br.flush(); //别忘了 serverSocket.close();
clientSocket.close();
br.close();
fos.close();
}
}
例子 多线程并发上传图片
服务端 import java.net.*;
class PICServer
{
public static void main(String [] args) throws Exception
{
ServerSocket serverSocket=new ServerSocket(9000); while(true)
{
Socket clientSocket=serverSocket.accept();
new Thread(new PICThread(clientSocket)).start();
}
}
}
import java.io.*;
import java.net.*;
class PICThread implements Runnable{
private Socket clientSocket;
public PICThread(Socket socket)
{
clientSocket=socket;
}
public void run()
{
try{ String clientIp=clientSocket.getInetAddress().getHostAddress();
FileOutputStream fos=new FileOutputStream("e:\\"+clientIp);
InputStream in =clientSocket.getInputStream(); //从套接字中取出数据 byte[] buff=new byte[1024];
int len=0;
while((len=in.read(buff))!=-1) //把数据从流中读出,写入文件
{
fos.write(buff,0,len);
} BufferedWriter br=new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
br.write("图片上传成功");
br.flush(); clientSocket.close();
fos.close();
in.close(); }
catch(Exception ex){
System.out.println("出错了");
}
}
}
客户端
import java.io.*;
import java.net.*;
class PICClient{
public static void main(String [] args) throws Exception
{ String fileName=args[0];
//String fileName="c:\\Image\\2.jpg"; //进行验证
File file=new File(fileName);
if(!(file.exists()&&file.isFile())) //验证文件是不是存在
{
System.out.println("输入的文件名错误或是个目录");
return;
} if( !file.getName().endsWith(".jpg")){
System.out.println("文件类型不正确");
return ;
} if( file.length() >1024*1024){
System.out.println("你想干啥,整这么大的文件上来? 不行");
return;
} Socket socket=new Socket("127.0.0.1",9000); FileInputStream fis=new FileInputStream(fileName); //构建文件输入流
OutputStream out=socket.getOutputStream(); //输出流 byte [] buff=new byte[1024];
int len=0;
while((len=fis.read(buff))!=-1) //一边读入,一边往文件中写出
{
out.write(buff,0,len);
} socket.shutdownOutput(); //取出服务端发过来的信息
BufferedReader brResult=new BufferedReader(new InputStreamReader(socket.getInputStream()));
System.out.println(brResult.readLine()); socket.close();
fis.close();
brResult.close();
out.close();
}
}
最新文章
- CSS3-01 简介
- Molecule – 帮助你构建跨平台的 HTML5 游戏
- 高效率http页面优化法则一【JS对DOM的操作】
- Daily Scrum 12.9
- 枚举esum20160530
- objective-C 自定义对象归档的实现
- Python基础知识--列表和集合
- ural 1207 Median on the Plane
- hdu 1029(hash)
- ACPI
- 讨论MMU
- Netty中如何序列化数据
- 产品 vs 服务,见识,耐心
- vue 实践记录
- HTTP1.0和HTTP1.1的区别
- (十六)qt-udp,组播
- Azure系列1.1.2 —— 用于 IntelliJ 的 Azure 工具包的登录说明
- HashMap 和 HashTable差别
- JAVA 根据设置的概率生成随机数
- openssl生成签名与验证签名