kafka의 통합 절차

kafka의 통합 절차
하나.통합kafka(생산자)절차 1.의존 가져오기(pom.xml) 2.프로필을 작성하고 프로필의 ip와 포트 번호를 수정하며 테마를 수정합니다 (producer.xml).만약 ssm 프로젝트에서spring을xml로 이 프로필을 불러옵니다. 재테스트 클래스에서 어떻게 불러옵니까? @RunWith(SpringJUnit4ClassRunner.class)//생산자의 설정 불러오기 @ContextConfiguration("classpath:producer.xml") 4.코드에 필요한 위치를 주입할 수 있습니다: @Autowired Kafka Template kafka Template;그리고 바로 send 방법을 사용해서 메시지를 보낼 수 있습니다!!(만약 우리가 보낸 것이 대상이라면 일반적인 상황에서 대상을 json으로 바꾸어 다시 보낼 것이다.)kafka Template.send(“cms_articles”,jsonString);
둘.카프카 소비자를 통합하는 절차 1.의존 가져오기(pom.xml) 2.프로필을 작성하고 IP와 포트 번호를 수정하며 감청하는 테마를 수정하고 감청기 종류의 위치를 지정합니다 (consumer.xml).만약 ssm 프로젝트에서spring을xml로 이 프로필을 불러옵니다. 테스트 클래스에서://소비자를 먼저 시작합니다. 소비자가 먼저 시작해야 kafka 생산자가 보낸 메시지가 항상 수신될 수 있기 때문입니다.public static void main (String [] args) {//소비자의 프로필을 로드합니다! new ClassPathXml Application Context ("classpath:consumer.xml");4. 감청기의 클래스를 작성하여 이 클래스가 Message Listener 인터페이스를 실현하도록 한다. onMessage 방법을 다시 쓰는 방법은 바로 정보를 감청하는 방법//파충류 프로젝트에서 보내온 글을 감청하는 json 꼬치public class Article Listener implements Message Listener {//는 정보를 감청하는 방법@Override public void on Message(Consumer Record data) {///여기서 메시지 수신 String msg = data.value} ()를 호출할 수 있다.
셋.레드를 통합하는 절차 1.의존 가져오기(pom.xml) 2.프로필을 작성하고 IP와 포트를 수정합니다.스프링을.xml 로드 redis.xml 4.코드의 위치에 RedisTemplate 5. 를 입력할 수 있습니다.레드리스에 대한 crud를 진행할 수 있습니다.
redis 최적화 단계 (캐시)/첫 접근 1.사용자가 처음 방문했을 때, Redis에서 데이터를 조회합니다.Redis에서 조회한 데이터가 비어 있는지 판단합니다.만약 비어 있다면, 첫 방문을 의미합니다. mysql에서 데이터를 조회하고, Redis에 한 부를 저장하여, 프론트에 되돌려줍니다.만약 비어 있지 않다면, 첫 방문이 아니라는 것을 의미하며, 직접 프론트 데스크로 되돌아온다
넷.ElasticSearch를 통합하려면 1.의존 가져오기(pom.xml) 2.구성 파일 작성(es.xml)3.IP 주소와 포트 번호 수정 & 창고 인터페이스의 패키지 스캔 위치 수정 4.스프링에 에스를 불러오라고 하세요.xml 5.3단계 창고 인터페이스 패키지의 위치에서 창고 인터페이스 XXXRepository 6.창고 인터페이스가 Elastic Search Repository를 계승하게 한 후 자동으로 간단한 CRUD 방법을 갖추게 됩니다. extends Elasticsearch Repository 7.엔티티 클래스를 설명하는 다양한 메모(인덱스 라이브러리 이름, 테이블 이름, 메인 키, 엔티티 클래스 속성 저장 매개 변수 지정)///라이브러리 이름(라이브러리 이름은 소문자로 작성해야 하며 특수 문자를 허용하지 않으면 오류가 발생), 테이블 이름 @Document(indexName=test user), type="user") @Id//name의 값을 인덱스할지 여부를 지정합니다. 2.저장 여부 3.name 값의 분사 방식 4.검색 키워드 분사 방식 5 이 필드의 값을 @Field(index=true,store=true,analyzer="ik smart", searchAnalyzer="ik smart", type=FieldType.text) 8은 임의의 위치에서 창고 인터페이스를 주입하거나 ElasticSearchTemplate@Autowired Userred UResitory pository를 주입할 수 있습니다. @Autowired ElasticsearchTemplate elasticsearchTemplate; crud 방법을 호출할 수 있습니다. 주의: 복잡한 조회를 하려면 사용자 정의 방법이 필요합니다.사용자 정의 메서드의 규칙은 명명 규칙에 따라 메서드의 구체적인 예를 명명해야 합니다. 즉, List findByName(String name).

