java Socket开发

java中什么是socket编程

网络上的两个程序通过一个双向的通讯连接实现数据的交换，这个双向链路的一端称为一个Socket。Socket通常用来实现客户方和服务方的连接。Socket是TCP/IP协议的一个十分流行的编程界面，一个Socket由一个IP地址和一个端口号唯一确定。 但是，Socket所支持的协议种类也不光TCP/IP一种，因此两者之间是没有必然联系的。在Java环境下，Socket编程主要是指基于TCP/IP协议的网络编程。

java编程中，Socket通信是怎么实现的？

java编程对于Socket之间的通信过程如下：

服务端往Socket的输出流里面写东西，客户端就可以通过Socket的输入流读取对应的内容。Socket与Socket之间是双向连通的，所以客户端也可以往对应的Socket输出流里面写东西，然后服务端对应的Socket的输入流就可以读出对应的内容。下面来看一些服务端与客户端通信的例子：

publicclassServer{

publicstaticvoidmain(Stringargs[])throwsIOException{
//为了简单起见，所有的异常信息都往外抛
intport=8899;
//定义一个ServerSocket监听在端口8899上
ServerSocketserver=newServerSocket(port);
//server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的
Socketsocket=server.accept();
//跟客户端建立好连接之后，我们就可以获取socket的InputStream，并从中读取客户端发过来的信息了。
Readerreader=newInputStreamReader(socket.getInputStream());
charchars[]=newchar[64];
intlen;
StringBuildersb=newStringBuilder();
while((len=reader.read(chars))!=-1){
sb.append(newString(chars,0,len));
}
System.out.println("fromclient:"+sb);
reader.close();
socket.close();
server.close();
}

}

客户端代码
Java代码publicclassClient{

publicstaticvoidmain(Stringargs[])throwsException{
//为了简单起见，所有的异常都直接往外抛
Stringhost="127.0.0.1";//要连接的服务端IP地址
intport=8899;//要连接的服务端对应的监听端口
//与服务端建立连接
Socketclient=newSocket(host,port);
//建立连接后就可以往服务端写数据了
Writerwriter=newOutputStreamWriter(client.getOutputStream());
writer.write("HelloServer.");
writer.flush();//写完后要记得flush
writer.close();
client.close();
}

}

java中socket编程

import java.io.*; import java.net.*; class UDPClient{ public static void main(String args[]) throws Exception{ DatagramSocket clientSocket = new DatagramSocket(); InetAddress IPAddress = InetAddress.getByName("localhost"); byte[] sendData = "F6".getBytes(); byte[] receiveData = new byte[64]; Datagra

用java做socket开发应用执行效率怎么样

一般这种情况用HTTP比较多，类似soap。 jsp，或者asp,php,python等都可以直接发http get或post的，接口灵活。 如果是纯粹的网络程序，java的socket通信比起c/c++还是稍弱了一些，毕竟，中间要经过java虚拟机。还有，如果做图像处理，视频等对内存要求比较大的时候，JAVA也有麻烦。

Java Socket开发 关于报文传递和接收

看 Oracle 官方教程，同步式的 Socket 就是传统的一问一答方式，它就是你需要的。

客户端先 socket.getOutputStream().write(...); 之后到 socket.getInputStream().read(byte[]) 在循环中读取直到 read 方法返回 -1 或你期望的字节数已经全部收到了就停下来，如果不尝试停下来，后面的 read 将会阻塞等待。

http://docs.oracle.com/javase/tutorial/networking/sockets/index.html

基于性能改进，一般我们需要使用 NIO 异步的 socket，只需要一个线程负责通信，每个线程都有自己的出站消息队列和入站消息队列，以线程为 key 区分开，通信线程只负责把各自的消息从出站队列中发送去并把收到的消息放入入站队列中，应用程序线程就去各自的消息队列中取消息就可以了。因为每个应用线程有各自的消息队列，我们把消息放入出站队列之后就到入站队列上用同步锁等待的方法阻塞到有消息回答时为止。

关于 NIO non-blocking 非阻塞式 socket，下面有一个 NBTimeServer 例子，它讲的是服务端。客户端与此类似，

http://docs.oracle.com/javase/7/docs/technotes/guides/io/example/index.html

NIO 通信线程样例。

publicvoidrun()
{
inttip=0;
try
{
selector=Selector.open();
SelectionKeyk=channel.register(selector,getInterestOptions());
k.attach(thread);//把当前线程绑定到附件中。
this.running=true;
statusChanged(Status.CONNECTED);
while(this.isRunning())
{
//select()isablockingoperation.
inteventCount=selector.select();
debug("[MC.Debug]PollingTCPevents..."+eventCount);
if(eventCount>0&&channel.isOpen()&&this.isRunning())
{
Setkeys=selector.selectedKeys();
for(Iteratoriter=keys.iterator();iter.hasNext();iter.remove())
{
SelectionKeykey=(SelectionKey)iter.next();
Threadthread=(Thread)key.attachment();

if(!key.isValid())
{//channelisclosing.
break;
}
process(key);//处理读取消息并把消息放入thread对应的队列。//写出消息类似的，不过在register时需要注册写出允许的事件，

}
}
}
}