站长资讯网1．Socket是代表两台机器之间网络连接的对象(java.net.Socket)。
Socket的建立如下，参数分别是服务器端的IP地址和端口号： Socket socket = new Socket(“167.5.75.1”,5000);
2. 客户端(Client)Socket的使用
2.1从Socket读出数据步骤：
?
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
// 1.创建Socket连接,告知Server的IP地址以及端口号 Socket socket =newSocket(“127.0.0.1”,4242); // 2.创建InputStreamReader,用于读取socket输入流 InputStreamReader stream =newInputStreamReader(socket.getInputStream()); // 3.使用BufferedReader链接输入流 BufferedReader br =newBufferedReader(stream);
// 4.读出数据 String line =null; while((line = br.readLine()) !=null) { System.out.println(“Today’s advice is: “+ line); }
// 5. 关闭输入流BufferedReader br.close(); |
2.2向Scoket写入数据步骤：
?
|
1 2 3 4 5 6 7 8 9 |
// 1.创建Socket连接,告知Server的IP地址以及端口号 Socket socket =newSocket(“127.0.0.1”,4242); // 2.创建PrintWriter对象,用以接收socket输出流 PrintWriter writer =newPrintWriter(socket.getOutputStream()); // 3.使用PrintWriter对象写出输出数据 String advice =”Today’s advice”; writer.println(advice); // 4. 关闭连接 writer.close(); |
3. 服务器端(Server)Socket的使用
?
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 |
// 1.创建一个SercerSocket,使用4242端口监听客户端请求 ServerSocket serverSocket =newServerSocket(4242); System.out.println(“The server is started, listening on port 4242”);
while(true) { // 2.ServerSocket的accept()在等待用户连接的时候闲置;在用户连接上来的时候,返回一个Socket来与客户端通信 Socket socket = serverSocket.accept(); // 3.创建PrintWriter对象,用以接收socket输出流 PrintWriter writer =newPrintWriter(socket.getOutputStream()); // 4.使用PrintWriter对象写出输出数据 String advice =”notifier’s blog”; writer.println(advice);
// 5. 关闭连接 writer.close(); } |
4. 线程的状态
线程总共有5种状态:
1．新建 (Thread t = new Thread())
2．就绪 (t.start())
3．运行
4．堵塞
线程被block的原因很多,比如:等待IO操作, sleep(),等待被占用对象释放
5．死亡
5. 解决线程同步化问题的方法是: 对使用到共享对象的方法使用synchronized
需要注意的是:
虽说是方法进行了synchronized，但锁不是加在方法上的而是对象上的，也就是说，是synchronized方法获取对象锁。如果对象（类）有两个或者多个synchronized方法，就表示两个线程不能同时进入同一个方法，也不能同时进入不同的方法。 因为同一时间，只有一个方法在占有对象锁。
6. synchronized代码块
有时候在一个方法中做了很多事情，但只有一部分逻辑是需要synchronized的，这时候我们可以使用synchronized代码块。如下，其中this表示当前对象：
?
|
1 2 3 4 5 6 7 8 9 10 11 12 13 |
publicvoidfunction() { doSomething();
//以下方法需要同步化 synchronized(this) { doCriticalStuff(); moreCriticalStuff(); }
doSomeOtherThing(); } |
7. 以下是一个Socket简单的例子:
客户端代码及详细注释:
?
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 |
/** * @author notifier * @create 2010-9-25 上午10:12:10 * @version 1.0 */ publicclassDailyAdviceClient { publicstaticvoidmain(String[] args) { DailyAdviceClient client =newDailyAdviceClient(); client.receiveMsg(); }
publicvoidreceiveMsg() { try { // 1.创建Socket连接,告知Server的IP地址以及端口号 Socket socket =newSocket(“127.0.0.1”,4242); // 2.创建InputStreamReader,用于读取socket输入流 InputStreamReader stream =newInputStreamReader(socket .getInputStream()); // 3.使用BufferedReader链接输入流 BufferedReader br =newBufferedReader(stream);
// 4.读出数据 String line =null; while((line = br.readLine()) !=null) { System.out.println(“Today’s advice is: “+ line); }
// 5. 关闭输入流BufferedReader br.close(); }catch(UnknownHostException e) { e.printStackTrace(); }catch(IOException e) { e.printStackTrace(); } } } |
服务器端代码及详细注释:
?
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 |
/** * @author notifier * @create 2010-9-25 下午07:06:54 * @version 1.0 */ publicclassSimpleChatServer { // 保存客户端列表 privateArrayList clientList =newArrayList();;
publicstaticvoidmain(String[] args) { newSimpleChatServer().startUp(); }
/** * 负责服务器端的启动 * */ publicvoidstartUp() { try { // 创建服务器端ServerSocket连接,监听端口号5000 ServerSocket serverSocket =newServerSocket(5000);
// 轮询等待客户端请求 while(true) { // 等待客户端请求,无请求则闲置;有请求到来时,返回一个对该请求的socket连接 Socket clientSocket = serverSocket.accept();
// 将该客户端加入到列表中 PrintWriter writer =newPrintWriter(clientSocket.getOutputStream()); clientList.add(writer);
// 创建ClientHandler对象,通过socket连接通信 Thread t =newThread(newClientHandler(clientSocket)); t.start();
System.out.println(“有Client连进来“); } }catch(Exception e) { e.printStackTrace(); } }
/** * 客户端处理类, 主要负责: * 1.接收客户端发来的消息 * 2.将消息转发其他客户端 * @author sdniu * @create 2010-9-26 上午10:00:18 * @version 1.0 */ publicclassClientHandlerimplementsRunnable { privateBufferedReader reader; privateSocket socket;
/** * ClientHandler的构造函数 * @param clientSocket */ publicClientHandler(Socket clientSocket) {
try { // 得到socket连接 socket = clientSocket;
// 得到客户端发来的消息 InputStreamReader isReader =newInputStreamReader(socket.getInputStream()); reader =newBufferedReader(isReader); }catch(IOException e) { e.printStackTrace(); } }
publicvoidrun() { String message; try { while((message = reader.readLine()) !=null) { System.out.println(“客户端消息: “+ message); // 将客户端发来的消息转发所有客户端 notifyAllClients(message); } }catch(IOException e) { e.printStackTrace(); } } }
/** * * @param message */ publicvoidnotifyAllClients(String message) { // 得到客户端列表的迭代器,语法格式为 Iterator it = clientList.iterator(); Iterator it = clientList.iterator();
while(it.hasNext()) { try { // 得到的Iterator别忘了强制转换回PrintWriter PrintWriter writer = (PrintWriter) it.next(); writer.println(message); writer.flush(); }catch(Exception e) { e.printStackTrace(); } } } } |
