我爱电脑技术论坛 » 编程语言 » Java开发中有关Java Socket编程的一些介绍

论坛积分策略	论坛VIP区开放申请	我爱电脑万人签名活动	原声大碟520欢迎你	广告位招租

‹‹ 上一主题 | 下一主题 ››

打印

[java] Java开发中有关Java Socket编程的一些介绍

star2008

等级：金牌会员

荣誉勋章

社区建设勋章

楼主大中小发表于 2008-5-19 11:13 只看该作者

Java开发中有关Java Socket编程的一些介绍

事实上网络编程简单的理解就是两台计算机相互通讯数据而已.对于程序员而言,去掌握一种编程接口并使用一种编程模型相对就会显得简单的多了.Java SDK提供一些相对简单的Api来完成这些工作.Socket就是其中之一.对于Java而言.这些Api存在与java.net 这个包里面.因此只要导入这个包就可以准备网络编程了. www.520diannao.com! x3 Y+ p. O$ S7 q% ]4 ?* M
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站+ b8 N& X: n9 z
- [' t6 a. X8 Q/ ?- }7 h# |; @
网络编程的基本模型就是客户机到服务器模型.简单的说就是两个进程之间相互通讯,然后其中一个必须提供一个固定的位置,而另一个则只需要知道这个固定的位置.并去建立两者之间的联系..然后完成数据的通讯就可以了.这里提供固定位置的通常称为服务器,而建立联系的通常叫做客户端.基于这个简单的模型,就可以进入网络编程啦.

www.520diannao.com1 l/ L. F0 {8 J) W! C5 s
Java对这个模型的支持有很多种Api.而这里我只想介绍有关Socket的编程接口.对于Java而言已经简化了Socket的编程接口.首先我们来讨论有关提供固定位置的服务方是如何建立的.Java提供了ServerSocket来对其进行支持.事实上当你创建该类的一个实力对象并提供一个端口资源你就建立了一个固定位置可以让其他计算机来访问你.ServerSocket server=new ServerSocket(6789);这里稍微要注意的是端口的分配必须是唯一的.因为端口是为了唯一标识每台计算机唯一服务的.另外端口号是从0~65535之间的,前1024个端口已经被Tcp/Ip 作为保留端口,因此你所分配的端口只能是1024个之后的.好了.我们有了固定位置.现在所需要的就是一根连接线了.该连接线由客户方首先提出要求.因此Java同样提供了一个Socket对象来对其进行支持.只要客户方创建一个Socket的实例对象进行支持就可以了.Socket client

=new Socket(InetAddress.getLocalHost(),5678);客户机必须知道有关服务器的IP地址.对于着一点Java也提供了一个相关的类InetAddress 该对象的实例必须通过它的静态方法来提供.它的静态方法主要提供了得到本机IP 和通过名字或IP直接得到InetAddress的方法.

7 d) r% X2 @2 _. B
好了.上面的方法基本可以建立一条连线让两台计算机相互交流了.可是数据是如何传输的呢?事实上I/O操作总是和网络编程息息相关的.因为底层的网络是继续数据的.除非远程调用,处理问题的核心在执行上.否则数据的交互还是依赖于IO操作的.所以你也必须导入java.io这个包.java的IO操作也不复杂.它提供了针对于字节流和Unicode的读者和写者,然后也提供了一个缓冲用于数据的读写.
打造最好的电脑自学交流论坛4 o- ^& j4 {- i* v' s
www.520diannao.com9 Z. e/ }4 l4 Q# U7 S( ]% M" Q7 P3 _
BufferedReader in=new BufferedReader(new InputStreamReader(server.getInputStream()));
www.520diannao.com- F: A% F: J  q9 P
我爱电脑技术社区--打造最好的电脑技术自学交流平台8 {: _& n7 C* r" v6 R
PrintWriter out=new PrintWriter(server.getOutputStream()); 我爱电脑技术论坛3 W4 g6 k% w" }& N

上面两句就是建立缓冲并把原始的字节流转变为Unicode可以操作.而原始的字节流来源于Socket的两个方法.getInputStream()和getOutputStream()方.分别用来得到输入和输出.那么现在有了基本的模型和基本的操作工具.我们可以做一个简单的Socket例程了. 我爱电脑技术论坛1 i2 S# P; O& T6 |: x
我爱电脑技术社区--打造最好的电脑技术自学交流平台5 s0 S4 x. [& d$ c5 Q9 b  p

服务方:

import java.io.*; 我爱电脑技术论坛% j! J# h/ `% H  g7 D2 T
打造最好的电脑自学交流论坛' u* a& e5 w' T0 ?
www.520diannao.com* r6 j# \  r" a& e* q, M; J
import java.net.*;
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站1 [* }! B& @% _8 y7 N) _( C
我爱电脑技术论坛) ^: {: l7 q9 U* H, n
% B2 a. F! ~- [. N$ R0 _2 q# d
public class MyServer {

public static void main(String[] args) throws IOException{ www.520diannao.com3 K! l" ~' t: {% x2 E% O
我爱电脑技术社区--打造最好的电脑技术自学交流平台8 J) B- B! h: B  x" R9 P6 Q7 E

ServerSocket server=new ServerSocket(5678);
www.520diannao.com. w. j" p2 t6 G1 a. ~7 Q: a3 r
& j5 M( e1 d  a, C/ V% g& I
Socket client=server.accept(); 打造最好的电脑自学交流论坛- }$ o1 F3 k8 \3 d4 `* L4 {

BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream()));

PrintWriter out=new PrintWriter(client.getOutputStream());
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站$ G7 H2 ~0 u; j' O
; j! U& M  ?% ^. c
while(true){ 打造最好的电脑自学交流论坛  g+ H) \7 C  \( h' H8 c

3 c. z6 B8 W1 |" J
String str=in.readLine();
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站$ M+ w% E' Y4 {8 H8 J' t' h  L
www.520diannao.com! |  R9 E4 n2 }- _
System.out.println(str);

out.println("has receive....");

out.flush();
我爱电脑技术社区--打造最好的电脑技术自学交流平台  N0 G0 f! @) K4 ?
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站) r: T7 o, [. F: b" b& Q- B$ `
if(str.equals("end")) 我爱电脑技术论坛$ e, k( x6 F+ d8 t
打造最好的电脑自学交流论坛! ^8 M  Y* I9 d, P
打造最好的电脑自学交流论坛9 D# o2 D4 E0 q: i( e# a6 l
break;
我爱电脑技术社区--打造最好的电脑技术自学交流平台2 m0 f1 C* O( J: }% }, _: ]( X7 C
www.520diannao.com3 P# T9 [  g! c  ^# h  F
} 电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站- O6 z& ]* ^% h& y8 g

client.close(); www.520diannao.com- Y3 u( R( B% i6 G4 c& g6 \
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站$ V) ^' f  s* u3 }

} 9 S/ Z- x2 z4 j- ~/ H

}

这个程序的主要目的在于服务器不断接收客户机所写入的信息只到.客户机发送"End"字符串就退出程序.并且服务器也会做出"Receive"为回应.告知客户机已接收到消息. 打造最好的电脑自学交流论坛9 l' V( [0 U' h6 E1 p+ X
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站( F6 a- R! ]7 T2 Y5 N

客户机代码:

3 |8 ]7 ^9 K1 d
import java.net.*;
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站4 p. j9 p! q( h2 Q- E4 Z- u
打造最好的电脑自学交流论坛  L6 N- e. a& Q6 a% t
import java.io.*;
我爱电脑技术论坛3 Z' C, I8 B" ]" [5 [

我爱电脑技术社区--打造最好的电脑技术自学交流平台5 ]# `* }9 O/ o* P
public class Client{ www.520diannao.com, c9 y: \  a/ v- N% H9 P
我爱电脑技术社区--打造最好的电脑技术自学交流平台! X' g0 G; z" u* X( {% i
打造最好的电脑自学交流论坛* D7 E) D- q# E3 Y! s! M9 t4 M
static Socket server;

