Java socket开发实例入门

damies

浏览: 238447 次
性别:
来自: 北京

最近访客更多访客>>

tpcrack

.zzzzzz

shenkerer

tingxuelouwq

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

JAVA技术

Socket Java 网络协议编程 .net

socket用中文意思就是我们常说的”套接字“，我们用它来解决基于TCP/IP协议的网络通信。Java有一套功能强大而又易于使用的网络开发API，这个API是一系列的接口和类，在java.net和javax.net包中可以找到它们。套接字一般分为两种：流套接字（Stream Socket)和数据报套接字（Datagram Sockets）。关于套接字的编程可以写成一本书，本文不想在这里做深入探究（其实是本人功力还不够，嘿嘿...）,这次主要是了解一下流套接字的基本开发。

一、几个重要的API：
1、InetAddress类
描述：该类在套接字编程中份演着目的地角色，通常作为参数传递给流套接字类和数据报套接字的构造方法或其它方法。

构造方法：该类只有一个默认的不带参的构造方法。
不能直接用new创建一个InetAddress对象。象这样做
InetAddress ia = new InetAddress ();
就是错误的。但是我们可以通过它的5个静态工厂方法获得一个InetAddress对象或对象数组。

重要方法：
static InetAddress[] getAllByName(String host);
通过传递参数host(主机名)，返回一个InetAddress对象数组的引用。如果指定的主机没有IP地址存在，则方法抛出一个UnknownHostException 异常对象。

static InetAddress getByAddress(byte[] addr);
通过传递一个用字节数组表示的二进制IP地址参数（4字节对应Ipv4,16字节对应Ipv6），返回一个InetAddress对象的引用。如果返回对象的数组既不是4字节也不是16字节，则方法抛出一个UnknownHostException 异常对象。

static InetAddress getByAddress(String host, byte[] addr);
创建一个基于给定主机名和给定字节数组组成的IP地址的InetAddress对象。如果返回对象中的数组既不是4字节也不是16字节，则方法抛出一个UnknownHostException 异常对象。

static InetAddress getByName(String host);
返回一个与给定主机名的InetAddress对象。如果指定的主机没有IP对应，则方法抛出一个UnknownHostException异常对象。

    static InetAddress getLocalHost();
    返回一个包含本地主机的IP地址的InetAddress对象。

    上面讲到的方法均提到返回一个或多个InetAddress对象的引用，实际上每一个方法都要返回一个或多个Inet4Address/Inet6Address对象的引用。一旦获得了InetAddress对象，你就可以使用其他非静态方法得到你想要的东东了。

2、Socket类
描述：Socket是建立网络连接时使用的。在连接成功时，服务端和客户端都会产生一个Socket实例，操作这个实例，完成所需的会话。对于一个网络连接来说，套接字是平等的，并没有差别，不因为在服务器端或在客户端而产生不同级别。

构造方法：该类有多个构造方法，常用的有两个：Socket(InetAddress addr, int port) 和 Socket(String host, int port)
两个构造方法都创建了一个基于指定接服务器主机名或InetAddress和服务器端口号的流套接字。对于第一个InetAddress子类对象通过addr参数获得服务器主机的IP地址，对于第二个函数host参数包被分配到InetAddress对象中，如果没有IP地址与host参数相一致，那么将抛出UnknownHostException异常对象。
如果创建连接成功，java网络API将在客户端的流套接字中捆绑客户程序的IP地址和任意一个端口号，否则两个函数都会抛出一个IOException对象。

重要方法：
InputStream getInputStream();
获得网络连接输入，同时返回一个IutputStream对象实例。

OutputStream getOutputStream();
获得网络连接输出,连接的另一端将得到输入，同时返回一个OutputStream对象实例。

必须捕获两个方法可能产生的IOException。怎么操作这些流对象就看你要作什么了！：）

3、ServerSocket类
描述：该类用于服务器端。
构造方法：该类有四个构造方法，常用的有：
ServerSocket(int port)
通过指定监听端口号来创建ServerSocket对象，如果在这时出现错误将抛出IOException异常对象，否则将创建ServerSocket对象并开始准备接收连接请求。接下来无限循环调用accept()方法。

重要方法：
Socket accept();
调用开始后accept()方法将导致调用线程阻塞直到连接建立。在建立连接后accept()返回一个最近创建的Socket对象，该Socket对象绑定了客户程序的IP地址和端口号。

4、注意事项：
在服务端和客户端均未发送数据时，不要在同时在两端的while()循环里读取 InputStream。否则将造成阻塞。
如果用字符流处理数据，请在数据末尾加上 “\r\n”,并记得 flush()一下。

二、实例
1、服务端 SimpleServerSocket:
例子采用字节流来操作，注释部分是采用字符流来操作。

java 代码

package com.unihub.unicall.test;
import java.io.IOException;
import java.net.ServerSocket;
public class SocketServerTest {
private ServerSocket server = null;
private int port = 9999;
public SocketServerTest() throws IOException
{
int counter = 1;
try
{
this.server = new ServerSocket(this.port);
}
catch (Exception ex)
{
System.err.println("Can't listening on port:" + this.port);
ex.printStackTrace(System.err);
System.exit(-1);
}
System.out.println("Start listening on port:" + this.port);
while (true)
{
new ServerThread(server.accept(),counter).start();
counter++;
}
}
public static void main(String[] args) throws Exception
{
// SocketServerTest sserver =
new SocketServerTest();
}
}

