请参阅以下资料:
socket非常类似于电话插座。以一个国家级电话网为例。电话的通话双方相当于相互通信的2个进程,区号是它的网络地址;区内一个单位的交换机相当于一台主机,主机分配给每个用户的局内号码相当于socket号。任何用户在通话之前,首先要占有一部电话机,相当于申请一个socket;同时要知道对方的号码,相当于对方有一个固定的socket。然后向对方拨号呼叫,相当于发出连接请求(假如对方不在同一区内,还要拨对方区号,相当于给出网络地址)。对方假如在场并空闲(相当于通信的另一主机开机且可以接受连接请求),拿起电话话筒,双方就可以正式通话,相当于连接成功。双方通话的过程,是一方向电话机发出信号和对方从电话机接收信号的过程,相当于向socket发送数据和从socket接收数据。通话结束后,一方挂起电话机相当于关闭socket,撤消连接。
在电话系统中,一般用户只能感受到本地电话机和对方电话号码的存在,建立通话的过程,话音传输的过程以及整个电话系统的技术细节对他都是透明的,这也与socket机制非常相似。socket利用网间网通信设施实现进程通信,但它对通信设施的细节毫不关心,只要通信设施能提供足够的通信能力,它就满足了。
至此,我们对socket进行了直观的描述。抽象出来,socket实质上提供了进程通信的端点。进程通信之前,双方首先必须各自创建一个端点,否则是没有办法建立联系并相互通信的。正如打电话之前,双方必须各自拥有一台电话机一样。在网间网内部,每一个socket用一个半相关描述:
(协议,本地地址,本地端口)
一个完整的socket有一个本地唯一的socket号,由 *** 作系统分配。
最重要的是,socket 是面向客户/服务器模型而设计的,针对客户和服务器程序提供不同的socket 系统调用。客户随机申请一个socket (相当于一个想打电话的人可以在任何一台入网电话上拨号呼叫),系统为之分配一个socket号;服务器拥有全局公认的 socket ,任何客户都可以向它发出连接请求和信息请求(相当于一个被呼叫的电话拥有一个呼叫方知道的电话号码)。
socket利用客户/服务器模式巧妙地解决了进程之间建立通信连接的问题。服务器socket 半相关为全局所公认非常重要。读者不妨考虑一下,两个完全随机的用户进程之间如何建立通信?假如通信双方没有任何一方的socket 固定,就好比打电话的双方彼此不知道对方的电话号码,要通话是不可能的。什么是socket?
你经常听到人们谈论着“socket”,或许你还不知道它的确切含义。现在让我告诉你:它是使用标准Unix文件描述符(filedescriptor)和其它程序通讯的方式。什么?你也许听到一些Unix高手(hacker)这样说过:“呀,Unix中的一切就是文件!”那个家伙也许正在说到一个事实:Unix程序在执行任何形式的I/O的时候,程序是在读或者写一个文件描述符。一个文件描述符只是一个和打开的文件相关联的整数。但是(注意后面的话),这个文件可能是一个网络连接,FIFO,管道,终端,磁盘上的文件或者什么其它的东西。Unix中所有的东西就是文件!所以,你想和Internet上别的程序通讯的时候,你将要使用到文件描述符。你必须理解刚才的话。现在你脑海中或许冒出这样的念头:“那么我从哪里得到网络通讯的文件描述符呢?”,这个问题无论如何我都要回答:你利用系统调用socket(),它返回套接字描述符(socketdescriptor),然后你再通过它来进行send()和recv()调用。“但是”,你可能有很大的疑惑,“如果它是个文件描述符,那么为什么不用一般调用read()和write()来进行套接字通讯?”简单的答案是:“你可以使用!”。详细的答案是:“你可以,但是使用send()和recv()让你更好的控制数据传输。”存在这样一个情况:在我们的世界上,有很多种套接字。有DARPAInternet地址(Internet套接字),本地节点的路径名(Unix套接字),CCITTX25地址(你可以将X25套接字完全忽略)。//ServerSocket
import javaio;
import javanet;
public class TcpServer {
public static void main(String[] args) throws Exception{
ServerSocket server = new ServerSocket(10003);
Socket client = serveraccept();
InputStream is = clientgetInputStream();
OutputStream os = clientgetOutputStream();
byte[] by = new byte[1024];
int len = 0;
String msg = null;
while((len=isread(by))!=-1){
msg = new String(by,0,len);
Systemoutprintln("来自"+clientgetInetAddress()getHostAddress()+"客户端的消息:"+msg);
if("886"equals(msg))
break;
oswrite(getPrint(msg));
}
clientclose();
}
private static byte[] getPrint(String msg){
return msggetBytes();
}
}//Socket
import javaio;
import javanet;
public class TcpClient {
public static void main(String[] args) throws Exception{
Socket sk = new Socket("localhost",10003);
OutputStream os = skgetOutputStream();
InputStream is = skgetInputStream();
oswrite(getPrint());
byte[] by = new byte[1024];
int len = 0;
while((len=isread(by))!=-1){
Systemoutprintln("来自"+skgetInetAddress()getHostAddress()+"服务器的消息:"+new String(by,0,len));
oswrite(getPrint());
}
skclose();
}
private static byte[] getPrint()throws Exception{
BufferedReader in = new BufferedReader(new InputStreamReader(Systemin));
String msg = inreadLine();
return msggetBytes();
}
}
//一下是输出结果:
来自127001客户端的消息:Hello
来自127001客户端的消息:eee
来自127001客户端的消息:886
//客户端:
Hello
来自127001服务器的消息:Hello
eee
来自127001服务器的消息:eee
886
提示:如果提问者想使用DataInputStream可以自行替换掉即可。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)