public static void main(String[] args)throws Exception{ www.520diannao.com  p* E/ a9 S8 t0 A
打造最好的电脑自学交流论坛; ?5 n- P7 ?9 ^: [9 @
9 e+ U2 Y( F- j' Q/ Q
server=new Socket(InetAddress.getLocalHost(),5678);
打造最好的电脑自学交流论坛9 h; w' r9 t- Q- i, F# V( q5 I8 N

BufferedReader in=new BufferedReader(new InputStreamReader(server.getInputStream()));

PrintWriter out=new PrintWriter(server.getOutputStream());

www.520diannao.com: e' i. r1 q+ i" X) [
BufferedReader wt=new BufferedReader(new InputStreamReader(System.in));

电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站( _, V' H1 c' h4 [, I

while(true){

我爱电脑技术社区--打造最好的电脑技术自学交流平台: b# x( O, h& [
String str=wt.readLine(); 打造最好的电脑自学交流论坛* c+ D# @4 ^/ X" `5 Q1 [

out.println(str);

out.flush(); 我爱电脑技术论坛4 U" o. [  b$ h: k" ?2 R0 \; n
打造最好的电脑自学交流论坛, q8 r: e3 [2 ~% Z1 \

if(str.equals("end")){ 我爱电脑技术社区--打造最好的电脑技术自学交流平台3 t- i5 d3 O1 d& N+ e  \. O

我爱电脑技术社区--打造最好的电脑技术自学交流平台) h+ q( }, D, }, {
break;
我爱电脑技术社区--打造最好的电脑技术自学交流平台! ^' \" p  |: u( Q) z$ \7 B. R4 S

}
我爱电脑技术论坛  K4 W; T6 d5 n8 E. L
打造最好的电脑自学交流论坛3 U" W7 U2 E2 f6 @) k
System.out.println(in.readLine());

}
www.520diannao.com3 U; o% [; f: I# [

server.close(); 我爱电脑技术论坛* @- N4 Y' H$ y( ^7 P

}
我爱电脑技术社区--打造最好的电脑技术自学交流平台, I0 y$ Y0 e) E7 A

} ; F/ g+ l% J9 x

我爱电脑技术论坛, Q9 a: @6 y" R

客户机代码则是接受客户键盘输入,并把该信息输出,然后输出"End"用来做退出标识.

TOP

star2008

等级：金牌会员

荣誉勋章

社区建设勋章

2楼大中小发表于 2008-5-19 11:13 只看该作者

这个程序只是简单的两台计算机之间的通讯.如果是多个客户同时访问一个服务器呢?你可以试着再运行一个客户端,结果是会抛出异常的.那么多个客户端如何实现呢? 我爱电脑技术论坛; @1 @4 b& n: y5 x4 m1 h& v
* R: |* \; z6 F

我爱电脑技术论坛8 I& S& v7 b9 n& L2 y. ^$ R: b+ _! W
其实,简单的分析一下,就可以看出客户和服务通讯的主要通道就是Socket本身.而服务器通过accept方法就是同意和客户建立通讯.这样当客户建立Socket的同时.服务器也会使用这一根连线来先后通讯.那么既然如此只要我们存在多条连线就可以了.那么我们的程序可以变为如下:
www.520diannao.com9 G; m* Q! G5 @4 O; V& h. K
我爱电脑技术社区--打造最好的电脑技术自学交流平台# L, Q) ~5 e: Z5 E
我爱电脑技术论坛* i) Z# v( Y& d& }, R. @6 c
服务器: www.520diannao.com/ a6 r7 \4 e) p$ |7 R; P" c8 L8 l
我爱电脑技术社区--打造最好的电脑技术自学交流平台: M- q1 @; a$ T$ C  a+ a

/ i  ~0 }2 S( N1 |2 m
import java.io.*;

import java.net.*; 电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站: O. O9 J2 ]/ G7 n

