java网络编程的目录
第一章 Java网络编程的原因
网络程序的功能
安全性
等等!还有更多!
第二章 基本网络概念
网络
网络的分层
IP、TCP和UDP
Internet
客户/服务器模型
Internet标准
第三章 基本Web概念
URI
HTML、SGML和XML
HTTP
MIME媒体类型
服务器端程序
第四章 流
输出流
输人流
过滤器流
阅读器和书写器
第五章 线程
运行线程
返回线程中的信息
同步
死锁
线程调度
线程池
第六章 查找Internet地址
InetAddress类
Inet4Address和Inet6Address
NetworkInterface类
一些有用的程序
第七章 U R L和U R I
URL类
URLEncoder和URLDecoder类
URI类
代理
通过GET方法与服务器端程序通信
访问受口令保护的网站
第八章 Swing中的HTM L
组件上的HTML
JEditorPane
解析HTML
coOkie一
第九章 客户端Socket
socket基础
用Telnet研究协议
Socket类
Socket异常
Socket地址
示例
第十章 服务器socket
ServerSocket类
一些有用的服务器
第十一章安全Socket
保护通信
创建安全客户端socket
SsLSocket类的方法
创建安全的服务器socket
SSLSerVerSocket类的方法
第十二章 非阻塞I/O。
一个示例客户端
一个示例服务器
缓冲区
通道
就绪选择
第十三章 UDP数据报和Socket
UDP协议
DatagramPacket类
DatagramSocket类
一些有用的应用程序
DatagramChannel
第十四章 组播socket
何为组播socket
使用组播socket
两个简单示例
第十五章 URLConnection
打开URLConnection
读取服务器的数据
读取首部
配置连接
配置客户端的请求HTTP首部
向服务器写入数据
内容处理器
0bject方法
URLConnection的安全考虑
猜测MIME内容类型
HttpURLCOnnectiOn
缓存
JarURLCOnnectiOn
第十六章 协议处理器
何为协议处理器7
URLStreamHandler类
编写协议处理器
更多协议处理器示例和技术
URLStreamHandlerFactory接口
第十七章 内容处理器
何为内容处理器7
ContentHandler类
ContentHandlerFactory接口
FITS格式的内容处理器
第十八 章远程方法调用
何为远程方法调用7
实现
在运行时加载类
java rmi包
jaVarmiregistry包
javarmiserver包
第十九章 JavaMailAPI
何为JavaMail API
发送电子邮件一
接收邮件
口令认证
地址一
URLName类
Message类
Part接口
多部分消息和附件
MIME消息
文件夹
……
153 服务多个客户
JabberServer可以正常工作,但每次只能为一个客户程序提供服务。在典型的服务器中,我们希望同时能处理多个客户的请求。解决这个问题的关键就是多线程处理机制。而对于那些本身不支持多线程的语言,达到这个要求无疑是异常困难的。通过第14章的学习,大家已经知道Java已对多线程的处理进行了尽可能的简化。由于Java的线程处理方式非常直接,所以让服务器控制多名客户并不是件难事。
最基本的方法是在服务器(程序)里创建单个ServerSocket,并调用accept()来等候一个新连接。一旦accept()返回,我们就取得结果获得的Socket,并用它新建一个线程,令其只为那个特定的客户服务。然后再调用accept(),等候下一次新的连接请求。
对于下面这段服务器代码,大家可发现它与JabberServerjava例子非常相似,只是为一个特定的客户提供服务的所有操作都已移入一个独立的线程类中:
//: MultiJabberServerjava
// A server that uses multithreading to handle
// any number of clients
import javaio;
import javanet;
class ServeOneJabber extends Thread {
private Socket socket;
private BufferedReader in;
private PrintWriter out;
public ServeOneJabber(Socket s)
throws IOException {
socket = s;
in =
new BufferedReader(
new InputStreamReader(
socketgetInputStream()));
// Enable auto-flush:
out =
new PrintWriter(
new BufferedWriter(
new OutputStreamWriter(
socketgetOutputStream())), true);
// If any of the above calls throw an
// exception, the caller is responsible for
// closing the socket Otherwise the thread
// will close it
start(); // Calls run()
}
public void run() {
try {
while (true) {
String str = inreadLine();
if (strequals("END")) break;
Systemoutprintln("Echoing: " + str);
outprintln(str);
}
Systemoutprintln("closing");
} catch (IOException e) {
} finally {
try {
socketclose();
} catch(IOException e) {}
}
}
}
public class MultiJabberServer {
static final int PORT = 8080;
public static void main(String[] args)
throws IOException {
ServerSocket s = new ServerSocket(PORT);
Systemoutprintln("Server Started");
try {
while(true) {
// Blocks until a connection occurs:
Socket socket = saccept();
try {
new ServeOneJabber(socket);
} catch(IOException e) {
// If it fails, close the socket,
// otherwise the thread will close it:
socketclose();
}
}
} finally {
sclose();
}
}
} ///:~
每次有新客户请求建立一个连接时,ServeOneJabber线程都会取得由accept()在main()中生成的Socket对象。然后和往常一样,它创建一个BufferedReader,并用Socket自动刷新PrintWriter对象。最后,它调用Thread的特殊方法start(),令其进行线程的初始化,然后调用run()。这里采取的操作与前例是一样的:从套扫字读入某些东西,然后把它原样反馈回去,直到遇到一个特殊的"END"结束标志为止。
同样地,套接字的清除必须进行谨慎的设计。就目前这种情况来说,套接字是在ServeOneJabber外部创建的,所以清除工作可以“共享”。若ServeOneJabber构建器失败,那么只需向调用者“掷”出一个违例即可,然后由调用者负责线程的清除。但假如构建器成功,那么必须由ServeOneJabber对象负责线程的清除,这是在它的run()里进行的。
请注意MultiJabberServer有多么简单。和以前一样,我们创建一个ServerSocket,并调用accept()允许一个新连接的建立。但这一次,accept()的返回值(一个套接字)将传递给用于ServeOneJabber的构建器,由它创建一个新线程,并对那个连接进行控制。连接中断后,线程便可简单地消失。
如果ServerSocket创建失败,则再一次通过main()掷出违例。如果成功,则位于外层的try-finally代码块可以担保正确的清除。位于内层的try-catch块只负责防范ServeOneJabber构建器的失败;若构建器成功,则ServeOneJabber线程会将对应的套接字关掉。
为了证实服务器代码确实能为多名客户提供服务,下面这个程序将创建许多客户(使用线程),并同相同的服务器建立连接。每个线程的“存在时间”都是有限的。一旦到期,就留出空间以便创建一个新线程。允许创建的线程的最大数量是由final int maxthreads决定的。大家会注意到这个值非常关键,因为假如把它设得很大,线程便有可能耗尽资源,并产生不可预知的程序错误。
//: MultiJabberClientjava
// Client that tests the MultiJabberServer
// by starting up multiple clients
import javanet;
import javaio;
class JabberClientThread extends Thread {
private Socket socket;
private BufferedReader in;
private PrintWriter out;
private static int counter = 0;
private int id = counter++;
private static int threadcount = 0;
public static int threadCount() {
return threadcount;
}
public JabberClientThread(InetAddress addr) {
Systemoutprintln("Making client " + id);
threadcount++;
try {
socket =
new Socket(addr, MultiJabberServerPORT);
} catch(IOException e) {
// If the creation of the socket fails,
// nothing needs to be cleaned up
}
try {
in =
new BufferedReader(
new InputStreamReader(
socketgetInputStream()));
// Enable auto-flush:
out =
new PrintWriter(
new BufferedWriter(
new OutputStreamWriter(
socketgetOutputStream())), true);
start();
} catch(IOException e) {
// The socket should be closed on any
// failures other than the socket
// constructor:
try {
socketclose();
} catch(IOException e2) {}
}
// Otherwise the socket will be closed by
// the run() method of the thread
}
public void run() {
try {
for(int i = 0; i < 25; i++) {
outprintln("Client " + id + ": " + i);
String str = inreadLine();
Systemoutprintln(str);
}
outprintln("END");
} catch(IOException e) {
} finally {
// Always close it:
try {
socketclose();
} catch(IOException e) {}
threadcount--; // Ending this thread
}
}
}
public class MultiJabberClient {
static final int MAX_THREADS = 40;
public static void main(String[] args)
throws IOException, InterruptedException {
InetAddress addr =
InetAddressgetByName(null);
while(true) {
if(JabberClientThreadthreadCount()
< MAX_THREADS)
new JabberClientThread(addr);
ThreadcurrentThread()sleep(100);
}
}
} ///:~
JabberClientThread构建器获取一个InetAddress,并用它打开一个套接字。大家可能已看出了这样的一个套路:Socket肯定用于创建某种Reader以及/或者Writer(或者InputStream和/或OutputStream)对象,这是运用Socket的唯一方式(当然,我们可考虑编写一、两个类,令其自动完成这些操作,避免大量重复的代码编写工作)。同样地,start()执行线程的初始化,并调用run()。在这里,消息发送给服务器,而来自服务器的信息则在屏幕上回显出来。然而,线程的“存在时间”是有限的,最终都会结束。注意在套接字创建好以后,但在构建器完成之前,假若构建器失败,套接字会被清除。否则,为套接字调用close()的责任便落到了run()方法的头上。
threadcount跟踪计算目前存在的JabberClientThread对象的数量。它将作为构建器的一部分增值,并在run()退出时减值(run()退出意味着线程中止)。在MultiJabberClientmain()中,大家可以看到线程的数量会得到检查。若数量太多,则多余的暂时不创建。方法随后进入“休眠”状态。这样一来,一旦部分线程最后被中止,多作的那些线程就可以创建了。大家可试验一下逐渐增大MAX_THREADS,看看对于你使用的系统来说,建立多少线程(连接)才会使您的系统资源降低到危险程度。
一、 客户端网络编程步骤
客户端(Client)是指网络编程中首先发起连接的程序,客户端一般实现程序界面和基本逻辑实现,在进行实际的客户端编程时,无论客户端复杂还是简单,以及客户端实现的方式,客户端的编程主要由三个步骤实现:
1、 建立网络连接
客户端网络编程的第一步都是建立网络连接。在建立网络连接时需要指定连接到的服务器的IP地址和端口号,建立完成以后,会形成一条虚拟的连接,后续的操作就可以通过该连接实现数据交换了。
2、 交换数据
连接建立以后,就可以通过这个连接交换数据了。交换数据严格按照请求响应模型进行,由客户端发送一个请求数据到服务器,服务器反馈一个响应数据给客户端,如果客户端不发送请求则服务器端就不响应。
根据逻辑需要,可以多次交换数据,但是还是必须遵循请求响应模型。
3、 关闭网络连接
在数据交换完成以后,关闭网络连接,释放程序占用的端口、内存等系统资源,结束网络编程。
最基本的步骤一般都是这三个步骤,在实际实现时,步骤2会出现重复,在进行代码组织时,由于网络编程是比较耗时的操作,所以一般开启专门的现场进行网络通讯。
二、服务器端网络编程步骤
服务器端(Server)是指在网络编程中被动等待连接的程序,服务器端一般实现程序的核心逻辑以及数据存储等核心功能。服务器端的编程步骤和客户端不同,是由四个步骤实现,依次是:
1、 监听端口
服务器端属于被动等待连接,所以服务器端启动以后,不需要发起连接,而只需要监听本地计算机的某个固定端口即可。
这个端口就是服务器端开放给客户端的端口,服务器端程序运行的本地计算机的IP地址就是服务器端程序的IP地址。
2、 获得连接
当客户端连接到服务器端时,服务器端就可以获得一个连接,这个连接包含客户端的信息,例如客户端IP地址等等,服务器端和客户端也通过该连接进行数据交换。
一般在服务器端编程中,当获得连接时,需要开启专门的线程处理该连接,每个连接都由独立的线程实现。
3、 交换数据
服务器端通过获得的连接进行数据交换。服务器端的数据交换步骤是首先接收客户端发送过来的数据,然后进行逻辑处理,再把处理以后的结果数据发送给客户端。简单来说,就是先接收再发送,这个和客户端的数据交换数序不同。
其实,服务器端获得的连接和客户端连接是一样的,只是数据交换的步骤不同。
当然,服务器端的数据交换也是可以多次进行的。
在数据交换完成以后,关闭和客户端的连接。
4、 关闭连接
当服务器程序关闭时,需要关闭服务器端,通过关闭服务器端使得服务器监听的端口以及占用的内存可以释放出来,实现了连接的关闭。
其实服务器端编程的模型和呼叫中心的实现是类似的,例如移动的客服电话10086就是典型的呼叫中心,当一个用户拨打10086时,转接给一个专门的客服人员,由该客服实现和该用户的问题解决,当另外一个用户拨打10086时,则转接给另一个客服,实现问题解决,依次类推。
在服务器端编程时,10086这个电话号码就类似于服务器端的端口号码,每个用户就相当于一个客户端程序,每个客服人员就相当于服务器端启动的专门和客户端连接的线程,每个线程都是独立进行交互的。
这就是服务器端编程的模型,只是TCP方式是需要建立连接的,对于服务器端的压力比较大,而UDP是不需要建立连接的,对于服务器端的压力比较小罢了。
服务端:
ServerSocket serverSocket = new ServerSocket(2008);while (true) {
Socket socket = serverSocketaccept();
MyThread thread = new MyThread(socket);
threadstart();
}public class MyThread extends Thread {
private Socket socket;
public MyThread(Socket socket) {
thissocket = socket;
}
@Override
public void run() {
superrun();
try {
InputStream is = socketgetInputStream();
BufferedReader bufReader = new BufferedReader(new InputStreamReader(is));
String line = "";
String s = "";
while ((s = bufReaderreadLine()) != null) {
line = line + s;
}
Systemoutprintln("接收到:" + line);
} catch (IOException e) {
eprintStackTrace();
}
}
}
客户端:
public static void main(String[] args) throws UnknownHostException, IOException {Socket socket=new Socket("1921680101", 2008);
OutputStream out=socketgetOutputStream();
PrintWriter pw=new PrintWriter(new OutputStreamWriter(out));
pwprint("12345上山打老虎");
pwflush();
pwclose();
outclose();
}
s
=
new
Socket("127001",
8880)
前面那个IP是服务器的地址,只要这个IP写正确了,服务器放在哪里,客户端都能连上去的。
1270。01最简单的解释就是本机地址,你用这个IP,访问的就是你自己。
你可以去服务器上查看一下网络地址,然后把1270。01换成服务器的IP。
JavaAPl5个技巧娱乐一下
1,不要自己去实现安全框架
几平每个人都知道避免去实现加密等算法。同样道理你的应用的安全栈的其余部分也是一样,可能需要花费很大,得到的风险也很大。你很可能会犯一些错误。自1999年以来,已经有89373个CVE(公共漏洞和暴露)发布了。而其中公开的大部分的发现者都是那些非常聪明的人。
你可能认为处理一个简单的用例(例如验证用户的密码)是很简单的事情一一你所做的一切只是比较一对字符串。这样想就错了。你需要验证密码的哈希值,审核尝试登录的次数,减少针对字典的攻击,这只是冰山一角。你最好的选择是使用现有的成熟的库或框架,例如Apache的Shiro或者SpringSecurity,让这些框架去处理各类复杂的安全问题。
2Use TLS,Always! 永远使用TLS!
能让你的应用需要TLS(HTTPS/SSL)只需要简单的一行代码,所有人都应该这样做!如果使用Apache Shiro框架,只需要设置属性:[urls]/ = ssl
如果使用Spring Security,,只需要在设置HttpSecurity时,简单调用一个方法即可。httprequiresChannel()anyRequest()requiresSecure();
在Spring Boot中,仅需设置一些属性,如下:serverport=8443serversslkey-store=classpath:keystorejksserversslkey-store-password=secretserversslkey-password=another-secret
3使用Spring Boot创建Web Service
Spring Boot是Spring平台的一个简化,能让编写Spring应用变得很简单,例如能用很少的代码,编写《app应用中考虑的12个因素》一文中提到的观点。如果你还在使用建War包的方式编码,那么Spring Boot值得你去学习。使用Spring Boot可以复杂的、不同类型的应用,例如可以使用简单的注解(@EnableResourceServer;就搭建一个OAuth资源服务器,或者通过简单的属性改变其端口:
serverport = 8090
如果不喜欢使用SpringBoot,那么可以使用Dropwizard去搭建JAX-RS技术栈。
4监视应用和性能指标
如果无任何数据的情况下是很难发现程序的错误的。Spring Boot通过使用Actuator,能让收集指标数据变得容易,只需要在应用中增加一个依赖,如下:
<dependency><groupld>orgspringframeworkboot</groupld><artifactld>spring-boot-tarter-actuator</artifactld></dependency>
然后就可以通过浏览器中,在访问应用地址后输入/health 或者/metrics去检查应用的健康情况或者指标。Dropwizard框架通过/healthcheck和/metrics实现同样的功能。
5保护敏感信息
人们都认为API密钥是不安全的,这是事实。密钥通过电子邮件发送或源代码管理系统控制。也许这是它们看起来比密码更不安全的原因,但它们也一样敏感。如果需要将API密钥存储在文件中,请确保授予文件有限的访问权限。例如,我们建议在私人目录中存放Okta的YAML文件并且赋予文件所有者只读权限。
$ chmod u=r,go-rwx ~/okta/oktayaml
如果你正为使用你的APP的用户创建API,记得提醒他们,如果无设置好权限的话,SSH的忽文件是放在你的~/ssh目录下,如果无设置好权限的话。GitHub 把它们放在“危险区域”,以提醒用户,这是十分有用的。
1不知道你是不是因为没有学过Spring框架的使用,你可以去学习了解下Spring和SpirngMVC框架的使用。
2第二个、第三个问题我暂时不知道怎么讲,抱歉哈,嘿嘿
客户端:Socket
服务器端:ServerSocket
给你个网址,这里的介绍比较详细
http://baikebaiducom/view/1589439htmlwtp=tt
0条评论