- 浏览: 338207 次
- 性别:
- 来自: 上海
文章分类
最新评论
-
yin_bp:
不建议使用session复制机制,推荐bboss会话共享框架, ...
JBOSS7 集群和Session复制配置笔记 -
heipacker:
建议:java(多线程)实现高性能数据同步==>java ...
java(多线程)实现高性能数据同步 -
yang_min:
582399232 写道你的脚本貌似不能用呀?service ...
JBOSS7学习笔记 -
yang_min:
582399232 写道感觉这个脚本不好#shutdown=' ...
JBOSS7学习笔记 -
yang_min:
582399232 写道博主能问几个问题吗?1.按照你的步骤执 ...
JBOSS7 集群和Session复制配置笔记
1.服务端
2.客户端
package sterning; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintWriter; import java.net.*; import java.util.concurrent.*; public class MultiThreadServer { private int port=8821; private ServerSocket serverSocket; private ExecutorService executorService;//线程池 private final int POOL_SIZE=10;//单个CPU线程池大小 public MultiThreadServer() throws IOException{ serverSocket=new ServerSocket(port); //Runtime的availableProcessor()方法返回当前系统的CPU数目. executorService=Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*POOL_SIZE); System.out.println("服务器启动"); } public void service(){ while(true){ Socket socket=null; try { //接收客户连接,只要客户进行了连接,就会触发accept();从而建立连接 socket=serverSocket.accept(); executorService.execute(new Handler(socket)); } catch (Exception e) { e.printStackTrace(); } } } public static void main(String[] args) throws IOException { new MultiThreadServer().service(); } } class Handler implements Runnable{ private Socket socket; public Handler(Socket socket){ this.socket=socket; } private PrintWriter getWriter(Socket socket) throws IOException{ OutputStream socketOut=socket.getOutputStream(); return new PrintWriter(socketOut,true); } private BufferedReader getReader(Socket socket) throws IOException{ InputStream socketIn=socket.getInputStream(); return new BufferedReader(new InputStreamReader(socketIn)); } public String echo(String msg){ return "echo:"+msg; } public void run(){ try { System.out.println("New connection accepted "+socket.getInetAddress()+":"+socket.getPort()); BufferedReader br=getReader(socket); PrintWriter pw=getWriter(socket); String msg=null; while((msg=br.readLine())!=null){ System.out.println(msg); pw.println(echo(msg)); if(msg.equals("bye")) break; } } catch (IOException e) { e.printStackTrace(); }finally{ try { if(socket!=null) socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
2.客户端
package sterning; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class MultiThreadClient { public static void main(String[] args) { int numTasks = 10; ExecutorService exec = Executors.newCachedThreadPool(); for (int i = 0; i < numTasks; i++) { exec.execute(createTask(i)); } } // 定义一个简单的任务 private static Runnable createTask(final int taskID) { return new Runnable() { private Socket socket = null; private int port=8821; public void run() { System.out.println("Task " + taskID + ":start"); try { socket = new Socket("localhost", port); // 发送关闭命令 OutputStream socketOut = socket.getOutputStream(); socketOut.write("shutdown\r\n".getBytes()); // 接收服务器的反馈 BufferedReader br = new BufferedReader( new InputStreamReader(socket.getInputStream())); String msg = null; while ((msg = br.readLine()) != null) System.out.println(msg); } catch (IOException e) { e.printStackTrace(); } } }; } }
发表评论
-
Java压缩 解压缩zip 并解决linux下中文乱码
2012-06-13 15:00 26681:再压缩前,要设置linux模式, 需要使用第三方ant-1 ... -
关于英文操作系统中解析中文文件插入到oracle中乱码问题
2011-11-04 22:58 1293真实环境: windows 2008 英文版 weblog ... -
Java反射经典实例 Java Reflection Cookbook (初级)
2009-10-16 14:56 2748Java提供了一套机制来动态执行方法和构造方法,以及数组操作等 ... -
判断密码的小方法(记一下不怕忘了)
2009-05-12 18:11 1268package test; import java.ut ... -
java的一些实用工具方法(用的时候随手了)
2009-03-28 16:21 1252// 将127.0.0.1 形式的IP地址转换成10进制整数, ... -
用XSL与XML实现多级菜单
2008-12-12 15:22 2519XML是可扩展标记语言(地 ... -
封装JNDI操作LDAP服务器的工具类(1)
2008-07-18 15:28 2391LDAP操作封装类 作者:廖武锋 MSN:liaowufe ... -
学Java应该搞懂的问题
2008-07-16 09:21 1376导读: 对于这个 ... -
Java实现获取本机上ADSL的IP
2008-05-20 15:42 2184import java.net.*; public clas ... -
对Spring做简单介绍
2007-11-05 16:46 1271Spring和Struts一样都是一 ... -
Struts,Spring,Hibernate优缺点
2007-11-05 12:06 3134.struts struts框架具有组件的模块化,灵活性和重 ... -
什么是JDBC
2007-11-05 12:05 2050JDBC, 全称为Java DataBase Co ... -
JAVA程序员之路
2007-11-04 22:41 2503很多网友问我学习Java有没有什么捷径,我说“无他,唯手熟尔” ... -
数据库时代的终结
2007-11-04 22:37 1162以数据库为核心的软件时代已经过去,数据库时代早已结束,当我看到 ... -
致面向对象技术初学者的一封公开信
2007-11-04 22:35 1121致面向对象技术初学者 ... -
Java EE/J2EE面向对象实战之道
2007-11-04 22:12 1068经常看到不少人抱怨Java ... -
经典Java基础问题!!!!
2007-11-03 00:02 1282对于这个系列里的问题,每个学Java的人都应该搞懂。当然,如果 ... -
什么是ant?
2007-11-02 23:28 2357ant Ant是一种基于Java的build工具。理论上来说, ... -
什么是Ruby
2007-11-02 21:06 1279Ruby是一种功能强大的面向对象的脚本语言,她可以使您方便快捷 ... -
转发和重定向的区别
2007-11-02 20:38 4683转发和重定向的区别 不要仅仅为了把变量传到下一个页面而使用s ...
相关推荐
多线程Java Socket编程示例.doc
其中采用Java 的ExecutorService来进行线程池的方式实现多线程,模拟客户端多用户向同一服务器端发送请求. 注意,此为学习笔记,可以作为参考学习使用,不建议商业使用或生产使用。 废话不多说,直接上代码。
多线程Java_Socket编程示例,多线程socket编程,值得一看
本代码系Java网络编程(第四版)示例代码,包括多线程编程示例代码,URL/RUI编程示例代码,HTTP编程示例代码,Socket编程示例代码和UDP编程示例代码
环境:Windows XP SP3、 VC++ 6.0、 Windows 2003 SDK 使用步骤: 1、下载解压之后,使用VC++ 6.0打开两个工程:...阅读对象:具有Java的Socket编程经验的人员,并且希望能够书写出比Java效率更高的即时通讯程序的人员
1.6 Java socket - 一个多线程示例 . . .. . . . 29 1.7 Java socket - 一个带有连接池的示例 . . . .. 35 1.8 Java socket - 现实生活中的套接字 . . . . .. . . 45 1.9 Java socket - 总结 . . . . . . . . . . . ...
java 多线程UDP通信资料与代码: 1、UDP多线程通信server程序(serverThread)详细解析 2、简易UDP client程序 3、多线程Java_Socket编程示例等资料
2012-06-11 10:37 151,588 多线程Java Socket编程示例.html 2012-06-11 09:46 56,832 存储管理动态分区分配算法的模拟.doc 2012-06-11 09:45 32,389 完整的串口通信程序VC++源码.7z 2012-06-11 10:41 2,183,866 对...
本书涵盖了Java平台标准版的全部基础知识和高级特性,包括Java编程基础知识、Java面向对象程序设计、高级类特性、Java GUI程序设计、集合框架、Java异常处理、I/O流、泛型、JDBC访问数据库、多线程编程、Socket网络...
主要介绍了Java编程利用socket多线程访问服务器文件代码示例,具有一定参考价值,需要的朋友可以了解下。
因为涉及到Socket编程,所以一定会使用多线程编程。这里本人翻写一个通用的线程池类,它可以用来作为工具类处理许多多线程问题。代码注释非常详尽,一行注释一行代码。 阅读对象:非常熟悉Java的基本概念,并且熟悉...
聊天室小程序示例,用到了socket编程,xml格式传输,多线程