8 g9 d. R2 F; ^. J# k

public class MyServer { www.520diannao.com6 s  J3 p5 v6 D3 H& S! F% h+ g

我爱电脑技术论坛4 J1 J3 |. X- {$ x7 }
public static void main(String[] args) throws IOException{

电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站6 V# W3 l6 n) q( X& ^& }% A
ServerSocket server=new ServerSocket(5678);
www.520diannao.com$ L8 Q% U9 l1 o( L, @/ Q( e

while(true){ 电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站( R" h& u& W. D. I/ M# s9 Y
* Q+ i5 o' W. k

Socket client=server.accept();
www.520diannao.com3 A2 M) }& E1 u+ o' m0 L+ X9 w2 U4 [

BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream())); 电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站8 A. Z) K& ~4 K3 }! ~4 `: P) ~

打造最好的电脑自学交流论坛# _4 {7 B" C' M) v! k, `) ?0 V' _
PrintWriter out=new PrintWriter(client.getOutputStream()); 我爱电脑技术社区--打造最好的电脑技术自学交流平台) b* ?) j' c9 Z# n- S% i. i

- S5 r, @0 ?0 i  ]/ H
while(true){ 打造最好的电脑自学交流论坛7 d$ V# c3 \; c' S8 W
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站9 g) `( f# {8 T+ b. v9 [; Q" A

String str=in.readLine();
www.520diannao.com) ]' w$ e! Y, i/ c

System.out.println(str);

www.520diannao.com+ O1 q) |. B4 R7 ~
out.println("has receive....");

out.flush();

if(str.equals("end")) 打造最好的电脑自学交流论坛& {. }# M  o; i% X# T

打造最好的电脑自学交流论坛2 x) \" V) C' A9 n5 s
break; 6 X) m8 X" n1 @

打造最好的电脑自学交流论坛6 C6 c) t/ _8 i# r9 l: \8 P
}
www.520diannao.com$ s) t1 X) u# X6 a4 S* g
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站$ ?, h: N$ s& C6 _! |( v( B
client.close();
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站) n9 U" H) L5 ~: I9 X1 _2 V

} 我爱电脑技术论坛) m2 ~5 s6 i( x

8 i5 @* w+ e5 `
} www.520diannao.com. i; [+ L- L2 ~  k& ?

电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站8 S) F% N9 N( {0 Q' f( ^3 q
} 打造最好的电脑自学交流论坛+ M; k" `0 i; A, F5 e8 r
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站* y% d) Q$ q0 X, \
打造最好的电脑自学交流论坛, {- Z9 D, F5 F& P+ T
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站: Y( |0 i: p# j' H4 I
这里仅仅只是加了一个外层的While循环.这个循环的目的就是当一个客户进来就为它分配一个Socket直到这个客户完成一次和服务器的交互,这里也就是接受到客户的"End"消息.那么现在就实现了多客户之间的交互了.但是.问题又来了.这样做虽然解决了多客户,可是是排队执行的.也就是说当一个客户和服务器完成一次通讯之后下一个客户才可以进来和服务器交互.无法做到同时服务.那么要如何才能同时达到既能相互之间交流又能同时交流呢?很显然这是一个并行执行的问题了.所以线程是最好的解决方案. www.520diannao.com/ G& `; E% _: y9 B2 G! D5 j8 I3 O

0 \& u) u, s" [" o6 X* u) I
那么下面的问题是如何使用线程.首先要做的事情是创建线程并使得其可以和网络连线取得联系.然后由线程来执行刚才的操作.要创建线程要么直接继承Thread要么实现Runnable接口,要建立和Socket的联系只要传递引用就可以了.而要执行线程就必须重写run方法.而run方法所做的事情.就是刚才单线程版本main所做的事情.因此我们的程序变成了这样: % H+ t8 l- X7 U' F4 X5 ?$ ~! a

我爱电脑技术社区--打造最好的电脑技术自学交流平台3 u* O. Z4 a+ x+ {0 l4 a4 o
import java.net.*;

import java.io.*; 电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站# K4 f$ @( R! I: q: ~  x

public class MultiUser extends Thread{

www.520diannao.com- i$ O7 R4 _8 ]$ A8 ^9 B, b
private Socket client;

public MultiUser(Socket c){ 我爱电脑技术社区--打造最好的电脑技术自学交流平台" J& @( x' F# J

this.client=c; 我爱电脑技术社区--打造最好的电脑技术自学交流平台$ |5 D+ Y: ~$ c" R. V. S/ `( `
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站- x3 I( h+ B' c
- F/ k2 v+ _6 N4 [
} 我爱电脑技术社区--打造最好的电脑技术自学交流平台9 D6 Z5 D, I+ Y3 I, X& B
打造最好的电脑自学交流论坛7 s8 r" I4 h) d* Z% B; n/ a7 [. n% R

public void run(){ 4 m; l4 u! }! \) m

电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站. r) R8 `' u# u. ~+ x# t
try{

BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream())); 我爱电脑技术社区--打造最好的电脑技术自学交流平台* W) \+ K; M" t2 y+ k5 O" h
我爱电脑技术论坛' ~4 N7 ?5 d. B

PrintWriter out=new PrintWriter(client.getOutputStream()); 我爱电脑技术社区--打造最好的电脑技术自学交流平台' L  n1 `3 J' Z: r7 i* _6 u( `
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站1 z; x. z  F; H# i8 F

//Mutil User but can't parallel ( |6 r1 P. d. {
我爱电脑技术论坛* w( y& {, N  t" S
打造最好的电脑自学交流论坛8 V$ @' u  ^; T# Y' w1 D( T% q. V& g
while(true){ www.520diannao.com, Y7 ]# s' F) ?# ~- n& X
www.520diannao.com) j4 U/ T: U1 j7 L# u

String str=in.readLine(); www.520diannao.com) O, j3 b+ g% G, N# ]" [, X! q
: z1 _2 K2 s$ e
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站1 E$ _0 C$ M6 {% b- V& M. v
System.out.println(str); 4 b9 h7 e9 ~! |" Y

out.println("has receive....");
我爱电脑技术论坛! b) ?0 n3 P: X) S6 ~

out.flush();

打造最好的电脑自学交流论坛# V6 J4 X* s8 o2 M! L
if(str.equals("end"))

break; 电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站& K& ?! b0 F$ G, U$ u. ]

电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站7 e/ u* J0 A! `, z3 O
} 打造最好的电脑自学交流论坛* W5 }# f: O! j9 r" ?
打造最好的电脑自学交流论坛" O6 ^  L$ T' g! r6 l

