开发者社区> 技术小美> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

[零基础学JAVA]Java SE应用部分-32.Java网络编程

简介:
+关注继续查看
C/S程序:表示的客户/服务器程序,每次需要编写两套程序 
|- MSN、QQ:一般会有两套程序,一个是服务器端,另外一个是客户端 
B/S程序:表示的浏览器/ 服务器,可以理解为动态WEB,论坛
本季目标
image
Sock:TCP通讯 
数据报:UDP通讯
Socket程序需要的类: 
1、所有的用户对于服务器来讲都是一个Socket客户端。 
2、在服务器上使用ServerSocket类接收客户端的Socket
Socket通信模型
image
Socket编程的四个基本步骤
image
编写一个服务器程序:ServerSocket
image
只要是网络连接都要求有一个端口 
public ServerSocket(int port) 
public Socket accept() throws IOException
通过此方法等待客户端的socket进行访问。
ServerSocket01服务器端代码:
image
此服务器端的功能非常的简单,就是接收客户端的请求,之后在屏幕上输出哈~
image
Windows中有一个telnet命令,通过此命令就可以直接连接到服务器了。
image
客户端收到http://redking.blog.51cto.com字符串,同时服务器端显示“客户端回应完毕~~~”
image
只要是符合网络的协议标准,所有的客户端都可以连接到此服务器端上。 
但是一般情况下,很少说直接去使用telnet连接,往往会编写一个客户端。 
Socket 
public Socket(String host,int port) throws UnknownHostException,IOException 
指定一个主机的IP地址和一个端口
ClientSocket01客户端代码:
image
验证下效果,和telnet一样哈~
image
以上代码验证了,程序需要编写两套程序: 
· 一个是服务器端 
· 另外一个是客户端
现在发现所有的代码只是执行一次就完了,那么能不能说执行多次呢?由我的用户可以自己发出中断的指令。 
这样的做法我们可以做一个Socket经典 —— Echo程序 
用户发什么内容,服务器就会回应什么内容:
EchoServer代码:
import java.io.*;    
import java.net.*;    
public class EchoServer{    
        //此处为了省去处理try...catch直接抛出了异常    
        public static void main(String args[]) throws Exception{    
                ServerSocket server = null;    
                //输出肯定使用打印流    
                PrintStream out = null;    
                //服务器肯定也要接收输入    
                BufferedReader buf = null;    
                //1.实例化一个服务器的监听端    
                server = new ServerSocket(9999);    
                //可以使用一种死循环的方式接收内容    
                Socket client = null;    
                while (true){    
                        //不断接收内容    
                        client = server.accept();    
                        //准备好向客户端输出内容    
                        out = new PrintStream(client.getOutputStream());    
                        //而且客户端要有输入给服务器端    
                        buf = new BufferedReader(new InputStreamReader(client.getInputStream()));    
                        //下面先给出一个完整的信息提示    
                        out.println("您好!欢迎光临:http://redking.blog.51cto.com");    
                        out.println("输入bye表示退出哈~");    
                        //一个用户要发很多的信息    
                        while (true){    
                                //接收客户端发送而来的内容    
                                String str = buf.readLine();    
                                if (str==null){    
                                        //如果str为空就表示退出    
                                        break;    
                                }else{    
                                        //如果输入的是bye则表示系统退出    
                                        if ("bye".equals(str)){    
                                                break;    
                                        }    
                                        //可以对用户发来的信息进行回应    
                                        out.println("ECHO:"+str);    
                                }    
                        }    
                        //进行收尾工作    
                        out.close();    
                        buf.close();    
                        client.close();    
                        //如果要关闭服务器时可以设置标志    
                        //server.close();    
                }    
        }    
}
看下效果:
image
现在我们用telnet连接上去看下效果
image
输入bye退出连接
image
同时可以多次连接
image
典型的包含了输入和输出
EchoClient代码:
import java.io.*;    
import java.net.*;    
public class EchoClient{    
        public static void main(String args[]) throws Exception{    
                Socket client = null;    
                BufferedReader buf = null;    
                PrintStream out = null;    
                //1.连接服务器    
                client = new Socket("localhost",9999);    
                //接收服务器端的输入信息    
                buf = new BufferedReader(new InputStreamReader(client.getInputStream()));    
                System.out.println(buf.readLine());    
                System.out.println(buf.readLine());    
                //之后准备从键盘接收数据    
                BufferedReader in = new BufferedReader(new InputStreamReader(System.in));    
                String userInput = null;    
                out = new PrintStream(client.getOutputStream());    
                while ((userInput=in.readLine())!=null){    
                        //表示有内容进来,要把内容发送到客户端    
                        out.println(userInput);    
                        //接收服务器端的回应    
                        System.out.println(buf.readLine());    
                }    
                out.close();    
                in.close();    
                client.close();    
        }    
}
image
但是此程序有一个问题,即:当一个用户操作的时候,其他用户是不能操作的 
程序是单线程的,所以每次只能一个用户访问。 
此处如果想解决,则只能使用多线程进行操作。 
首先需要编写一个线程的类:
ThreadServer代码:
import java.io.*;    
import java.net.*;    
public class ThreadServer implements Runnable{    
        //现在所有的Socket都要归入到一个线程之中    
        private Socket client = null;    
        public ThreadServer(Socket client){    
                this.client = client;    
        }    
        public void run(){    
                //要不断的接收客户发送来的信息    
                String input = null;    
                //通过BufferedReader进行接收    
                BufferedReader buf = null;    
                //有一个输出的对象    
                PrintStream out = null;    
                try{    
                        buf = new BufferedReader(new InputStreamReader(this.client.getInputStream()));    
                        while(true){    
                                //接收发送过来的信息    
                                input = buf.readLine();    
                                out = new PrintStream(this.client.getOutputStream());    
                                if ("bye".equals(input)){    
                                        break;    
                                }else{    
                                        out.println("ECHO:"+input);    
                                }    
                        }    
                        this.client.close();    
                }catch (Exception e){}    
        }    
}
EchoServer01服务器端代码: 
import java.io.*;    
import java.net.*;    
public class EchoServer01{    
        //此处为了省去处理try...catch直接抛出了异常    
        public static void main(String args[]) throws Exception{    
                ServerSocket server = null;    
                //输出肯定使用打印流    
                PrintStream out = null;    
                //服务器肯定也要接收输入    
                BufferedReader buf = null;    
                //1.实例化一个服务器的监听端    
                server = new ServerSocket(9999);    
                //可以使用一种死循环的方式接收内容    
                Socket client = null;    
                while (true){    
                        //不断接收内容    
                        client = server.accept();    
                        //在此处启动了一个线程    
                        new Thread(new ThreadServer(client)).start();    
                }    
        }    
}
使用telnet测试效果哈~
image 
通过以上代码,可以发现,多线程实际上在服务器上是比较常用的。 
服务器 = 多线程 + IO + Socket 
Socket程序实际上是属于TCP程序,是一个稳定的连接
 
