java多線程與socket
Ⅰ java socket多線程的問題可以多個線程使用同一個socket嗎
可以寫個demo試一下啊，應該是可以的，socket接收到的消息只能被其中一個線程接收。線程1 和2 接受到的肯定不是同一個消息。會有先後之分。看你怎麼控制。比如從接收的消息是ABCD，那麼這相當於一個資源。線程1和2在這里拿消息，拿到之後，socket裡面就少了，比如線程1拿到AB，線程2拿到CD
Ⅱ java一個Socket連接多線程是否能操作兩個讀取流
可以啊 ，不過需要新建兩個實現Runnable 借口的類，重寫run方法，一個實現讀取，另一個實現輸出的功能。再用兩條線程分別操作這兩個方法。
Ⅲ Java入門基礎需要學習什麼
Java入門基礎學習有很多坑，稍不留神可能你就學偏了，最後發現Java好難根本就學不會，Java確實有很多瑣碎的知識點，所以對於初學者學習Java入門基礎需要理清楚學習流程。那麼Java入門基礎需要學習什麼？
Java入門基礎是新手的敲門磚，千里之行，始於足下，基礎打好，以後學習就會一帆風順了。那麼Java入門基礎需要學習什麼呢？
1、Java簡介
了解什麼是Java；代碼語法基本格式；輸出表達式。
了解Java的大致編譯以及執行過程。
2、Java語言基礎、循環、數組；了解類和對象。
掌握Java的基本數據類型和引用數據類型有哪些。
掌握強制數據類型轉換和自動類型提升規則。
常滾沒褲量如何聲明及賦值。
循環的語法及作用。
掌握類的概念及什麼是對象。
3、OOP封裝大簡、繼承、多態
面向對象的三大特徵。(這塊內容非常重要，相對來說較為難以理解)
4、java.util.*包下的常用類。
lang包下的基本數據類型對應的包裝類(Byte,Short,Integer,Long,Double,Float,Character,Boolean)；
字元串相關的類String、StringBuffer、StringBuilder.
5、IO流操作，多線程以及Socket
掌握IO讀寫流相關的類，了解位元組流，字元流和字元流緩沖區；
掌握線程的概念，多線程的創建、啟動方式，鎖和同步的概念及運用；
掌握Socket通信的概念，如何聲明客戶端服務端，如何完成雙端通信；
掌握資料庫的基本概念，Mysql的安裝、啟動與停止；
Mysql資料庫客戶端的安裝與使用；
JDBC的概念，在Java中使用Mysql驅動包連接Mysql。
通過第一階段的學習掌握Java語法和常用類，資料庫入門技術相關知識。讓自己對於存儲，IO，這些有個大概的了解。
這時候，暫時不需要花大量的精力以及篇幅去學習多線程和Socket，當然這里不是說他們不重要，而是對於現階段的你，或許很難非常清晰的明白以及了解他們具體的作用。
這里第一節忽察陸略掉了Swing，Swing章節的內容可以不學，因為在實際的工作中基本上沒有用武之地。新手在第一階段的學習是最難熬的，因為這個階段需要記的東西特別多，但是又不像看小說一樣，什麼東西都能看明白，建議大家先過一遍基礎內容，不明白的地方可以先放一邊，回頭可以慢慢撿。
此外，不建議開始學就抱一本書在那裡慢慢啃，可以找一些講的比較好的視頻跟著學。
Java入門基礎其實沒有想像中的那麼難，我們制定好Java學習路線圖然後按照Java學習路線進行學習可能會事半功倍，如果你對於Java入門基礎需要學習什麼？還是比較迷茫建議填寫下面的表單即可獲得昌平北大青鳥Java培訓班免費體驗課程，讓昌平北大青鳥講師為你制定Java入門基礎學習路線圖。
Ⅳ socket java實現客戶端多線程接受消息並發送消息給伺服器，並發執行
客服端：
package MyKeFudaun;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class KeFuDuan {
public static void main(String[] args) {
KeFuDuan kf = new KeFuDuan();
kf.start();
}
public void start(){
Socket sco;
String ss= "";
try {
sco = new Socket("127.0.0.1",8866);
KeFuanJie kf = new KeFuanJie(sco);
KeFuWuFasong kfs = new KeFuWuFasong(sco);
kf.start();
kfs.start();
//sco.close();
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
class KeFuanJie extends Thread{
Socket soc;
String ss;
BufferedReader br;
public KeFuanJie(Socket soc){
try {
this.soc = soc;
br = new BufferedReader(new InputStreamReader(soc.getInputStream()));
} catch (IOException e) {
e.printStackTrace();
}
}
//負責接受服務端來的信息
public void run(){
while(true){
//接受伺服器端來的信息
try {
ss = br.readLine();
System.out.println("伺服器---->客服端： "+ss);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
//向伺服器發送東西
class KeFuWuFasong extends Thread{
Socket soc;
BufferedWriter bw;
BufferedReader brr;
public KeFuWuFasong(Socket soc){
this.soc = soc;
try {
brr =new BufferedReader(new InputStreamReader(System.in));
bw = new BufferedWriter(new OutputStreamWriter(soc.getOutputStream()));
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void run(){
while(true){
//向伺服器發送請求
try {
bw.write(brr.readLine());
bw.newLine();
bw.flush();// 或者用bw.close()
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
伺服器端：
package MyKeFudaun;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
Server server = new Server();
server.start();
}
public void start(){
try { //伺服器端打開埠
ServerSocket server = new ServerSocket(4499);
Socket socket = null;
ServerToClientThread stct = null;
while(true){
socket = server.accept(); //迎接（接收）客戶端的Socket訪問
stct = new ServerToClientThread(socket); //分配一個新線程負責和信賴的Socket溝通
stct.start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
package MyKeFudaun;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
public class ServerReceiveFromClient extends Thread{
Socket socket;
BufferedReader br;
String s;
public ServerReceiveFromClient(Socket socket){
this.socket = socket;
try {
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
} catch (IOException e) {
e.printStackTrace();
}
}
public void run(){
while(true){
try {
s = br.readLine();
System.out.println(socket.getInetAddress().getHostAddress()+"發送了:"+s);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
package MyKeFudaun;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class ServerToClientThread extends Thread{
Socket socket;
BufferedReader br;
BufferedWriter bw;
String s;
//建立的同時，和客戶端的Socket建立輸入、輸出流
public ServerToClientThread(Socket socket){
this.socket = socket;
try {
bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
} catch (IOException e) {
e.printStackTrace();
}
}
public void run(){
ServerReceiveFromClient srfc = new ServerReceiveFromClient(socket);
srfc.start();
while(true){
try {
bw.write("歡迎光臨。");
bw.newLine();
bw.flush();
Thread.sleep(10*1000);
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
Ⅳ JAVA程序完成伺服器和客戶端的SOCKET通訊，要求伺服器使用多線程接收和處理多個客戶端訪問請求
1. 客戶端程序
import java.io.*;
import java.net.*;
public class TalkClient {
public static void main(String args[]) {
try{
Socket socket=new Socket("127.0.0.1",4700);
//向本機的4700埠發出客戶請求
BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
//由系統標准輸入設備構造BufferedReader對象
PrintWriter os=new PrintWriter(socket.getOutputStream());
//由Socket對象得到輸出流，並構造PrintWriter對象
BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//由Socket對象得到輸入流，並構造相應的BufferedReader對象
String readline;
readline=sin.readLine(); //從系統標准輸入讀入一字元串
while(!readline.equals("bye")){
//若從標准輸入讀入的字元串為 "bye"則停止循環
os.println(readline);
//將從系統標准輸入讀入的字元串輸出到Server
os.flush();
//刷新輸出流，使Server馬上收到該字元串
System.out.println("Client:"+readline);
//在系統標准輸出上列印讀入的字元串
System.out.println("Server:"+is.readLine());
//從Server讀入一字元串，並列印到標准輸出上
readline=sin.readLine(); //從系統標准輸入讀入一字元串
} //繼續循環
os.close(); //關閉Socket輸出流
is.close(); //關閉Socket輸入流
socket.close(); //關閉Socket
}catch(Exception e) {
System.out.println("Error"+e); //出錯，則列印出錯信息
}
}
}
2. 伺服器端程序
import java.io.*;
import java.net.*;
import java.applet.Applet;
public class TalkServer{
public static void main(String args[]) {
try{
ServerSocket server=null;
try{
server=new ServerSocket(4700);
//創建一個ServerSocket在埠4700監聽客戶請求
}catch(Exception e) {
System.out.println("can not listen to:"+e);
//出錯，列印出錯信息
}
Socket socket=null;
try{
socket=server.accept();
//使用accept()阻塞等待客戶請求，有客戶
//請求到來則產生一個Socket對象，並繼續執行
}catch(Exception e) {
System.out.println("Error."+e);
//出錯，列印出錯信息
}
String line;
BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
//由Socket對象得到輸入流，並構造相應的BufferedReader對象
PrintWriter os=newPrintWriter(socket.getOutputStream());
//由Socket對象得到輸出流，並構造PrintWriter對象
BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
//由系統標准輸入設備構造BufferedReader對象
System.out.println("Client:"+is.readLine());
//在標准輸出上列印從客戶端讀入的字元串
line=sin.readLine();
//從標准輸入讀入一字元串
while(!line.equals("bye")){
//如果該字元串為 "bye"，則停止循環
os.println(line);
//向客戶端輸出該字元串
os.flush();
//刷新輸出流，使Client馬上收到該字元串
System.out.println("Server:"+line);
//在系統標准輸出上列印讀入的字元串
System.out.println("Client:"+is.readLine());
//從Client讀入一字元串，並列印到標准輸出上
line=sin.readLine();
//從系統標准輸入讀入一字元串
} //繼續循環
os.close(); //關閉Socket輸出流
is.close(); //關閉Socket輸入流
socket.close(); //關閉Socket
server.close(); //關閉ServerSocket
}catch(Exception e){
System.out.println("Error:"+e);
//出錯，列印出錯信息
}
}}