client.close(); 我爱电脑技术论坛0 W( O5 s  J2 C3 W

www.520diannao.com& i" l& q& \5 a+ ~, o6 G! ?7 E
}catch(IOException ex){ 我爱电脑技术论坛6 P; g4 Z" S' Z2 {2 g4 Z
. ~( ]+ C- _, I& `& J

}finally{ 我爱电脑技术社区--打造最好的电脑技术自学交流平台( S8 L+ D' D& l5 _0 S# E  }! l  L* E, F& k8 s
我爱电脑技术社区--打造最好的电脑技术自学交流平台/ U. h1 f; |* G0 U
我爱电脑技术社区--打造最好的电脑技术自学交流平台0 j5 {- l! }8 T! l. {' w0 W' z
+ G6 s' s5 v4 g1 {  K
}
打造最好的电脑自学交流论坛# h5 ~( ^! Q8 m* ^" v

}
我爱电脑技术论坛6 M4 R# I& ^. x) A
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站! O5 _5 O/ o6 R) S# H5 Y

public static void main(String[] args)throws IOException{
我爱电脑技术论坛4 E2 r6 f) E6 s8 c6 |) ]9 n; z

ServerSocket server=new ServerSocket(5678); 我爱电脑技术论坛( X+ Z8 A, O* G0 @3 {1 T
我爱电脑技术社区--打造最好的电脑技术自学交流平台, S& f2 `! ]0 h# C0 Y
电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站6 \2 t" Y6 z8 H; |3 s
while(true){
我爱电脑技术论坛, S- }0 S5 M: h* q+ `$ Z# T
www.520diannao.com; b5 `! B/ N; r  l
//transfer location change Single User or Multi User 我爱电脑技术社区--打造最好的电脑技术自学交流平台- H1 O0 Q0 ], z2 z