线程类：

java 代码

package com.unihub.unicall.test;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.net.Socket;
import com.unihub.unicall.common.util.SocketUtil;
public class ServerThread extends Thread {
private Socket client;
private int counter;
public ServerThread(Socket client, int counter) {
System.out.println("[info] Create connection with "
+ client.getInetAddress().getHostAddress().toString()
+ " successful.");
this.client = client;
this.counter = counter;
}
public void run() {
try {
BufferedInputStream bis = new BufferedInputStream(client
.getInputStream());
BufferedOutputStream bos = new BufferedOutputStream(client
.getOutputStream());
// BufferedReader in = new BufferedReader(new
// InputStreamReader(client.getInputStream()));
// PrintWriter out = new PrintWriter(client.getOutputStream(),true);
bos.write(("Hi! Enter QUIT to exit.\r\n").getBytes());
bos.flush();
boolean done = false;
byte[] bytes = new byte[client.getReceiveBufferSize()];
while (!done) {
int contentLength = bis.read(bytes);
if (contentLength == -1) {
System.out.println("contentLength = " + contentLength);
done = true;
} else {
// String recieve = new String(bytes, 0, contentLength);
// if (recieve.trim().equalsIgnoreCase("quit")) {
// done = true;
// } else {
// System.out.println("[info] " + recieve);
//
// bos
// .write(("Echo server(" + counter + "):"
// + recieve + "\r\n").getBytes());
// bos.flush();
// }
byte[] b1 = SocketUtil.getSubByte(bytes, 0, 4);
byte[] b2 = SocketUtil.getSubByte(bytes, 4, 4);
byte[] b3 = SocketUtil.getSubByte(bytes, 20, 257);
System.out.println("111111111111:"+SocketUtil.byte2int(b1));
System.out.println("报文长度:"+SocketUtil.byte2int(b2));
System.out.println("报文内容:"+new String(b3,"ISO-8859-1"));
}
}
// String recieve;
// while((recieve = in.readLine()) != null)
// {
// if(recieve.trim().equalsIgnoreCase("quit")){break;}
// else
// {
// System.out.println("[info] " + recieve);
// out.println("Echo server("+ counter +"):" + recieve);
// }
// }
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (client != null) {
client.close();
System.out.println("[info] Disconnect successful.");
}
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}

2、客户端 SimpleSocket:

java 代码

package com.cyberobject.socket;
import java.io.*;
import java.net.*;
public class SimpleSocket
{
private Socket client;
private String host = "192.168.0.66";
private int port = 30000;
public SimpleSocket()
{
try
{
this.client = new Socket(InetAddress.getByName(this.host),this.port);
System.out.println("[info] Connect to " + this.host + " successful.");
// BufferedReader in = new BufferedReader(new
// InputStreamReader(client.getInputStream()));
// PrintWriter out = new PrintWriter(client.getOutputStream(),true);
BufferedReader systemIn = new BufferedReader(new InputStreamReader(System.in));
BufferedInputStream bis = new BufferedInputStream(client.getInputStream());
BufferedOutputStream bos = new BufferedOutputStream(client.getOutputStream());
System.out.println("[info] Start...");
boolean done = false;
// while(!done)
// {
// String recieve = in.readLine();
// if(recieve == null) done = true;
// else
// {
// System.out.println(recieve);
// out.println(systemIn.readLine());
// }
// }
byte[] bytes = new byte[client.getReceiveBufferSize()];
int len = 0;
while (!done)
{
len = bis.read(bytes);
if (len == -1) done = true;
else
{
String recieve = new String(bytes, 0, len);
System.out.println(recieve);
bos.write(systemIn.readLine().getBytes());
bos.flush();
}
}
System.out.println("[info] Stop.");
}
catch (Exception ex)
{
ex.printStackTrace(System.err);
}
finally
{
try
{
if (client != null)
{
client.close();
}
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
public static void main(String[] args)
{
SimpleSocket ssocket = new SimpleSocket();
}
}

分享到：

oracle存储过程基本方法 | 全面认识UML类图元素

2007-08-21 16:08
浏览 12230
评论(4)
查看更多

4 楼 struts2VSspring 2012-01-06

貌似运行有错唉

3 楼 f_zongjian 2009-04-22

wzx7934003 写道

兄弟，少一个socketutil类啊，能麻烦贴一下吗

-------------------------
public static byte[] getSubByte(byte[] byteArray, int startIndex, int endIndex) {
byte[] newArray = new byte[endIndex - startIndex + 1];
for(int index = 0; index < (endIndex - startIndex); index++) {
newArray[index] = byteArray[startIndex + index];
}
return newArray;
}
public static int byte2int(byte[] byteArray) {
return new Integer(new String(byteArray)).intValue();
}

2 楼 ypluck 2008-12-17

SocketUtil就实现了一个截取，一个转换，自己写个就OK

1 楼 wzx7934003 2008-11-26

兄弟，少一个socketutil类啊，能麻烦贴一下吗

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论