java文件級消息同步

A. 200分求java 用socket進行文件的同步

客戶端，.java:

public class Client {
public static void main(String[] args) throws IOException {
Socket socket = null;
String host = "127.0.0.1";

socket = new Socket(host, 4444);

File file = new File("M:\\test.xml");
// Get the size of the file
long length = file.length();
byte[] bytes = new byte[16 * 1024];
InputStream in = new FileInputStream(file);
OutputStream out = socket.getOutputStream();

int count;
while ((count = in.read(bytes)) > 0) {
out.write(bytes, 0, count);
}

out.close();
in.close();
socket.close();
}
}

服務端，Server.java:
public class Server {
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = null;

try {
serverSocket = new ServerSocket(4444);
} catch (IOException ex) {
System.out.println("Can't setup server on this port number. ");
}

Socket socket = null;
InputStream in = null;
OutputStream out = null;

try {
socket = serverSocket.accept();
} catch (IOException ex) {
System.out.println("Can't accept client connection. ");
}

try {
in = socket.getInputStream();
} catch (IOException ex) {
System.out.println("Can't get socket input stream. ");
}

try {
out = new FileOutputStream("M:\\test2.xml");
} catch (FileNotFoundException ex) {
System.out.println("File not found. ");
}

byte[] bytes = new byte[16*1024];

int count;
while ((count = in.read(bytes)) > 0) {
out.write(bytes, 0, count);
}

out.close();
in.close();
socket.close();
serverSocket.close();
}
}

B. java如何實現兩台計算機之間文件夾同步更新

實現兩台電腦同步文件夾的方法：
1、在登錄完成之後，客戶端會自動彈出配置向導。

2、選擇目標文件夾之後，客戶端會自動在該文件夾下面生成名為「」的同步文件夾。
即可實現成功。

C. java中實現同步的方法有哪兩種

Java的同步可以用synchronized關鍵字來實現。

sychronized可以同步代碼，需要綁定一個對象，如synchronized(obj){}
也可以同步一個方法，是對方法進行線程同步。如public void synchronized methodA(){}

D. java多線程解決同步問題的幾種方式，原理和代碼

在Java中一共有四種方法支持同步，其中前三個是同步方法，一個是管道方法。管道方法不建議使用。

• wait()/notify()方法

• await()/signal()方法

• BlockingQueue阻塞隊列方法

• PipedInputStream/PipedOutputStream

阻塞隊列的一個簡單實現：

• public class BlockingQueue {


• private List queue = new LinkedList();


• private int limit = 10;



• public BlockingQueue(int limit){


• this.limit = limit;


• }



• public synchronized void enqueue(Object item)throws InterruptedException {


• while(this.queue.size() == this.limit) {


• wait();


• }


• if(this.queue.size() == 0) {


• notifyAll();


• }


• this.queue.add(item);


• }



• public synchronized Object dequeue() throws InterruptedException{


• while(this.queue.size() == 0){


• wait();


• }


• if(this.queue.size() == this.limit){


• notifyAll();


• }



• return this.queue.remove(0);


• }}



在enqueue和dequeue方法內部，只有隊列的大小等於上限（limit）或者下限（0）時，才調用notifyAll方法。如果隊列的大小既不等於上限，也不等於下限，任何線程調用enqueue或者dequeue方法時，都不會阻塞，都能夠正常的往隊列中添加或者移除元素。


• wait()/notify()方法

• 生產者的主要作用是生成一定量的數據放到緩沖區中，然後重復此過程。與此同時，消費者也在緩沖區消耗這些數據。該問題的關鍵就是要保證生產者不會在緩沖區滿時加入數據，消費者也不會在緩沖區中空時消耗數據。

  要解決該問題，就必須讓生產者在緩沖區滿時休眠（要麼乾脆就放棄數據），等到下次消費者消耗緩沖區中的數據的時候，生產者才能被喚醒，開始往緩沖區添加數據。同樣，也可以讓消費者在緩沖區空時進入休眠，等到生產者往緩沖區添加數據之後，再喚醒消費者。

E. java怎麼同步發送及非同步發送簡訊例子解析

1. 發送簡訊的介面
   根據自己的情況選擇服務商。
   