MultiUser mu=new MultiUser(server.accept()); 电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站- B2 O2 b. ]  G4 Y, g& M
www.520diannao.com& z' S0 k$ x& t
! d; L! q. ^; W  V2 K- e8 U
mu.start(); 打造最好的电脑自学交流论坛7 p% |8 V* r2 I  P

我爱电脑技术论坛# R7 V; U7 `# G. U5 l4 n( M
} 我爱电脑技术论坛; D  o/ V% L( n
我爱电脑技术社区--打造最好的电脑技术自学交流平台, [) l$ z4 U7 V# v. s" B) H6 p( I

} 电脑,技术,IT,学习,交流,网络安全,QQ,硬件,软件,编程,教程,建站; Z' x) {2 T" p6 k& o5 L. _+ P

我爱电脑技术论坛6 o2 n; l! c" r* R2 P2 Y
}
我爱电脑技术社区--打造最好的电脑技术自学交流平台. G0 L0 T( d" I7 [" B- \1 Z
& Y0 e. l8 L- {2 g/ y- P5 x
* M- s! O8 q  a5 n& [9 n9 L
我的类直接从Thread类继承了下来.并且通过构造函数传递引用和客户Socket建立了联系.这样每个线程就有了.一个通讯管道.同样我们可以填写run方法.把之前的操作交给线程来完成.这样多客户并行的Socket就建立起来了.

TOP

‹‹ 上一主题 | 下一主题 ››