<div class="iteye-blog-content-contain" style="font-size: 14px"></div>
客户端代码
package serialver.client;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInput;
import java.io.ObjectInputStream;
import java.io.ObjectOutput;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
/**
* @ version 创建时间:2014-3-21 下午03:19:58
*
* @ author leicl
*
* 类说明:
*
*/
public class Client {
public static void main(String[] args) throws UnknownHostException, IOException, ClassNotFoundException {
Socket s = new Socket(InetAddress.getLocalHost(), 2323);
int[] a = {2,3,4,5};
int[] b = {1,1,1,1};
InputStream is = s.getInputStream();
ObjectInput ois = new ObjectInputStream(is);
OutputStream os = s.getOutputStream();
ObjectOutput oos = new ObjectOutputStream(os);
oos.writeObject(a);
oos.writeObject(b);
int[] result = (int[]) ois.readObject();
System.out.println("result got from MathServer:");
for (int i = 0; i < result.length; i++) {
System.out.print(result[i]+"\t");
}
ois.close();
oos.close();
}
}
服务器端代码:
package serialver.server;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInput;
import java.io.ObjectInputStream;
import java.io.ObjectOutput;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
* @ version 创建时间:2014-3-21 下午03:06:52
*
* @ author leicl
*
* 类说明:
*
*/
public class MathServer extends Thread{
public static void main(String[] args) throws IOException {
final ServerSocket ser = new ServerSocket(2323);
new Thread(new Runnable() {
public void run() {
while(true){
try {
final Socket accept = ser.accept();
int[] a = new int[10];
int[] b = new int[10];
int[] result = new int[10];
try {
//此处注意,应该先new ObjectOutput,否则会出现卡死问题
//而且系统捕获不到任何异常
OutputStream os = accept.getOutputStream();
ObjectOutput oos = new ObjectOutputStream(os);
InputStream in = accept.getInputStream();
ObjectInput ois = new ObjectInputStream(in);
a = (int[]) ois.readObject();
b = (int[]) ois.readObject();
for (int i = 0; i < a.length; i++) {
System.out.println("a["+i+"]=" +a[i]);
}
for (int i = 0; i < b.length; i++) {
System.out.println("b["+i+"]=" +b[i]);
}
for (int i = 0; i < b.length; i++) {
result[i] = a[i] + b[i];
}
for (int i = 0; i < result.length; i++) {
System.out.println("result["+i+"]=" +result[i]);
}
oos.writeObject(result);
oos.flush();
ois.close();
oos.close();
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}).start();
}
}
分享到:
相关推荐
客户端的请求首先会进入请求队列,处理器线程池会向请求队列获取请求并且分配分配处理器,每个处理器分配一个线程。处理器可以指定interceptor,处理逻辑都实现在ResponseHandler中。空闲时,处理器线程会休眠直到有...
java实现Socket方式文件批量传输/上传到服务器(awt界面),主要功能包括: 1.awt上传管理文件界面,提供applet嵌入jsp文件实现 2.Socket实现文件批量上传到SocketServer服务器 3.提供applet嵌入进jsp页面
Tcp(socket)Server.java
socketserver-kafka用Java netty 实现简单的socket 通讯,消费kafka消息队列appserver 目录是netty的socket监听启动。ServiceOrderConsumerAPI.java 是kafka的主要消费程序。程序写的很简单。只是做个小演示希望各位...
Socket和ServerSocket类库位于java.net包中。Server Socket用于服务器端,Server Socket通信是建立网络连接时使用的。在 连接成功时,应用程序两端都会产生一个Socket实例,操作这个实例,完成所需的会话。对于一个...
import java.io.*; import java.net.*; import java.util.concurrent.*; public class EchoServer { private int port=8000; private ServerSocket serverSocket; private ...
实现 Socket 客户端 和服务器 交互, 实现TCP即时通讯。
socket分为socketserver和socketclient,socketserver是一个简单的建立长连接后等待接收数据,socketclient请求建立与服务端连接,连接建立以后通过servlet发起通信。 服务端直接用application执行; 客户端部署到...
node-java-socket NodeJS net 模块学习 使用 net 模块作为分发服务器,把客户端消息广播其他客户端 客户端采用 Java socket 进行通信 USE client javac client/src/ui/ClientStart.java java client/src/ui/Client...
Socket_Server
通过GCC编译后,运行程序,就可以监听8000端口,收到数据会打印到终端
An blocking socket client for Java application or Andorid. Open source licenses Basic Socket Library Socket Server Plugin Library OkSocket Introduce OkSocket is a Java library project ...
用以一个餐饮卡机的项目socket代码,很简单。 将压缩包解压,在IDE上启动server thead,可以通过实例的client进行运行测试。 兼容其他的web项目,可在项目代码中以多线程方式启用。
1、使用场景:应用部署的...2、附件有源码,直接打包运行SocketServer,就能启动一个Socket的Http访问代理服务了,Test源文件是调用例子,直接调用proxyRequest方法(传入ip,port,需要代理访问的公网url参数)即可。
实现一个服务器对多个客户端的关键是,在服务端的使用集合CPtrList类用保存客户端的socket对象,思想与Java中的编程思想一样,只不过Java中会使用多线程技术,在Vector集合保存客户端的socket对象,而MFC框架提供了...
SocketServer为服务器端 ,java编写 SocketClient为客户端, android编写 最近在学习中,这些程序也是socket基本架构。绝对可行。 不要忘了,在程序中重新设置地址哦。 还有要保证服务器和客户端要在同一个局域网...
PC端一般使用c++或c# socket收发信息,网页端只能使用websocket,手机端是java socket。需要将PC端、手机端和网页端,多端打通同时实现即时通讯,就是需要websocket和socket相互通信。
套接字服务器Java多线程套接字服务器,基于BIO 用法: 扩展抽象类“ServerHandler”,实现方法“process(request)”: 公共类 MyServerHandler 扩展了 ServerHandler { Logger logger=ServerLoggerFactory.getLogger...