activemq java方式實現

2021-09-10 08:17:12 字數 1869 閱讀 5548

p2p模式(點對點模式):生產者生產的每一條訊息只能被消費一次。 

生產者:

public class testoriginalproducer 

public void send()

session.commit();

} catch (jm***ception e) finally catch (jm***ception e)

}if (connection != null) catch (jm***ception e)

}} }

}

消費者(第一種方式):

public class testoriginalconsumer 

public void receivemessage() else }}

} catch (jm***ception e) finally catch (jm***ception e)

}if (session != null) catch (jm***ception e)

}} }

}

消費者(第二種方式):

public class testoriginalconsumer 

public void receivemessage()

}});

} catch (jm***ception e) finally catch (jm***ception e)

}if (session != null) catch (jm***ception e)

}} }

}

發布訂閱模式:乙個生產者生產的訊息,可以被多個消費者消費,前提是消費者訂閱了生產者發布的主題。 

生產者: 

public class testoriginalprovider 

public void send()

session.commit();

} catch (jm***ception e) finally catch (jm***ception e)

}if (connection != null) catch (jm***ception e)

}} }

}

消費者(第一種方式):

public class testoriginalconsumer 

public void send() else }}

} catch (jm***ception e) finally catch (jm***ception e)

}if (connection != null) catch (jm***ception e)

}} }

}

消費者(第二種方式):

public class testoriginalconsumer 

public void send() }}

})} catch (jm***ception e) finally catch (jm***ception e)

}if (connection != null) catch (jm***ception e)

}} }

}

實模式定址方式

邏輯位址 即邏輯上的位址,實模式下由 段基位址 段內偏移 組成 保護模式下由 段選擇符 段內偏移 組成。線性位址 邏輯位址經分段機制後就成線性位址,它是平坦的 如果不啟用分頁,那麼此線性位址即實體地址。實體地址 剛才說了8086cpu 資料匯流排為 16位,也就是一次最多能取 2 16 64kb 資...

實現IDisposable介面的方式和實際應用

實現idisposable介面的類才能在建立此類的碼中使用using來自動釋放資源,如 public class userbll idisposable region 成員方法 成員方法 endregion region 釋放類資源 private bool m disposed public vo...

socket 使用select 非阻塞方式實現

select函式原型如下 int select int maxfds,fd set readfds,fd set writefds,fd set exceptfds,struct timeval timeout select系統呼叫是用來讓我們的程式監視多個檔案控制代碼 socket 控制代碼 的狀...