1. 程式人生 > >python 傳送訊息到ActiveMq

python 傳送訊息到ActiveMq

生產:

你可以產生訊息 通過POST request to the server, like

curl -u admin:admin -d "body=message" http://localhost:8161/api/message/TEST?type=queue

-d/--data <data>   HTTP POST data (H)  
  
  
use  LWP::UserAgent;     
use LWP;    
use Encode;    
use LWP::Simple;    
use LWP::UserAgent;    
use HTTP::Cookies;    
use HTTP::Headers;    
use HTTP::Response;    
use Encode;    
use URI::Escape;    
use URI::URL;    
use JSON;    
use Data::Dumper;    
  my $ua = LWP::UserAgent->new;    
     $ua->agent("Mozilla/5.0 (Windows NT 6.1; rv:30.0) Gecko/20100101 Firefox/30.0");    
  my $cookie_jar = HTTP::Cookies->new(    
     file=>'lwp_cookies.txt',    
     autosave=>1,    
     ignore_discard=>1);    
     $ua->cookie_jar($cookie_jar);      
  my $login_url ="http://admin:admin\@192.168.137.3:8161/api/message/czcb2017?type=queue";      
   my $post = {      
     
         "body"=>"messag"  
    };      
    use JSON qw(encode_json);      
    $json_string = encode_json($post);      
      
    my $req = HTTP::Request->new(      
        'POST' => $login_url    
    );      
    $req->referer("https://wx.qq.com/?&lang=zh_CN");      
    $req->content_type('application/json; charset=UTF-8')      
      ;    #post請求,如果有傳送引數,必須要有這句      
    $req->content("$json_string");    #傳送post的引數      
    my $res = $ua->request($req);      
    print $res->content();            #獲取的是響應正文  
	
注意:  如果沒有型別引數是被指定,預設是建立一個topic.

改變預設的queue,初始化 servlet 使用一個初始引數在webapps/demo/WEB-INF/web.xml



# -*- coding: utf-8 -*-
import urllib2
import urllib
import cookielib
import json
import httplib
import time
import re
import os
import requests

s = requests.session()
print s.headers

login_url = 'http://admin:
[email protected]
:8161/api/message/czcb2017?type=queue' data = {'body': '12223345'} # data = urllib.urlencode(data) headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:54.0) Gecko/20100101 Firefox/54.0', 'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8', } response = s.post(login_url, data=data, headers=headers) print response print response.status_code print response.content

相關推薦

python 傳送訊息ActiveMq

生產: 你可以產生訊息 通過POST request to the server, like curl -u admin:admin -d "body=message" http://localhost:8161/api/message/TEST?type=queue

python傳送訊息給微信好友

咱們就直接上程式碼啦! import itchat import requests import re def login_sendmsg(text): itchat.login() # 只是普通的登陸,並不具有快取的功能 itchat.auto_login(hotReload=T

activemq傳送訊息接收不到問題排查

昨天,在公司開發環境上嘗試資料同步,涉及到兩個服務,服務A釋出主題,服務B監聽訊息,然後同步A表中的資料到B表; 由服務A通過activemq釋出訊息到一個topic:VirtualTopic.topic,發現服務A日誌上顯示傳送訊息成功,VirtualTopic.topic對應的Messa

使用python定時傳送訊息給微信好友

    以前以為微信沒有介面和python連線,但是最近發現了個庫wechat_sender,然後就稍微學習了下。還不深入,寫了一個簡易的測試程式作為初步進入。     需要用到的庫有 threading, wxpy前者需要用到Timer這個函式,作為定時

shell或python呼叫企業微信傳送訊息(實現報警功能)

shell或python呼叫企業微信傳送訊息(實現報警功能) 官方文件 企業內部開發簡易教程:https://work.weixin.qq.com/api/doc#90000/90003/90487服務端API:https://work.weixin.qq.com/api/doc#90000/90135/

Java模擬壓測裝置傳送訊息到伺服器(Rabbitmq) python模擬上報訊息到rabbitMQ(protobuf)

進入idea,新建一個maven專案 主要是模擬150個裝置同時併發,併發時間持續15min 1.建立客戶端,構造請求傳送到對應的rabbitmq的佇列,用的protobuf協議。 import com.google.protobuf.ByteString; import com.