2. 開發文檔
   從開發文檔中我們可以看到. 可以直接使用http請求也可以使用WebService請求發送簡訊. 由於DEMO文件夾下的java和jsp文件夾中的代碼都是使用http請求發送簡訊. 所以這里就不再細說了, 我們使用WebService的方式演示發送簡訊.
   

3. 生成客戶端代碼

   從介面文檔中我們知道它的WebService的WSDL的url為:http://106.ihuyi.cn/webservice/sms.php?WSDL那麼我們可以執行下面的命令生成客戶端代碼:

   wsimport -keep http://106.ihuyi.cn/webservice/sms.php?WSDL

   其中wsimport是JDK自帶的工具, -keep url選項是"保留生成的文件". 該命令會在當前目錄下生成sms.cn.ihuyi._106包, 以及眾多的類. 接下來開始編寫我們自己的代碼.

4. 定義介面

   為了方便, 這里我們首先定義一個介面:

   Sms.java
   publicinterfaceSms{
   /**
   *向mobile發送簡訊,內容為message
   *
   *@parammobile手機號
   *@parammessage簡訊內容
   *@return成功返回-1,否則返回其他值
   */
   intsendMessage(Stringmobile,Stringmessage);
   }

   這個介面很簡單, 只有一個方法. 這個方法用來發送簡訊.

5. 同步發送簡訊

   接下來我們首先實現一個同步發送簡訊的類:

   
   

   IhuyiSmsImpl.java
   {
   
   privateStringaccount;
   privateStringpassword;
   
   publicvoidsetAccount(Stringaccount){
   this.account=account;
   }
   
   publicvoidsetPassword(Stringpassword){
   this.password=password;
   }
   
   @Override
   publicintsendMessage(Stringmobile,Stringmessage){
   cn.ihuyi._106.Smsfactory=newcn.ihuyi._106.Sms();
   SmsSoapsmsSoap=factory.getSmsSoap();
   SubmitResultsubmit=smsSoap.submit(account,password,mobile,message);
   intcode=submit.getCode();
   if(code==2){
   return-1;
   }
   System.out.println("發送簡訊失敗,code:"+code);
   returncode;
   }
   }

6. 非同步發送簡訊

   由於發送簡訊涉及到網路通信, 因此sendMessage方法可能會有一些延遲. 為了改善用戶體驗, 我們可以使用非同步發送簡訊的方法. 原理很簡單: 如果用戶請求發送簡訊, 我們不是直接調用IhuyiSmsImpl的sendMessage方法, 而是將請求保存起來(生產者), 然後告訴用戶: 簡訊發送成功. 之後有若干個消費者取出任務, 調用sendMessage方法發送簡訊.

   這里, 我使用線程池完成上面的任務:

   AsyncSmsImpl.java
   {
   publicSmssendSms;
   =Executors.newFixedThreadPool(3);
   
   publicvoidsetSendSms(SmssendSms){
   this.sendSms=sendSms;
   }
   
   @Override
   publicintsendMessage(Stringmobile,Stringmessage){
   try{
   executorService.submit(()->sendSms.sendMessage(mobile,message));
   }
   catch(Exceptione){
   Sysemt.out.println("提交任務時發生錯誤"+e);
   return0;
   }
   return-1;
   }
   
   publicvoiddestroy(){
   try{
   executorService.shutdown();
   }
   catch(Exceptione){}
   }
   }

   在第17行, 我們獲得遠程對象的一個代理對象. 之後就可以通過這個代理對象進行發送簡訊, 查詢賬戶余額等操作.

   第18行, 使用該代理對象的submit方法提交了簡訊內容. 該方法的參數信息及返回值含義在介面文檔中有詳細的說明.

   第19行我們獲得了結果的狀態碼. 根據文檔上的說明, 狀態碼為2說明提交成功. 簡單起見, 這里我們只關注提交成功的情況. 需要注意的是, 狀態碼為2隻是說明提交成功. 根據官網上的"3-5秒內響應、100%到達", 我們可以推測. 如果提交成功, 那麼基本上3-5秒內,簡訊就會發送成功, 根據用戶的網路情況, 可能稍有延遲用戶就可以收到簡訊.

   使用這段代碼發送簡訊也很簡單, 直接new一個對象, 設置好賬號和密碼就可以發送簡訊了.

