关于java类socket的信息

admin 2022-12-31 23:06:10 978

本篇文章给大家谈谈java类socket，以及对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

1、java中的socket是什么意思?
2、java socket有什么作用
3、java中的socket编程是作什么的
4、Java网络编程从入门到精通（18）：Socket类的getter和setter方法（2）
5、Java Socket编程中的一个秘密类

java中的socket是什么意思?

所谓socket通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。\x0d\x0a以J2SDK-1.3为例，Socket和ServerSocket类库位于java.net包中。ServerSocket用于服务器端，Socket是建立网络连接时使用的。在连接成功时，应用程序两端都会产生一个Socket实例，操作这个实例，完成所需的会话。对于一个网络连接来说，套接字是平等的，并没有差别，不因为在服务器端或在客户端而产生不同级别。不管是Socket还是ServerSocket它们的工作都是通过SocketImpl类及其子类完成的。\x0d\x0a重要的Socket API：\x0d\x0ajava.net.Socket继承于java.lang.Object，有八个构造器，其方法并不多，下面介绍使用最频繁的三个方法，其它方法大家可以见JDK-1.3文档。\x0d\x0a. Accept方法用于产生"阻塞"，直到接受到一个连接，并且返回一个客户端的Socket对象实例。"阻塞"是一个术语，它使程序运行暂时"停留"在这个地方，直到一个会话产生，然后程序继续；通常"阻塞"是由循环产生的。\x0d\x0a. getInputStream方法获得网络连接输入，同时返回一个InputStream对象实例。\x0d\x0a. getOutputStream方法连接的另一端将得到输入，同时返回一个OutputStream对象实例。\x0d\x0a注意：其中getInputStream和getOutputStream方法均会产生一个IOException，它必须被捕获，因为它们返回的流对象，通常都会被另一个流对象使用。\x0d\x0a2ServerSocket类例子编辑\x0d\x0a\x0d\x0apackage com.lanber.socket;\x0d\x0aimport java.io.DataInputStream;\x0d\x0aimport java.io.DataOutputStream;\x0d\x0aimport java.io.IOException;\x0d\x0aimport java.net.ServerSocket;\x0d\x0aimport java.net.Socket;\x0d\x0apublic class ServerDemo {\x0d\x0a/**\x0d\x0a* 注意：Socket的发送与接收是需要同步进行的，即客户端发送一条信息，服务器必需先接收这条信息，\x0d\x0a* 而后才可以向客户端发送信息，否则将会有运行时出错。\x0d\x0a* @param args\x0d\x0a*/\x0d\x0apublic static void main(String[] args) {\x0d\x0aServerSocket ss = null;\x0d\x0atry {\x0d\x0ass = new ServerSocket(8888);\x0d\x0a//服务器接收到客户端的数据后，创建与此客户端对话的Socket\x0d\x0aSocket socket = ss.accept();\x0d\x0a//用于向客户端发送数据的输出流\x0d\x0aDataOutputStream dos = new DataOutputStream(socket.getOutputStream());\x0d\x0a//用于接收客户端发来的数据的输入流\x0d\x0aDataInputStream dis = new DataInputStream(socket.getInputStream());\x0d\x0aSystem.out.println("服务器接收到客户端的连接请求：" + dis.readUTF());\x0d\x0a//服务器向客户端发送连接成功确认信息\x0d\x0ados.writeUTF("接受连接请求，连接成功!");\x0d\x0a//不需要继续使用此连接时，关闭连接\x0d\x0asocket.close();\x0d\x0ass.close();\x0d\x0a} catch (IOException e) {\x0d\x0ae.printStackTrace();\x0d\x0a}\x0d\x0a}\x0d\x0a}\x0d\x0a\x0d\x0a3客户端的例子编辑\x0d\x0apackage com.lanber.socket;\x0d\x0aimportjava.io.DataInputStream;\x0d\x0aimport java.io.DataOutputStream;\x0d\x0aimportjava.io.IOException;\x0d\x0aimport java.io.OutputStream;\x0d\x0aimport java.net.Socket;\x0d\x0aimport java.net.UnknownHostException;\x0d\x0apublic class ClientDemo {\x0d\x0a/**\x0d\x0a* @param args\x0d\x0a*/\x0d\x0apublic static void main(String[] args) {\x0d\x0aSocket socket = null;\x0d\x0atry {\x0d\x0asocket = new Socket("localhost",8888);\x0d\x0a//获取输出流，用于客户端向服务器端发送数据\x0d\x0aDataOutputStream dos = new DataOutputStream(socket.getOutputStream());\x0d\x0a//获取输入流，用于接收服务器端发送来的数据\x0d\x0aDataInputStream dis = new DataInputStream(socket.getInputStream());\x0d\x0a//客户端向服务器端发送数据\x0d\x0ados.writeUTF("我是客户端，请求连接!");\x0d\x0a//打印出从服务器端接收到的数据\x0d\x0aSystem.out.println(dis.readUTF());\x0d\x0a//不需要继续使用此连接时，记得关闭哦\x0d\x0asocket.close();\x0d\x0a} catch (UnknownHostException e) {\x0d\x0ae.printStackTrace();\x0d\x0a} catch (IOException e) {\x0d\x0ae.printStackTrace();\x0d\x0a}\x0d\x0a}\x0d\x0a}

java socket有什么作用

socket 用来写网络通讯程序的，简单来说在远程机器，和本地机器各建一个socket，然后进行连接通讯即可。

QQ什么的都网络通讯都是采用socket来写的。

有兴趣的话看看网络编程（非Web网络编程）方面的书

java中的socket编程是作什么的

Socket,又称为套接字，Socket是计算机网络通信的基本的技术之一。如今大多数基于网络的软件，如浏览器，即时通讯工具甚至是P2P下载都是基于Socket实现的。本文会介绍一下基于TCP/IP的Socket编程，并且如何写一个客户端/服务器程序。

方法/步骤

Java中的socket编程下面的部分将通过一些示例讲解一下如何使用socket编写客户端和服务器端的程序。注意：在接下来的示例中，我将使用基于TCP/IP协议的socket编程，因为这个协议远远比UDP/IP使用的要广泛。并且所有的socket相关的类都位于java.net包下，所以在我们进行socket编程时需要引入这个包。

写入数据接下来就是写入请求数据，我们从客户端的socket对象中得到OutputStream对象，然后写入数据后。很类似文件IO的处理代码。

打开服务器端的socket

读取数据通过上面得到的socket对象获取InputStream对象，然后安装文件IO一样读取数据即可。这里我们将内容打印出来。

使用socket实现一个回声服务器，就是服务器会将客户端发送过来的数据传回给客户端。

Java网络编程从入门到精通（18）：Socket类的getter和setter方法（2）

二用于获得和设置Socket选项的getter和setter方法

Socket选择可以指定Socket类发送和接受数据的方式在JDK *** 有个Socket选择可以设置这个选项都定义在 SocketOptions接口中定义如下

public final static int TCP_NODELAY = x ; public final static int SO_REUSEADDR = x ; public final static int SO_LINGER = x ; public final static int SO_TIMEOUT = x ; public final static int SO_SNDBUF = x ; public final static int SO_RCVBUF = x ; public final static int SO_KEEPALIVE = x ; public final static int SO_OOBINLINE = x ;

有趣的是这个选项除了第一个没在SO前缀外其他个选项都以SO作为前缀其实这个SO就是Socket Option的缩写因此在Java中约定所有以SO为前缀的常量都表示Socket选项当然也有例外如TCP_NODELAY 在Socket类中为每一个选项提供了一对get和set方法分别用来获得和设置这些选项

TCP_NODELAY

public boolean getTcpNoDelay() throws SocketExceptionpublic void setTcpNoDelay(boolean on) throws SocketException

在默认情况下客户端向服务器发送数据时会根据数据包的大小决定是否立即发送当数据包中的数据很少时如只有个字节而数据包的头却有几十个字节（IP头+TCP头）时系统会在发送之前先将较小的包合并到软大的包后一起将数据发送出去在发送下一个数据包时系统会等待服务器对前一个数据包的响应当收到服务器的响应后再发送下一个数据包这就是所谓的Nagle算法在默认情况下 Nagle算法是开启的

这种算法虽然可以有效地改善网络传输的效率但对于网络速度比较慢而且对实现性的要求比较高的情况下（如游戏 Telnet等）使用这种方式传输数据会使得客户端有明显的停顿现象因此最好的解决方案就是需要Nagle算法时就使用它不需要时就关闭它而使用setTcpToDelay正好可以满足这个需求当使用setTcpNoDelay（true）将Nagle算法关闭后客户端每发送一次数据无论数据包的大小都会将这些数据发送出去

SO_REUSEADDR

public boolean getReuseAddress() throws SocketException public void setReuseAddress(boolean on) throws SocketException

通过这个选项可以使多个Socket对象绑定在同一个端口上其实这样做并没有多大意义但当使用close方法关闭Socket连接后 Socket对象所绑定的端口并不一定马上释放系统有时在Socket连接关闭才会再确认一下是否有因为延迟面未到达的数据包这完全是在底层处理的也就是说对用户是透明的因此在使用Socket类时完全不会感觉到

这种处理机制对于随机绑定端口的Socket对象没有什么影响但对于绑定在固定端口的Socket对象就可能会抛出 Address already in use JVM_Bind 例外因此使用这个选项可以避免个例外的发生

package mynet;import *;import java io *;public class Test{ public static void main(String[] args) { Socket socket = new Socket(); Socket socket = new Socket(); try { socket setReuseAddress(true); socket bind(new InetSocketAddress( )); System out println( socket getReuseAddress(): + socket getReuseAddress()); socket bind(new InetSocketAddress( )); } catch (Exception e) { System out println( error: + e getMessage()); try { socket setReuseAddress(true); socket bind(new InetSocketAddress( )); System out println( socket getReuseAddress(): + socket getReuseAddress()); System out println( 端口第二次绑定成功! ); } catch (Exception e ) { System out println(e getMessage()); } } }}

上面的代码的运行结果如下

socket getReuseAddress():trueerror:Address already in use: JVM_Bindsocket getReuseAddress():true端口第二次绑定成功!

使用SO_REUSEADDR选项时有两点需要注意

必须在调用bind方法之前使用setReuseAddress方法来打开SO_REUSEADDR选项因此要想使用SO_REUSEADDR选项就不能通过Socket类的构造方法来绑定端口

必须将绑定同一个端口的所有的Socket对象的SO_REUSEADDR选项都打开才能起作用如在例程中 socket 和socket 都使用了setReuseAddress方法打开了各自的SO_REUSEADDR选项

SO_LINGER

public int getSoLinger() throws SocketExceptionpublic void setSoLinger(boolean on int linger) throws SocketException

这个Socket选项可以影响close方法的行为在默认情况下当调用close方法后将立即返回如果这时仍然有未被送出的数据包那么这些数据包将被丢弃如果将linger参数设为一个正整数n时（n的值最大是）在调用close方法后将最多被阻塞n秒在这n秒内系统将尽量将未送出的数据包发送出去如果超过了n秒如果还有未发送的数据包这些数据包将全部被丢弃而close方法会立即返回如果将linger设为和关闭SO_LINGER选项的作用是一样的

如果底层的Socket实现不支持SO_LINGER都会抛出SocketException例外当给linger参数传递负数值时 setSoLinger还会抛出一个IllegalArgumentException例外可以通过getSoLinger方法得到延迟关闭的时间如果返回则表明SO_LINGER是关闭的例如下面的代码将延迟关闭的时间设为分钟

if(socket getSoLinger() == ) socket setSoLinger(true );

SO_TIMEOUT

public int getSoTimeout() throws SocketExceptionpublic void setSoTimeout(int timeout) throws SocketException

这个Socket选项在前面已经讨论过可以通过这个选项来设置读取数据超时当输入流的read方法被阻塞时如果设置timeout（timeout的单位是毫秒）那么系统在等待了timeout毫秒后会抛出一个InterruptedIOException例外在抛出例外后输入流并未关闭你可以继续通过read方法读取数据

如果将timeout设为就意味着read将会无限等待下去直到服务端程序关闭这个Socket 这也是timeout的默认值如下面的语句将读取数据超时设为秒

socket setSoTimeout( * );

当底层的Socket实现不支持SO_TIMEOUT选项时这两个方法将抛出SocketException例外不能将timeout设为负数否则setSoTimeout方法将抛出IllegalArgumentException例外

SO_SNDBUF

public int getSendBufferSize() throws SocketExceptionpublic void setSendBufferSize(int size) throws SocketException

在默认情况下输出流的发送缓冲区是个字节（ K）这个值是Java所建议的输出缓冲区的大小如果这个默认值不能满足要求可以用setSendBufferSize方法来重新设置缓冲区的大小但最好不要将输出缓冲区设得太小否则会导致传输数据过于频繁从而降低网络传输的效率

如果底层的Socket实现不支持SO_SENDBUF选项这两个方法将会抛出SocketException例外必须将size设为正整数否则setSendBufferedSize方法将抛出IllegalArgumentException例外

SO_RCVBUF

public int getReceiveBufferSize() throws SocketExceptionpublic void setReceiveBufferSize(int size) throws SocketException

在默认情况下输入流的接收缓冲区是个字节（ K）这个值是Java所建议的输入缓冲区的大小如果这个默认值不能满足要求可以用setReceiveBufferSize方法来重新设置缓冲区的大小但最好不要将输入缓冲区设得太小否则会导致传输数据过于频繁从而降低网络传输的效率

如果底层的Socket实现不支持SO_RCVBUF选项这两个方法将会抛出SocketException例外必须将size设为正整数否则setReceiveBufferSize方法将抛出IllegalArgumentException例外

SO_KEEPALIVE

public boolean getKeepAlive() throws SocketExceptionpublic void setKeepAlive(boolean on) throws SocketException

如果将这个Socket选项打开客户端Socket每隔段的时间（大约两个小时）就会利用空闲的连接向服务器发送一个数据包这个数据包并没有其它的作用只是为了检测一下服务器是否仍处于活动状态如果服务器未响应这个数据包在大约分钟后客户端Socket再发送一个数据包如果在分钟内服务器还没响应那么客户端Socket将关闭如果将Socket选项关闭客户端Socket在服务器无效的情况下可能会长时间不会关闭 SO_KEEPALIVE选项在默认情况下是关闭的可以使用如下的语句将这个SO_KEEPALIVE选项打开

socket setKeepAlive(true);

SO_OOBINLINE

public boolean getOOBInline() throws SocketException public void setOOBInline(boolean on) throws SocketException

如果这个Socket选项打开可以通过Socket类的sendUrgentData方法向服务器发送一个单字节的数据这个单字节数据并不经过输出缓冲区而是立即发出虽然在客户端并不是使用OutputStream向服务器发送数据但在服务端程序中这个单字节的数据是和其它的普通数据混在一起的因此在服务端程序中并不知道由客户端发过来的数据是由OutputStream还是由sendUrgentData发过来的下面是sendUrgentData方法的声明

public void sendUrgentData(int data) throws IOException

虽然sendUrgentData的参数data是int类型但只有这个int类型的低字节被发送其它的三个字节被忽略下面的代码演示了如何使用SO_OOBINLINE选项来发送单字节数据

package mynet;import *;import java io *;class Server{ public static void main(String[] args) throws Exception { ServerSocket serverSocket = new ServerSocket( ); System out println( 服务器已经启动端口号 ); while (true) { Socket socket = serverSocket accept(); socket setOOBInline(true); InputStream in = socket getInputStream(); InputStreamReader inReader = new InputStreamReader(in); BufferedReader bReader = new BufferedReader(inReader); System out println(bReader readLine()); System out println(bReader readLine()); socket close(); } }}public class Client{ public static void main(String[] args) throws Exception { Socket socket = new Socket( ); socket setOOBInline(true); OutputStream out = socket getOutputStream(); OutputStreamWriter outWriter = new OutputStreamWriter(out); outWriter write( ); // 向服务器发送字符 C outWriter write( hello world\r\n ); socket sendUrgentData( ); // 向服务器发送字符 A socket sendUrgentData( ); // 向服务器发送字符 B outWriter flush(); socket sendUrgentData( ); // 向服务器发送汉字中 socket sendUrgentData( ); socket sendUrgentData( ); // 向服务器发送汉字国 socket sendUrgentData( ); socket close(); }}

由于运行上面的代码需要一个服务器类因此在加了一个类名为Server的服务器类关于服务端套接字的使用方法将会在后面的文章中详细讨论在类Server类中只使用了ServerSocket类的accept方法接收客户端的请求并从客户端传来的数据中读取两行字符串并显示在控制台上

测试

由于本例使用了因Server和Client类必须在同一台机器上运行

运行Server

java mynet Server

运行Client

java mynet Client

在服务端控制台的输出结果

服务器已经启动端口号 ABChello world中国

在ClienT类中使用了sendUrgentData方法向服务器发送了字符 A （）和 B （）但发送 B 时实际发送的是由于sendUrgentData只发送整型数的低字节因此实际发送的是十进制整型的二进制形式如图所示

图十进制整型的二进制形式

从图可以看出虽然分布在了两个字节上但它的低字节仍然是

在Client类中使用flush将缓冲区中的数据发送到服务器我们可以从输出结果发现一个问题在Client类中先后向服务器发送了 C hello world r n A B 而在服务端程序的控制台上显示的却是ABChello world 这种现象说明使用sendUrgentData方法发送数据后系统会立即将这些数据发送出去而使用write发送数据必须要使用flush方法才会真正发送数据

在Client类中向服务器发送中国字符串由于中是由和两个字节组成的而国是由和两个字节组成的因此可分别发送这四个字节来传送中国字符串

lishixinzhi/Article/program/Java/hx/201311/26387

Java Socket编程中的一个秘密类

　一介绍

Java平台在java net包里来实现Socket 在这本文中我们将使用Java net包中的下面三个类来工作

·URLConnection

·Socket

·ServerSocket

在java net包里包含有更多的类但是这些是你最经常遇见的让我们从URLConnection开始这个类提供了在你的java代码里使用Socket的方法而无需了解Socket的底层机制

甚至不用尝试就可以使用sockets

连接到一个URL包括以下几个步骤

·创建一个URLConnection

·用不同的setter方法配置它

·连接到URLConnection

·与不同的getter方法进行交互

下面我们来用一些例子示范怎样使用URLConnection从一台服务器上请求一份文档

URLClient类

我们将从URLClient类的结构开始讲起

import java io *;import java net *;public class URLClient {　protected URLConnection connection;　public static void main(String[] args) {}　public String getDocumentAt(String urlString) {}}

注意必须要先导入java net和java io包才行

我们给我们的类一个实例变量用于保存一个URLConnection

我们的类包含一个main()方法用于处理浏览一个文档的逻辑流（logic flow）我们的类还包含了getDocumentAt()方法用于连接服务器以及请求文档下面我们将探究这些方法的细节

浏览文档

main()方法用于处理浏览一个文档的逻辑流（logic flow）

public static void main(String[] args) {　URLClient client = new URLClient();　String yahoo = client getDocumentAt( // yahoo );　System out println(yahoo);}

我们的main()方法仅仅创建了一个新的URLClient类的实例并使用一个有效的URL String来调用getDocumentAt()方法当调用返回文档我们把它储存在一个String里并把这个String输出到控制台上然而实际的工作是getDocumentAt()方法当中完成的

从服务器上请求一份文档

getDocumentAt()方法处理在实际工作中如何从web上得到一份文档

public String getDocumentAt(String urlString) {　StringBuffer document = new StringBuffer();　try {URL url = new URL(urlString);URLConnection conn = url openConnection();BufferedReader reader = new BufferedReader(new InputStreamReader(conn getInputStream()));String line = null;while ((line = reader readLine()) != null)　document append(line + \n );　reader close();　} catch (MalformedURLException e) {System out println( Unable to connect to URL: + urlString);　} catch (IOException e) {System out println( IOException when connecting to URL: + urlString);　}　return document toString();}

getDocumentAt()方法有一个String类型的参数包含我们想得到的那份文档的URL 我们先创建一个StringBuffer用于保存文档的行接着我们用传进去的参数urlString来创建一个新的URL 然后我们创建一个URLConnection并打开它

URLConnection conn = url openConnection();

一旦有了一个URLConnection 我们就获得它的InputStream并包装成InputStreamReader 然后我们又把它进而包装成BufferedReader以至于我们能够读取从服务器获得的文档的行我们在java代码中处理socket的时候会经常使用这种包装技术在我们继续学习之前你必须熟悉它

BufferedReader reader =new BufferedReader(new InputStreamReader(conn getInputStream()));

有了BufferedReader 我们能够容易的读取文档的内容我们在一个while loop循环里调用reader上的readline()方法

String line = null;while ((line = reader readLine()) != null)document append(line + \n );

调用readLine()方法后从InputStream传入行终止符（例如换行符）时才产生阻塞如果没有得到它将继续等待当连接关闭时它才会返回null 既然这样一旦我们获得一个行我们连同一个换行符把它追加到一个调用的文档的StringBuffer上这样就保留了从服务器上原文档的格式

当我们读取所有行以后我们应该关闭BufferedReader:

reader close();

如果提供给urlString的URL构造器无效则将会抛出一个MalformedUR特拉LException异常同样如果产生了其他的错误例如从连接获取InputStream时将会抛出IOException

二总结

．用一个你想连接的资源的有效的url String来实例化URL

．连接到指定URL

．包装InputStream为连接在BufferedReader以至于你可以读取行

．用你的BufferedReader读取文档内容

lishixinzhi/Article/program/Java/hx/201311/27254

java类socket的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于、java类socket的信息别忘了在本站进行查找喔。

标签：java类socket