python 釘釘機器人傳送訊息

import json import requests def sendmessage(message): url = 'https://oapi.dingtalk.com/robot/send?access_xxxxxxx' #釘釘機器人的webhook地址 HEADERS = {

Python && 微信企業號傳送訊息指令碼

#!/usr/local/python3/bin/python3 #-*- coding:utf-8 -*- import requests import json import sys import os #企業號及應用相關資訊 corp_id='wwe0x

python ZeroMQ實現1:N,非同步收發訊息(也可向指定客戶端傳送訊息

ZeroMQ的python版本和C/C++版本的介面差不多,要實現一個server對N個client,非同步方式,而且可以對指定的client傳送訊息,可以這樣: server採用ROUTER方式,cl

activeMQ高併發傳送訊息異常解決方法

高併發傳送訊息異常解決方法:現象:使用10個執行緒每100ms傳送一條訊息,大約3000多條後,出現異常,所有執行緒停             止:javax.jms.JMSException:Could not connect to brokerURL: tcp://loc

python傳送訊息(基於阿里雲平臺)

簡訊介面線上測試頁面:https://api.aliyun.com/new#/?product=Dysmsapi&api=SendSms&params={}&tab=DEMO&lang=PYTHON   一、首先,註冊阿里雲賬號一個,完成實名認證,然後在產品中找到

MQ系列3 使用Spring傳送,消費topic和queue訊息 activeMQ

簡介 實戰一 , 實戰二 介紹了ActiveMQ的基本概念和配置方式. 本篇將通過一個例項介紹使用spring傳送,消費topic, queue型別訊息的方法. 不懂topic和queue的google 之. 如圖示, TOPIC和QUEUE分別代表一個top

python入門(三) 實現QQ自動傳送訊息

前言 前面二章簡單過了一下python的基本知識,最近剛好需要實現QQ自動傳送訊息的指令碼,於是便拿python來練手。 業務邏輯 1、開啟需要傳送訊息的視窗 2、鎖定該視窗 3、將需要傳送的內容放到QQ視窗 4、模擬按鍵傳送enter鍵傳送訊息(QQ傳送訊息有二

寫一個python定時傳送訊息的指令碼——每天跟你女盆友說晚安

首先 你要有個女朋友效果需要安裝幾個包pip install wxpypip install wechat_senderpip install requests程式碼如下from __future__ import unicode_literals from threadin

activeMq傳送訊息變慢

之前,百度一直沒有找不到原因。特來寫個解決方案 解決方案: 我們現在用queue都是每天幾千條每月幾萬條吧,記憶體越吃越多,到時候就會堵了。 activemq重啟,釋放記憶體,就可以解決傳送訊息變

python win32api win32gui win32con 視窗控制代碼 傳送訊息 常用方法 鍵盤輸入

推薦微軟的Spy++來檢視視窗類名等資訊。 import win32gui import win32con import win32api # 從頂層視窗向下搜尋主視窗,無法搜尋子視窗 # FindWindow(lpClassName=None, lpW

python騷操作,指定微信好友傳送訊息

python 指定好友傳送訊息 大家在測試的時候儘量使用微信小號 不要不改程式碼就測試 這裡呼叫了金山詞霸的每日一句,你也可以指定文字資訊傳送,七夕快到了,你懂得。 from threading 

Python *args **kargs 傳參 釘釘自定義引數傳送訊息

Python *args  **kargs  傳參 Python *args *args:(表示的就是將實參中按照位置傳值,多出來的值都給args,且以元組的方式呈現) def foo(x,*

JMS訊息傳送機制ActiveMQ

JMS(Java Message Service) 訊息服務是一個面向訊息中介軟體(MOM)的API,用於在兩個應用程式之間,或者分散式系統中傳送訊息消費訊息,進行非同步通訊,資料互動。JMS提供的A

【轉】python win32api win32gui win32con 簡單操作教程(視窗控制代碼 傳送訊息 常用方法 鍵盤輸入)

import win32gui import win32con import win32api # 從頂層視窗向下搜尋主視窗,無法搜尋子視窗 # FindWindow(lpClassName=None, lpWindowName=None)  視窗類名 視窗標題名 hand