7. 代碼很簡單, 直接將Sms介面的sendMessage(mobile, message)方法作為一個任務加到線程池的任務隊列中. 這樣等到有空閑線程時, 就會執行sendSms.sendMessage(mobile, message)發送簡訊. 這里我們假設只要保存到線程池就可以成功發送簡訊. 因為發送失敗的情況實際上很罕見.
   

F. java中實現同步的方法到底有哪兩種

應該是同步方法和同步悶衫代碼塊。synchronized,wait與notify 這幾個是實現同步的進一步細節升扮操作，如果不是為了實現什麼多線程明細，就螞笑腔簡單的同步方法和同步代碼塊即可解決同步問題。

G. 在java中如何實現同步和非同步

同步和非同步一般是指多線程中對資源的大碧訪問的。最簡單的例子是在多襲蘆線程中對一個靜態整數進行遞增拍仿帶操作，然後在線程run方法上加synchronizied關鍵字試試。

H. java中什麼同步什麼是非同步分別用在什麼地方

java同步指的是synchronized機制，而非synchronized的都是非同步，弄懂同步的概念就大致明白了兩者的差別。

有關同步：
synchronized用來修飾一個方法或者一個代碼塊，它用來保證在同一時刻最多隻有一個線程執行該段代碼。
一、當兩個並發線程訪問同一個對象object中的這個synchronized(this)同步代碼塊時，一個時間內只能有一個線程得到執行。另一個線程必須等待當前線程執行完這個代碼塊以後才能執行該代碼塊。
二、然而，當一個線程訪問object的一個synchronized(this)同步代碼塊時，另一個線程仍然可以訪問該object中的非synchronized(this)同步代碼塊。
三、尤其關鍵的是，當一個線程訪問object的一個synchronized(this)同步代碼塊時，其他線程對object中所有其它synchronized(this)同步代碼塊的訪問將被阻塞。
四、第三個例子同樣適用其它同步代碼塊。也就是說，當一個線程訪問object的一個synchronized(this)同步代碼塊時，它就獲得了這個object的對象鎖。結果，其它線程對該object對象所有同步代碼部分的訪問都被暫時阻塞。
五、以上規則對其它對象鎖同樣適用。

示例代碼：
public class Thread1 implements Runnable {
public void run() {
synchronized(this) {
for (int i = 0; i < 5; i++) {
System.out.println(Thread.currentThread().getName() + " synchronized loop " + i);
}
}
}
public static void main(String[] args) {
Thread1 t1 = new Thread1();
Thread ta = new Thread(t1, "A");
Thread tb = new Thread(t1, "B");
ta.start();
tb.start();
}
}
結果：
A synchronized loop 0
A synchronized loop 1
A synchronized loop 2
A synchronized loop 3
A synchronized loop 4
B synchronized loop 0
B synchronized loop 1
B synchronized loop 2
B synchronized loop 3
B synchronized loop 4

I. java 數據同步要怎麼實現才好

首先得弄清楚 你的插入是對同一資料庫 還是不同資料庫的操作數據量大的時候 是否要求即時性 是否牽扯到事物
本人推薦 做一個跑批程序 進行同步數據 這樣能提高代碼性能 以及程序性能 當然 你所說的瓶頸 無非就是大數據量對資料庫的操作次數 以及海量數據造成程序效率的一個瓶頸 謝謝！

J. java如何實現伺服器之間的文件同步

給大家講講我的學習經歷吧，開始的兩年我學JAVA就是拿書看，練習書上的例子，但是一直沒有好的效果。後來因為項目需要開始正式使用JAVA開發，我發現以前練習的東西都忘光了，所以不得不在拿起書看。也就是基本上做了無用功了。現在想來因為大部分是抄來的，不怎麼動腦子，所以不清楚為什麼要這樣。所以我強烈建議你學習的時候給自己設定一個假想的項目目標，做一個東西出來，網頁也好，application也好，這樣你才會快速地學習。對java有了一定地感覺以後，你在去看他的DOCUMENT，看他的源碼，我建議你從低版本的JAVA源碼看起，因為他類少，看起來容易懂。然後你就會知道自己以前編碼的東西那些是很幼稚的，是可以用一兩句就能搞定的。如果你已經稍微有了些感覺，如果覺得合適也可以考慮參加一些培訓，畢竟比自學要輕鬆些，另外還可以學到別人的一些經驗，比如：「動力節點」或「王勇Java」一些學員反應不錯的，也建議你們多了解一下其它的培訓機構。Y.