詩(shī)特林-sterning

請(qǐng)問作者：
可不可以利用服務(wù)端主動(dòng)發(fā)信？

膏藥帖~~

很好！不錯(cuò)！

dgdfggfdgdf

我也是參照孫的書，可是運(yùn)行不能得到正確的結(jié)果!很是郁悶啊
[code]
package com.zz.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class EchoServer {

private int port = 8000;
private ServerSocket ss;

public EchoServer() throws IOException {
ss = new ServerSocket(port);
System.out.println("server is starting....");
}

private String echoString(String msg){
return "echo:" + msg;
}
public static void main(String[] args) {
try {
new EchoServer().service();
} catch (IOException e) {
e.printStackTrace();
}
}

private void service(){
while(true){
Socket s = null;
try{
s = ss.accept();
System.out.println("a client is coming......");
BufferedReader br = this.getReader(s);
PrintWriter pw = this.getWriter(s);
String msg = null;
while((msg = br.readLine()) != null){
System.out.println(msg);
pw.println(this.echoString(msg)+"\n");
pw.flush();
if(msg.equals("bye")) break;
}
}catch(IOException e ){

}
}
}

private PrintWriter getWriter(Socket s) throws IOException {
return new PrintWriter(s.getOutputStream());
}

private BufferedReader getReader(Socket s) throws IOException {
return new BufferedReader(new InputStreamReader(s.getInputStream()));
}

}



[/code]

package com.zz.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class EchoClient {
private String host = "localhost";
private int port = 8000;
private Socket socket;

private EchoClient() throws IOException {
socket = new Socket(host, port);
}

public void talk() throws IOException {
try {
BufferedReader br = getReader(socket);
PrintWriter pw = getWriter(socket);
BufferedReader localReader = new BufferedReader(
new InputStreamReader(System.in));
String msg = null;
while ((msg = localReader.readLine())!= null) {
pw.println(msg+"\n");
pw.flush();
System.out.println(br.readLine());
if (msg.equals("bye"))
break;
}
} catch (IOException e) {
} finally {
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}

private PrintWriter getWriter(Socket s) throws IOException {
return new PrintWriter(s.getOutputStream());
}

private BufferedReader getReader(Socket s) throws IOException {
return new BufferedReader(new InputStreamReader(s.getInputStream()));
}

/**
* @param args
* @throws IOException
*/
public static void main(String[] args) throws IOException {
new EchoClient().talk();

}

}

這個(gè)代碼有很多問題，如請(qǐng)求處理，怎么封裝請(qǐng)求對(duì)象，把請(qǐng)求對(duì)象放一隊(duì)列

從服務(wù)器端怎么發(fā)消息到客戶端.....

貌似整體思想可以，但是，程序的問題就比較多了...

第三方殺毒

如果多個(gè)線程對(duì)同一資源進(jìn)行讀取，能保證資源的原子性嗎？應(yīng)該對(duì)資源加鎖

正找這樣的文章 多謝

如何設(shè)定超時(shí)的問題呢？

我是java網(wǎng)絡(luò)編程的初學(xué)者很想加 詩(shī)特林 為好友向你請(qǐng)教些問題。我的qq826463574

服務(wù)器端：
public class MultiThreadServer {
private int port=8821;
private ServerSocket serverSocket;
private ExecutorService executorService;//線程池
private final int POOL_SIZE=10;//單個(gè)CPU線程池大小

public MultiThreadServer() throws IOException{
serverSocket=new ServerSocket(port);
//Runtime的availableProcessor()方法返回當(dāng)前系統(tǒng)的CPU數(shù)目.
executorService=Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*POOL_SIZE);
System.out.println("服務(wù)器啟動(dòng)");
}

public void service(){
while(true){
Socket socket=null;
try {
//接收客戶連接,只要客戶進(jìn)行了連接,就會(huì)觸發(fā)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 DataOutputStream dos(Socket socket) throws IOException{
OutputStream socketOut=socket.getOutputStream();
return new DataOutputStream(socketOut);
}
private DataInputStream dis(Socket socket) throws IOException{
InputStream socketIn=socket.getInputStream();
return new DataInputStream(socketIn);
}*/

public void run(){
try {
System.out.println("New connection accepted "+socket.getInetAddress()+":"+socket.getPort());
OutputStream os = socket.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);

InputStream is = socket.getInputStream( );
DataInputStream dis=new DataInputStream(is);
new myserverread(dis).start();
new myserverwite(dos).start();


} catch (IOException e) {
e.printStackTrace();
}/*finally{
try {
if(socket!=null)
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}*/
}
}
class myserverread extends Thread{
private DataInputStream dis;
public myserverread (DataInputStream dis){
this.dis=dis;
}
public void run(){
String info;
try{
while(true)
{
info=dis.readUTF();
System.out.println("對(duì)方說(shuō)"+info);
if (info.equals("bye")){
System.out.println("對(duì)方下線,程序退出");
System.exit(0);}
}
}
catch (Exception e){e.getStackTrace();}

}
}

class myserverwite extends Thread{
private DataOutputStream dos;
public myserverwite (DataOutputStream dos){
this.dos=dos;
}
public void run(){
BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
String info;
try{
while(true)
{
info=br.readLine();
dos.writeUTF(info);
if (info.equals("bye")){
System.out.println("自己下線,程序退出");
System.exit(0);}
}
}
catch (Exception e){e.getStackTrace();}

}
}

客戶端：


import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
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 ID=Info.i;

ExecutorService exec = Executors.newCachedThreadPool();

/* for (int i = 0; i < numTasks; i++) {
exec.execute(createTask(i));
}
*/
System.out.println("客戶端線程"+ID+"已啟動(dòng)~~");
exec.execute(createTask(ID));
Info.i=ID++;

}