//      
//	List findByAddress(String address);
//	
//	//         
//	List findByAddressAndName(String address,String name);

//	//         
//	List findByAddressOrName(String address,String name);

//  id  5   
//	List findByIdLessThan(int id);

//       -     
List findByPriceBetween(double money,double money)

cms시스템에서 검색(하이라이트 디스플레이) 1.페이지 수준 ->에는 검색 상자와 검색 단추가 있어야 합니다. 2.검색 상자의form 폼의 요청 방식과 요청 경로를 수정합니다.프론트 데스크톱의form 표현 요청 방식에 따라 백엔드 컨트롤러층을 작성합니다.(컨트롤러층의 코드로 하여금 우리의 검색 키워드를 수신하게 한다)4.우리의 검색 데이터는 es 인덱스 라이브러리에서 찾기 때문에 우리가 해야 할 일은 mysql에서 데이터를 조회한 다음에 es 인덱스 라이브러리에 저장하면 5.cms시스템에 통합es기술이 있기 때문에 저는 또 한 가지 일을 해야 합니다. cms시스템에서 통합es------>참고46.창고 인터페이스 (findByTitle () 를 호출하여 일반 검색을 할 수 있습니다.강조를 실현하려면: 강조된 도구 클래스를 호출합니다//1.필요한 템플릿 클래스 검색 2.작업할 솔리드 클래스 유형 지정 3.현재 페이지 4.페이지당 몇 개가 표시됩니다.string 형식의 그룹 그룹에 저장된 필드는 다음과 같습니다. (실체 클래스의 필드와 일치해야 합니다.)정렬할 필드 7 지정검색의 키워드 PageInfo info = (PageInfo) HLutils.findByHighLight(elasticsearchTemplate, cms_article.class, pageNum, pageSize, new String[] {“title”}, “id”, key);
=================================================================================================================linux 시스템에 프로젝트를 배치하다데이터베이스 연결 수정:db.properties에서 mysql의 ip 주소를 윈도우즈의 ip(ipconfig로 씁니다. 무선 네트워크가 연결되어 있으면 무선 네트워크 어댑터 Ipv4의 주소를 찾습니다. 연결된 것이 네트워크라면 랜을 찾습니다. 로컬 연결 ipv4)2.프로젝트에 대해 Run as --> Maven build -->package(테스트 skip tests 건너뛰기)를 오른쪽 단추로 눌러서 실행이 완료될 때까지 기다립니다.실행이 끝난 후 로그에서 Warm 패키지가 있는 위치를 찾아서 데스크톱에 copy를 꺼내서 Root라고 이름을 바꿉니다.war 4.루트를.war는 linux의tomcat 디렉터리에 있는 웹 앱에 업로드하고 ROOT 폴더를 삭제합니다.tomcat의 bin 디렉터리에 한 단계 올라가서 실행 – >./bin/shutdown.shtomcat->tomcat 로그tail-f logs/catalina를 먼저 닫습니다.out --> ./bin/startup.shtomcat 6. 열기브라우저 직접 입력: linux의 ip: 8080/접근 경로 7.linux의 ip 가상 도메인 이름 – > c디스크에서 다음과 같은 경로를 찾습니다: C:\Windows\System32\drivers\etc에서hosts 파일을 찾고hosts 파일을 오른쪽 단추로 열고 192.168.21.128ww.gengjiaxin.com 저장 9.브라우저에서 도메인 네임에 구호를 붙이는 형식으로 주의에 접근했습니다: = 프로젝트를 배치할 때: 만약 당신의 절차가 옳다고 생각하면 프로젝트도 옳지만, 프로젝트가 계속 빙글빙글 돌기 때문에 윈도우즈의 mysql가 설치되었을 때 원격 사용자의 접근을 허용하지 않습니다. (localhost나 127.0.0.1만 접근할 수 있습니다.) 작은 녹색 잎을 열고 다음과 같은 두 가지 명령을 실행하십시오: GRANT ALL PRI VILEGES ON.TO'root'@'%'IDENTIFIED BY'이것은 당신의 mysql 비밀번호입니다'.flush privileges;