`
Luob.
  • 浏览: 1590124 次
  • 来自: 上海
社区版块
存档分类
最新评论

java之 24天 TCP编程 (一)

    博客分类:
  • Java
阅读更多
多客户端同时上传图片
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**图片上传
 * 
 * 客户端
 * 1.服务端点
 * 2.读取客户端已有的图片数据
 * 3.通过socket输出流将数据发送给服务端
 * 4.读取服务端的反馈信息
 * 5.关闭资源
 *
 */

class PicClient{
	public static void main(String[] args)throws IOException{
		if(args.length!=1){
			System.out.println("瞎搞,选择一个文件");
			return;
		}		
		File file=new File(args[0]);
		if(!file.exists() || !file.isFile()){
			System.out.println("无效文件");
			return;
		}
		if(!file.getName().endsWith(".jpg")){
			System.out.println("格式错误!");
			return;
		}
		if(file.length()>1024*1024*5){
			System.out.println("文件过大 ,不安好心!");
			return;
		}
		
		Socket s=new Socket("192.168.1.121",10000);
		FileInputStream fis=new FileInputStream(file);
		
		OutputStream out=s.getOutputStream();
		byte[] buf=new byte[1024];
		int len=0;
		while((len=fis.read(buf))!=-1){
			out.write(buf,0,len);
		}
		//告诉服务端数据已写完
		s.shutdownOutput();
		
		InputStream in=s.getInputStream();
		byte[] bufn=new byte[1024];
		int num=in.read(bufn);
		System.out.print(new String(bufn,0,num));
		fis.close();
		s.close();
	}
	
}

/**
 * 服务端
 * 这个 服务端有个局限性,只能服务一次后
 * 当A客户端连接后,被服务器端获取,服务端执行具体的流程.
 * 这好似B客户端的连接自由等待,
 * 因为服务端还没有处理完A客户端的琴秋,还没循环回来执行下次的accept方法,所以暂时获取不到B客户端对象
 * 
 * 那么为了可以让多个客户端同时发送访问服务端
 * 那么服务端最好就是将每个客户端封装到一个单独的线程中,这样,就可以同时处理多个客户端请求.
 * 
 * 如何定义多线程呢?
 * 只要明确了每一个客户端要在服务端执行的代码即可,将该代码存入run方法中.
 * 
 */
class PicServer{
	
	public static void main(String[] args)throws IOException{
		ServerSocket ss=new ServerSocket(10000);
		
		while(true){
			Socket s=ss.accept();
			new Thread(new PicThread(s)).start();
			
			/*InputStream in=s.getInputStream();
			FileOutputStream fos=new FileOutputStream("c:\\3.jpg");
			
			byte[] buf=new byte[1024];
			int len=0;
			while((len=in.read(buf))!=-1){
				fos.write(buf,0,len);
			}
			
			
			OutputStream out=s.getOutputStream();
			out.write("上传成功".getBytes());
			
			fos.close();
			s.close();*/
		}
		//ss.close();
	}
	
}

class PicThread implements Runnable{
	
	private Socket s;
	PicThread(Socket s){
		this.s=s;
	}
	public void run(){
		String ip=s.getInetAddress().getHostAddress();
		int count=1;
		try{
			File file=new File("c:\\"+ip+"("+count+").jpg");
			
			while(file.exists()){
				file=new File("c:\\"+ip+"("+(count++)+").jpg");
			}
			
			System.out.println(ip+".....connected");
			InputStream in=s.getInputStream();
			FileOutputStream fos=new FileOutputStream(file);
			
			byte[] buf=new byte[1024];
			int len=0;
			while((len=in.read(buf))!=-1){
				fos.write(buf,0,len);
			}
			
			
			OutputStream out=s.getOutputStream();
			out.write("上传成功".getBytes());
			
			fos.close();
			s.close();
		}catch(IOException e){
			throw new RuntimeException(ip+"上传失败");
		}
		
	}
	
}



登陆验证

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

/**
 * 客户打通过键盘录入用户名.
 * 服务端对这个用户名进行校验
 * 
 * 如果用户存在,在服务端显示xxx,已登录
 * 并反馈给客户端 xxx,欢迎观临
 * 
 * 如果用户不存在,在服务端显示xxx.尝试登录.
 * 并在客户端显示.xxx,该用户不存在.
 * 
 * 客户端最多登录三次
user.txt 里面就是
lisi
wanwu
....
 */


class LoginClient{
	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));
		
		PrintWriter out=new PrintWriter(s.getOutputStream(),true);
		
		BufferedReader bufc=new BufferedReader(new InputStreamReader(s.getInputStream()));
		
		for(int x=0;x<3;x++){
			String line=bufr.readLine();
			if(line==null)
				break;
			out.println(line);
			String info=bufc.readLine();
			System.out.println("info:"+info);
			if(info.contains("欢迎"))
				break;
		}
		bufr.close();
		s.close();
	}
}

class LoginServer{
	public static void main(String[] args) throws IOException{
		
		ServerSocket ss=new ServerSocket(10000);
		
		while(true){
			Socket s=ss.accept();
			new Thread(new UserThread(s)).start();
		}
	}
}
class UserThread implements Runnable{
	 Socket s;
	 UserThread(Socket s){
		 this.s=s;
	 }
	 public void run(){
		 String ip=s.getInetAddress().getHostAddress();
		 System.out.println(ip+"....connected");
		 try{
			 for(int x=0;x<3;x++){
				BufferedReader bufr=new BufferedReader(new InputStreamReader(s.getInputStream()));
				
				String name=bufr.readLine();
				if(name==null)
					break;
				
				BufferedReader bufr1=new BufferedReader(new FileReader("E:\\workspace4\\exam\\src\\com\\itheima\\day24\\user.txt"));
				
				PrintWriter out=new PrintWriter(s.getOutputStream(),true);
				
				String line=null;
				boolean flag=false;
				while((line=bufr1.readLine())!=null){
					if(line.equals(name)){
						flag=true;
						break;
					}
				}
				if(flag){
					System.out.println(name+",已登录");
					out.println(name+",欢迎光临");
					break;
				}else{
					System.out.println(name+",尝试登录");
					out.println(name+",用户名不存在");
					
				}
			 }
			 s.close();
		 }catch(IOException e){
			 throw new RuntimeException(ip+"校验失败");
		 }
	 }
}



自定义服务端使用 浏览器进行访问

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


/**
 * 演示客户端 和服务端
 * 1.
 *   客户端 : 浏览器
 *   服务端 : 自定义
 * 
 *在 ie中输入 http://localhost:10000/ 就可以看到下面的输出了
 *或者 在cmd 中 使用 telnet localhost:10000
 *
 *2.
 *  客户端:浏览器
 *  服务器:Tomcat服务器
 *
 *3.
 *  客户端:自定义
 *  服务端:tomcat
 *
 */
public class ServerDemo {

	public static void main(String[] args)throws IOException {
	
		ServerSocket ss=new ServerSocket(10000);
		
		Socket s=ss.accept();
		
		InputStream in=s.getInputStream();
		
		byte[] buf=new byte[1024];
		int len=in.read(buf);
		System.out.println(new String(buf,0,len));  //获取浏览器中 请求的数据
		
		PrintWriter out=new PrintWriter(s.getOutputStream(),true);
		
		out.println("<font color='red' size='7'>客户端你好</font>");
		s.close();
		ss.close();
		
		/* HTTP:协议请求消息头
		 使用 (IE)浏览器访问: http://192.168.1.121:10000  
		 服务端获取的信息:
			GET / HTTP/1.1
			Accept: *
			Accept-Language: zh-CN
			User-Agent: Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.1; WOW64; Trident/4.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; Media Center PC 6.0)
			Accept-Encoding: gzip, deflate
			Host: 192.168.1.121:10000
			Connection: Keep-Alive
		*/
		
		 /* 使用(google)浏览器访问: http://192.168.1.121:10000/myweb/demo.html
		  服务端获取的信息:
		  	GET /myweb/demo.html HTTP/1.1
			Host: 192.168.1.121:10000
			Connection: keep-alive
			Cache-Control: max-age=0
			Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*;q=0.8
			User-Agent: Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.22 (KHTML, like Gecko) Chrome/25.0.1364.97 Safari/537.22
			Accept-Encoding: gzip,deflate,sdch
			Accept-Language: zh-CN,zh;q=0.8
			Accept-Charset: GBK,utf-8;q=0.7,*;q=0.3
			Cookie: bdshare_firstime=1369217069313; Hm_lvt_3bd13360626ecf28813d84d3ee16de60=1369217069,1369280883,1369722035
			空行   消息头结束
			请求的数据体
			
		*/ 
			
	}
	
	

}


自定义客户端 ,访问 tomcat服务器获取数据


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

/**
 * 模拟 IE发送 一个 HTTP 请求 到 tomcat服务器 拿到  一个 html文本
 *
 * 客户端 : 自定义 
 * 服务端 : tomcat服务器
 */
public class MyIE {

	
	public static void main(String[] args) throws IOException{
		Socket s=new Socket("192.168.1.121",8181);
		
		PrintWriter out=new PrintWriter(s.getOutputStream(),true);
		
		out.println("GET /myweb/1.html HTTP/1.1");
		out.println("Accept: */*");
		out.println("Accept-Language: zh-CN");
		out.println("Host: 192.168.1.121:8080");
		//out.println("Connection: Keep-Alive");  请求完后 还保持连接,直到  请求超时
		out.println("Connection: closed");     //请求完后,连接就关闭
		out.println();  //结束头部请求
		
		BufferedReader bufr=new BufferedReader(new InputStreamReader(s.getInputStream()));
		
		String line=null;
		while((line=bufr.readLine())!=null){
			System.out.println(line);
		}
		
		s.close();

		/* tomcat 返回的信息
		HTTP/1.1 200 OK     							// (HTTP协议, Http状态码 200  Ok :描述 
		Server: Apache-Coyote/1.1   					//:服务器版本
		Accept-Ranges: bytes        					//
		ETag: W/"305-1369798061359"
		Last-Modified: Wed, 29 May 2013 03:27:41 GMT	//文本 最后修改时间
		Content-Type: text/html							//文本类型
		Content-Length: 305								//文本长度
		Date: Wed, 29 May 2013 05:52:33 GMT				//时间
		Connection: close								//连接: 关闭

		<html>
			<body>
				<h1>这是我的主页</h1>
				<font size=5 color=red>欢迎光临</font>
				<div>
				斯蒂芬撒分斯蒂芬的收费似懂非懂岁<br/>
				斯蒂芬撒分斯蒂芬的收费似懂非懂岁<br/>
				斯蒂芬撒分斯蒂芬的收费似懂非懂岁<br/>
				斯蒂芬撒分斯蒂芬的收费似懂非懂岁<br/>
										2013/5/29
				</div>
			</body>

		</html>*/
	}

}
0
0
分享到:
评论

相关推荐

    27天java训练*(详细到每一天训练目标和内容)

    **第24-26天:Java网络编程** 学习者会接触Socket编程,理解TCP和UDP协议,以及如何使用Java实现客户端和服务器之间的通信。 **第27天:项目实践与回顾** 最后一天,学习者会将所学知识应用到一个小型项目中,巩固...

    毕向东_Java 25天基础源代码

    《毕向东_Java 25天基础源代码》是一份专为初学者设计的Java编程学习资源,由知名IT教育专家毕向东精心编撰。这个资料包包含了25天的学习计划,每天的学习内容都对应一个具体的Java编程概念或技术,通过源代码的形式...

    21天学通Java-由浅入深

    第一篇 基础篇 第1章 Java简介(精彩视频:33分钟) 21 1.1 Java的平台简介 21 1.2 安装工具包 22 1.2.1 下载JDK 22 1.2.2 安装JDK 24 1.2.3 查看与设置环境变量 25 1.2.4 JDK常用命令 27 1.2.5 Java各个目录含义 28...

    java毕向东源代码16-25天

    这期间,学员将通过每一天的学习和编码实践,掌握从第16天到第25天的Java高级特性,如并发编程、集合框架的深入使用、IO流、网络编程、异常处理、设计模式等关键知识点。 【标签】"java-毕向东" 显示了课程的专业...

    java范例开发大全源代码

    第1篇 Java编程基础  第1章 Java开发环境的搭建(教学视频:9分钟) 2  1.1 理解Java 2  1.2 搭建Java所需环境 3  1.2.1 下载JDK 3  1.2.2 安装JDK 4  1.2.3 配置环境 5  1.2.4 测试JDK配置...

    java范例开发大全

    第1篇 Java编程基础 第1章 Java开发环境的搭建(教学视频:9分钟) 2 1.1 理解Java 2 1.2 搭建Java所需环境 3 1.2.1 下载JDK 3 1.2.2 安装JDK 4 1.2.3 配置环境 5 1.2.4 测试JDK配置是否成功 7 实例1 开发第一个Java...

    Java范例开发大全 (源程序)

    第1篇 Java编程基础  第1章 Java开发环境的搭建(教学视频:9分钟) 2  1.1 理解Java 2  1.2 搭建Java所需环境 3  1.2.1 下载JDK 3  1.2.2 安装JDK 4  1.2.3 配置环境 5  1.2.4 测试JDK配置是否成功 7...

    JAVA面试常见问题大全及解答

    Java面试中,面试官通常会关注候选人的基础知识、编程实践、设计模式以及系统架构的理解。以下是一些常见的Java面试问题及其解答: 1. **Java基本数据类型**:Java有8种基本数据类型,包括整型(byte, short, int, ...

    Java范例开发大全(全书源程序)

    第1篇 Java编程基础 第1章 Java开发环境的搭建(教学视频:9分钟) 2 1.1 理解Java 2 1.2 搭建Java所需环境 3 1.2.1 下载JDK 3 1.2.2 安装JDK 4 1.2.3 配置环境 5 1.2.4 测试JDK配置是否成功 7 实例1 开发...

    java范例开发大全(pdf&源码)

    第1篇 Java编程基础 第1章 Java开发环境的搭建(教学视频:9分钟) 2 1.1 理解Java 2 1.2 搭建Java所需环境 3 1.2.1 下载JDK 3 1.2.2 安装JDK 4 1.2.3 配置环境 5 1.2.4 测试JDK配置是否成功 7 实例1 开发第一个Java...

    最新Java面试大全

    - **判断某日期是否为当月最后一天**:通过Calendar类设置日期并比较。 - **格式化日期**:使用SimpleDateFormat或DateTimeFormatter。 #### 5. 数组和集合 - **数组**:固定长度的数据结构,用于存储同类型的元素...

    2021-2022计算机二级等级考试试题及答案No.14584.docx

    13. **TCP通信客户端**:在Java中,使用Socket类实现TCP通信的客户端程序(正确答案:B)。 14. **线程启动**:调用Thread的start()方法启动线程,系统会在新线程中自动调用run()方法(正确答案:开启一个新线程、...

    2021-2022计算机二级等级考试试题及答案No.2509.docx

    24. Java方法调用:在Java中,方法b()可以在方法b()内部调用方法a(),但不能在方法a()内部直接调用b(),因为方法调用顺序是从上到下。 25. 存储单位:1MB表示1024 * 1024字节,这是存储容量的基本单位转换。 26. ...

    Basic4android库分析器兼智能提示文本汉化工具

    但往往靠编程吃饭的,往往对于奉献之类的没什么热情 ,一个理由,我要靠编程养家,没时间。目前网上这么多软件,难道都是吃编程这碗饭无私编写的吗,不是,80%是些不从事编程工作的人员编写的。对于B4A的发展,B4A...

    2021-2022计算机二级等级考试试题及答案No.9309.docx

    8. 日期计算:在某些编程语言或系统中,storedate()可能会初始化当前日期,m_date减去365天后得到的年份是2001年。 9. 线程生命周期:线程有新建、就绪、运行、阻塞和死亡五种状态。 10. 静态数组初始化:Java中,...

    2021-2022计算机二级等级考试试题及答案No.10742.docx

    23. SQL查询:查找20天之内参加工作的记录,条件应为Between Date() And Date()-20,选项C正确。 24. 循环语句:for循环结束后,i的值为5,因为循环执行5次,选项B正确。 25. 软件系统:没有软件系统的计算机无法...

    2021-2022计算机二级等级考试试题及答案No.2808.docx

    14. **条件表达式**:VB中的IIf函数根据条件返回两个值之一,如果a&gt;5,则x=-1。 15. **硬盘删除操作**:硬盘上删除的文件或文件夹默认会被放入回收站,但可通过设置直接删除。 16. **SQL索引**:CREATE UNIQUE ...

Global site tag (gtag.js) - Google Analytics