// 定義一個(gè)簡(jiǎn)單的任務(wù)
private static Runnable createTask(int taskID) {
// this.taskID=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);
// 發(fā)送關(guān)閉命令
InputStream is = socket.getInputStream( );
DataInputStream dis=new DataInputStream(is);

OutputStream os = socket.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);

new myclientread(dis).start();
new myclientwite(dos).start();

} catch (IOException e) {
e.printStackTrace();
}
}

};
}
}
class myclientread extends Thread{
private DataInputStream dis;
public myclientread (DataInputStream dis){
this.dis=dis;
}
public void run(){
String info;
try{
while(true)
{
info=dis.readUTF();
System.out.println("對(duì)方說(shuō)"+info);
if (info.equals("bye")){
System.out.println("對(duì)方下線,程序退出");
System.exit(0);}
}
}
catch (Exception e){e.getStackTrace();}

}
}

class myclientwite extends Thread{
private DataOutputStream dos;
public myclientwite (DataOutputStream dos){
this.dos=dos;
}
public void run(){
BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
String info;
try{
while(true)
{
info=br.readLine();
dos.writeUTF(info);
if (info.equals("bye")){
System.out.println("自己下線,程序退出");
System.exit(0);}
}
}
catch (Exception e){}

}
}

這個(gè)程序我想實(shí)現(xiàn)多用戶與服務(wù)器的連接交互問題，但是能過連接上但是不能實(shí)現(xiàn)交互，這是為什么呢？我是java網(wǎng)絡(luò)編程初學(xué)者謝謝您的指教急待您的回復(fù)！

學(xué)習(xí)了

你好，這樣不會(huì)出現(xiàn)中文亂碼嗎？

求 超市收銀系統(tǒng) 用XML Socket 和多線程 做的 有的發(fā)我郵箱 769566815@qq.com

跪求 急用 6月5號(hào)交上去

@鐘僥
while(true){
Socket s = null;

每次s都是null

看錯(cuò)了，

s = ss.accept();

你那個(gè)代碼變量名太差了吧！看都看不清！

請(qǐng)問您知不知道哪里有socket的學(xué)習(xí)視頻啊？因?yàn)槭诸^資料實(shí)在有限，有好多不懂的地方。如果有的話請(qǐng)發(fā)到我的郵箱960696649@qq.com，麻煩您了~

很不錯(cuò)的socket教程

@有貓相伴的日子
項(xiàng)目中正打算使用這段代碼的，看你的品論才發(fā)現(xiàn) 確實(shí)沒有用到隊(duì)列，如果并發(fā)數(shù)量超過線程數(shù)會(huì)出現(xiàn)什么情況？