UDP程序:数据报程序
image
Send发送端代码:
import java.io.*;    
import java.net.*;    
public class Send{    
        public static void main(String args[]) throws Exception{    
                DatagramSocket ds = null;    
                DatagramPacket dp = null;    
                //发送端必须有一个监视的端口    
                ds = new DatagramSocket(9999);    
                String str = "http://redking.blog.51cto.com";    
                //发送的内容只能是byte数组    
                //接收端端口号是8888    
                dp = new DatagramPacket(str.getBytes(),str.length(),InetAddress.getByName("localhost"),8888);    
                ds.send(dp);    
                ds.close();    
        }    
}
看下效果:
image
信息已经发送出去了哈~
下面我们再写个接收代码
image
Receive接收端代码:
import java.io.*;    
import java.net.*;    
public class Receive{    
        public static void main(String args[]) throws Exception{    
                DatagramSocket ds = null;    
                DatagramPacket dp = null;    
                //要有一个空间大小    
                byte b[] = new byte[1024];    
                //ds的监听端口就表示发送端指定好的    
                ds = new DatagramSocket(8888);    
                dp = new DatagramPacket(b,b.length);    
                //开始接收    
                ds.receive(dp);    
                System.out.println(new String(dp.getData()).trim());    
                ds.close();    
        }    
}
现在我们测试一下哈~首先必须接收端开启着
image
然后我们运行发送端发送信息
image
总结 
网络编程在实际中确实使用越来越少,JAVA的主要特点全部集中在了JAVA WEB上了。 
只需要了解以下概念即可: 
· 网络程序的分类:TCP、UDP 
· 服务器 = IO + Socket + Thread
###################################################






本文转自redking51CTO博客,原文链接:http://blog.51cto.com/redking/135374,如需转载请自行联系原作者

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
【Java】网络编程,JUnit单元测试,设计模式(二)
【Java】网络编程,JUnit单元测试,设计模式
0 0
【Java】网络编程,JUnit单元测试,设计模式(一)
【Java】网络编程,JUnit单元测试,设计模式
0 0
Java 基础入门 | 第十六章 Java网络编程
目录网络相关概念网络协议网络编程TCP编程UDP编程URL编程网络相关概念什么是计算机网络局域网 城域网 广域网把分布在不同地理区域的计算机与专门的外部设备用通信线路互连成一个规模大、功能强的网络系统,从而使
0 0
Java多线程+IO流+网络编程+MySQL+JDBC编程实现多人联机版坦克大战
该项目为博主与几位伙伴的共同成果,历时1个月,由最初知识尚未掌握,到最后开发出完整项目,一途走过不少弯路,但也对个人的编程能力及对java知识的掌握更进一步,游戏逻辑主要参考【马士兵网络版坦克大战】
0 0
Java网络编程:UDP/TCP实现实时聊天、上传图片、下载资源等
ip地址的分类: 1、ipv4、ipv6 127.0.0.1:4个字节组成,0-255,42亿;30亿都在北美,亚洲就只有4亿 2011年就用尽了。
0 0
Java基础进阶网络编程-URL
Java基础进阶网络编程-URL
0 0
Java基础进阶网络编程-TCP和UDP协议
Java基础进阶网络编程-TCP和UDP协议
0 0
Java基础进阶网络编程概述
Java基础进阶网络编程概述
0 0
Java网络编程net-1-地址-2
Java网络编程net-1-地址-2
0 0
+关注
文章
问答
文章排行榜
最热
最新
相关电子书
更多
JAVA 应用排查全景图
立即下载
Java工程师必读手册
立即下载
Java应用提速(速度与激情)
立即下载