最近一个项目中接口通讯这一块主要是调用银联系统的socket接口,我方是客户端,即发送请求接收返回报文的一方。在贴代码之前,还是要了解一下关于socket的基础知识。
Socket的基本概念
1.建立连接
当需要建立网络连接时,必须有一台机器运行一个程序,随时等候连接,而另一端的程序这对其发出连接请求。这一点同电话系统类似——必须有一方拨打电话,而另一方必须等候电话连通。
建立连接的过程为:
(1)先在服务器端生成一个ServerSocket实例对象,随时监听客户端的连接请求。
(2)当客户端需要连接服务端时,相应地要生成一个Socket实例对象,并发出连接请求,其中host参数指明该主机名,port参数指明该主机端口号。
(3)服务器端通过accept()方法接收到客户端的请求后,开辟一个接口与之进行连接,并生成所需的I/O数据流。
(4)客户端和服务器端的通信都是通过一对InputStream和OutputStream进行的,通信结束后,两端分别关闭对应的Socket接口。
2.连接地址
打电话时,呼叫方必须事先知道所需拨打的号码,而程序建立网络连接时,也同样需要知道地址或主机名称。
另外,网络连接还需要一个端口号(可以将其当作电话的分机号),连接到正确的主机之后,需要对该连接确认特定口令。
3.端口号
在TCP/IP系统中,端口号由16位二进制整数组成,即在0-65535之间。实际应用中,前1024个端口号已经预先定义为一些特定服务,因此一般不能使用,除非想同这些服务器进行连接(如Telnet,SMTP,mail,ftp等)。在两个程序连接之前,彼此之间必须达成一致,即由客户端负责初始化连接,而服务器随时等候请求。只有客户端和服务器端指定端口号一致时连接才会建立。如果系统中两个程序所用端口号不一致,这连接无法建立。
4.网络连接模式
在Java中,TCP/IP接口的连接是由java.net包中的类实现的。如图表示的是Socket连接过程中客户端和服务器端的工作原理。
每个server端都拥有一个端口号,一台机器上如果运行多个服务,这可能对应多个端口号。通信结束后,两端分别关闭对应的Socket接口,而不影响其他的端口。
Socket通信的基本步骤
使用Socket方式进行网络通信的程序基本结构都是类似的,无论一个Socket通信程序的功能多么齐全、程序多么复杂,其基本结构都是一样的。客户端与服务器端进行通信的过程都包括以下四个基本步骤:
(1)在服务器端指定一个用来等待连接的端口号,在客户端规定一个主机和端口号,从而在客户端和服务器端创建Socket/ServerSocket实例。
(2)打开连接到Socket的输入输出流。
(3)利用输入输出流,按照一定的协议对Socket进行读写操作。
(4)关闭输入输出流和Socket
通常,程序员的主要工作时针对所要完成的功能砸器第(3)步进行编程,第(1)、(2)、(4)步对所有的通信程序来说几乎都是一样的。
Socket类中常用的构造函数
1:Socket(InetAddress address,int port) :该方法用于创建一个链接,向指定的IP地址上指定的端口的服务器端程序发送连接请求
2:Socket(InetAddress address,int port) : 同上,但该方法允许通过主机名字符串向服务器发送连接请求
Socket类中常用的方法
1:InetAddress getLocalAddress() :返回和Socket进行连接的本地的IP地址
2:int getLocalPort() :返回和Socket进行连接的本地的端口号
3:InetAddress getInetAddress():返回Socket建立了连接的服务器的IP地址
4:int getPort():返回和Socket建立了连接的服务器的端口号
5:InputStream getInputStream() :返回当前Socket的输入流(常用)
6:OutputStream getOutStream():返回当前Socket的输出流(常用)
7:void close():关闭当前的Socket 连接
ServerSocket中常用的构造函数
1:ServerSocket(int port) :这是构造方法用于在当前的服务器默认的IP地址上监听一个指定的端口,即在指定的IP和端口创建一个ServerSocket对象
ServerSocket中常用的方法
1:Socket accept() :产生阻塞,监听指定的端口,直至有客户端发来连接请求(常用)
2:void close() :关闭当前ServerSocket
3:InetAddress getInetAddress() :返回ServerSocket监听的本机的IP地址
4:int getLocalPort(): 返回ServerSocket监听的,本机的IP地址上指定的端口号
5:int getSoTimeout()::void setSoTimeout(int timeout) 设置连接过程中没有得到相应的等待期限时间(TimeOut)
6:String toString() : 以字符串的方式返回ServerSocket监听的,本机的IP地址及其端口号
Socker通信的程序设计
终于到了贴代码的时间了。。。。。
1.服务器端程序
public static void main(String[] args) {
// 定义ServerSocket和Socket对象
ServerSocket ss = null;
Socket sk;
// 定义发送字符串,即客户端收到的信息
String sendString = "hello!我是服务端...";
// 定义OutputStream类
OutputStream s1out;
// 定义DataOutputStream类
DataOutputStream dos;
// 通过1314端口建立连接
try {
// 创建ServerSocket并把传入端口号
ss = new ServerSocket(1314);
} catch (Exception e) {
e.printStackTrace();
}
// 循环运行监听程序,以监视连接请求
while (true) {
try {
// 监听端口请求,等待连接
sk = ss.accept();
// 得到与socket相连接的数据流对象
s1out = sk.getOutputStream();
dos = new DataOutputStream(s1out);
// 发送字符串
dos.writeUTF(sendString);
// 关闭数据流(但不是关闭Socket连接)
dos.close();
s1out.close();
sk.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
2.客户端程序
/** * 采用socket连接向服务器发送消息,接受响应信息 注意,如果是通过不同的ip port确定调用接口 这个方法要重写,将ip * port作为请求条件,现改为传固有参数进来 * * @param text * @throws Exception */ public static String sendBySocket(String text, String ip, int port) throws Exception { log.info("开始建立socket连接"); Socket socket = new Socket(ip, port); InputStream is = socket.getInputStream(); InputStreamReader isr = new InputStreamReader(is, "GBK"); // 2.获取客户端输出流 OutputStream dos = socket.getOutputStream(); log.info("连上服务端"); // 3.向服务端发送消息 dos.write(text.getBytes()); dos.flush(); log.info("成功向服务器发送消息"); // 4.获取输入流,并读取服务器端的响应信息 BufferedReader br = new BufferedReader(isr); String returnInfo = br.readLine(); log.info("服务器端返回数据为:" + returnInfo); // 4.关闭资源 br.close(); isr.close(); is.close(); dos.close(); socket.close(); return returnInfo; }